org.apache.beam.sdk.metrics

Class Lineage

java.lang.Object

org.apache.beam.sdk.metrics.Lineage

public class Lineage
extends java.lang.Object

Standard collection of metrics used to record source and sinks information for lineage tracking.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	LINEAGE_NAMESPACE
static java.lang.String	SINK_METRIC_NAME
static java.lang.String	SOURCE_METRIC_NAME

Constructor Summary

Constructors

Constructor and Description
Lineage()

Method Summary

Modifier and Type	Method and Description
static StringSet	getSinks() StringSet representing sinks.
static StringSet	getSources() StringSet representing sources and optionally side inputs.

Methods inherited from class java.lang.Object

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

Field Detail

LINEAGE_NAMESPACE

public static final java.lang.String LINEAGE_NAMESPACE

See Also:

Constant Field Values

SOURCE_METRIC_NAME

public static final java.lang.String SOURCE_METRIC_NAME

See Also:

Constant Field Values

SINK_METRIC_NAME

public static final java.lang.String SINK_METRIC_NAME

See Also:

Constant Field Values

Constructor Detail

Lineage

public Lineage()

Method Detail

getSources

public static StringSet getSources()

StringSet representing sources and optionally side inputs.

getSinks

public static StringSet getSinks()

StringSet representing sinks.