Package io.github.flink.gcp.connector.bigquery.sink

Interface BigQueryLineageSink<T>

All Superinterfaces:
org.apache.flink.streaming.api.lineage.LineageVertexProvider
All Known Implementing Classes:
BigQueryBufferedStreamSink, BigQueryDefaultStreamSink, BigQueryFileLoadsSink
@Internal public interface BigQueryLineageSink<T> extends org.apache.flink.streaming.api.lineage.LineageVertexProvider
Internal Table metadata handoff shared by the concrete BigQuery write methods.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.flink.api.connector.sink2.Sink<T>
    withTableLineage(String logicalName)
    Returns a copy with a SQL catalog identity, retaining the concrete sink's runtime abilities.

    Methods inherited from interface org.apache.flink.streaming.api.lineage.LineageVertexProvider

    getLineageVertex

  • Method Details

    • withTableLineage

      org.apache.flink.api.connector.sink2.Sink<T> withTableLineage(String logicalName)
      Returns a copy with a SQL catalog identity, retaining the concrete sink's runtime abilities.