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, String logicalName)
    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, String logicalName)
    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, @Nullable String logicalName)
      Reports the configured table with the source's actual boundedness.

    • sink

      public static org.apache.flink.streaming.api.lineage.LineageVertex sink(DestinationResolver<?> resolver, @Nullable String logicalName)
      Inspects a fixed resolver without evaluating a destination against a record.