Package io.github.flink.gcp.connector.bigtable

Class BigtableLineage

java.lang.Object

io.github.flink.gcp.connector.bigtable.BigtableLineage

@Internal
public final class BigtableLineage
extends Object

Configured table identities shared by the Bigtable sources and sink families.

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.streaming.api.lineage.LineageVertex	sink(DestinationResolver<?> resolver, LineageMetadata lineage)	Inspects a fixed resolver without evaluating a destination against a record.
static org.apache.flink.streaming.api.lineage.SourceLineageVertex	source(TableDestination table, org.apache.flink.api.connector.source.Boundedness boundedness, LineageMetadata lineage)	Reports the configured table with the source's actual boundedness.

Methods inherited from class java.lang.Object

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

Method Details

source

public static org.apache.flink.streaming.api.lineage.SourceLineageVertex source(TableDestination table,
 org.apache.flink.api.connector.source.Boundedness boundedness,
 LineageMetadata lineage)

Reports the configured table with the source's actual boundedness.

sink

public static org.apache.flink.streaming.api.lineage.LineageVertex sink(DestinationResolver<?> resolver,
 LineageMetadata lineage)

Inspects a fixed resolver without evaluating a destination against a record.