Package io.github.flink.gcp.connector.spanner.table

Class SpannerTableLineage

java.lang.Object
io.github.flink.gcp.connector.spanner.table.SpannerTableLineage
All Implemented Interfaces:
Serializable
@Internal public final class SpannerTableLineage extends Object implements Serializable
Immutable physical identities carried from the Table factory to its runtime providers.
See Also:

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    equals(Object other)
     
    static SpannerTableLineage
    from(String logicalName, org.apache.flink.configuration.ReadableConfig config)
    Captures only resource options, before pushdown or runtime client creation.
    int
    hashCode()
     
    <T> org.apache.flink.api.connector.sink2.Sink<T>
    sink(org.apache.flink.api.connector.sink2.Sink<T> sink)
    Adapts metadata while retaining the sink's writer creation path.
    <T, S extends org.apache.flink.api.connector.source.SourceSplit, E>
    org.apache.flink.api.connector.source.Source<T,S,E>
    source(org.apache.flink.api.connector.source.Source<T,S,E> source, org.apache.flink.api.common.typeinfo.TypeInformation<T> type)
    Adapts metadata while retaining the source's runtime operations and produced type.

    Methods inherited from class java.lang.Object

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

  • Method Details

    • from

      public static SpannerTableLineage from(String logicalName, org.apache.flink.configuration.ReadableConfig config)
      Captures only resource options, before pushdown or runtime client creation.

    • source

      public <T, S extends org.apache.flink.api.connector.source.SourceSplit, E> org.apache.flink.api.connector.source.Source<T,S,E> source(org.apache.flink.api.connector.source.Source<T,S,E> source, org.apache.flink.api.common.typeinfo.TypeInformation<T> type)
      Adapts metadata while retaining the source's runtime operations and produced type.

    • sink

      public <T> org.apache.flink.api.connector.sink2.Sink<T> sink(org.apache.flink.api.connector.sink2.Sink<T> sink)
      Adapts metadata while retaining the sink's writer creation path.

    • equals

      public boolean equals(Object other)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object