co.cask.cdap.data2.metadata.writer

Class NoOpLineageWriter

java.lang.Object

co.cask.cdap.data2.metadata.writer.NoOpLineageWriter

All Implemented Interfaces:

LineageWriter

public class NoOpLineageWriter
extends Object
implements LineageWriter

No-op LineageWriter.

Constructor Summary

Constructors

Constructor and Description
NoOpLineageWriter()

Method Summary

Methods

Modifier and Type	Method and Description
void	addAccess(Id.Run run, Id.DatasetInstance datasetInstance, AccessType accessType) Add a program-dataset access.
void	addAccess(Id.Run run, Id.DatasetInstance datasetInstance, AccessType accessType, Id.NamespacedId component) Add a program-dataset access.
void	addAccess(Id.Run run, Id.Stream stream, AccessType accessType) Add a program-stream access.
void	addAccess(Id.Run run, Id.Stream stream, AccessType accessType, Id.NamespacedId component) Add a program-stream access.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NoOpLineageWriter

public NoOpLineageWriter()

Method Detail

addAccess

public void addAccess(Id.Run run,
             Id.DatasetInstance datasetInstance,
             AccessType accessType)

Description copied from interface: LineageWriter

Add a program-dataset access.

Specified by:

addAccess in interface LineageWriter

Parameters:

run - program run information

datasetInstance - dataset accessed by the program

accessType - access type

addAccess

public void addAccess(Id.Run run,
             Id.DatasetInstance datasetInstance,
             AccessType accessType,
             @Nullable
             Id.NamespacedId component)

Description copied from interface: LineageWriter

Add a program-dataset access.

Specified by:

addAccess in interface LineageWriter

Parameters:

run - program run information

datasetInstance - dataset accessed by the program

accessType - access type

component - program component such as flowlet id, etc.

addAccess

public void addAccess(Id.Run run,
             Id.Stream stream,
             AccessType accessType)

Description copied from interface: LineageWriter

Add a program-stream access.

Specified by:

addAccess in interface LineageWriter

Parameters:

run - program run information

stream - stream accessed by the program

accessType - access type

addAccess

public void addAccess(Id.Run run,
             Id.Stream stream,
             AccessType accessType,
             @Nullable
             Id.NamespacedId component)

Description copied from interface: LineageWriter

Add a program-stream access.

Specified by:

addAccess in interface LineageWriter

Parameters:

run - program run information

stream - stream accessed by the program

accessType - access type

component - program component such as flowlet id, etc.