co.cask.cdap.data2.metadata.writer

Interface LineageWriter

All Known Implementing Classes:

BasicLineageWriter, NoOpLineageWriter

public interface LineageWriter

Defines an interface to record program-dataset access records.

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.

Method Detail

addAccess

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

Add a program-dataset access.

Parameters:

run - program run information

datasetInstance - dataset accessed by the program

accessType - access type

addAccess

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

Add a program-dataset access.

Parameters:

run - program run information

datasetInstance - dataset accessed by the program

accessType - access type

component - program component such as flowlet id, etc.

addAccess

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

Add a program-stream access.

Parameters:

run - program run information

stream - stream accessed by the program

accessType - access type

addAccess

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

Add a program-stream access.

Parameters:

run - program run information

stream - stream accessed by the program

accessType - access type

component - program component such as flowlet id, etc.