Class Hierarchy
- java.lang.Object
- io.github.flink.gcp.connector.bigquery.sink.BigQuerySink
- io.github.flink.gcp.connector.bigquery.sink.BigQuerySinkBuilder<T>
- io.github.flink.gcp.connector.bigquery.sink.BigQuerySinkConfig<T> (implements java.io.Serializable)
- io.github.flink.gcp.connector.bigquery.sink.CdcTableOptions (implements java.io.Serializable)
- io.github.flink.gcp.connector.bigquery.sink.CdcTableOptions.Builder
- io.github.flink.gcp.connector.bigquery.sink.DestinationResolution
- io.github.flink.gcp.connector.bigquery.sink.TableDestination (implements java.io.Serializable)
- io.github.flink.gcp.connector.bigquery.sink.UnroutableRecord (implements io.github.flink.gcp.connector.bigquery.sink.failure.BigQueryFailure)
- io.github.flink.gcp.connector.bigquery.sink.DestinationResolutionDispatcher
- io.github.flink.gcp.connector.bigquery.sink.FixedDestinationResolver (implements io.github.flink.gcp.connector.bigquery.sink.DestinationResolver<T>)
- io.github.flink.gcp.connector.bigquery.sink.SchemaUpdateOptions (implements java.io.Serializable)
- io.github.flink.gcp.connector.bigquery.sink.SchemaUpdateOptions.Builder
- io.github.flink.gcp.connector.bigquery.sink.TableCreateOptions (implements java.io.Serializable)
- io.github.flink.gcp.connector.bigquery.sink.TableCreateOptions.Builder
Interface Hierarchy
- io.github.flink.gcp.connector.bigquery.sink.DestinationResolutionDispatcher.Visitor<T>
- org.apache.flink.streaming.api.lineage.LineageVertexProvider
- io.github.flink.gcp.connector.bigquery.sink.BigQueryLineageSink<T>
- java.io.Serializable
- io.github.flink.gcp.connector.bigquery.sink.CdcTableOptionsProvider
- io.github.flink.gcp.connector.bigquery.sink.DestinationResolver<T>
- org.apache.flink.api.connector.sink2.Sink<InputT>
- io.github.flink.gcp.connector.bigquery.sink.CrossVersionSink<InputT>
- io.github.flink.gcp.connector.bigquery.sink.TableCreateOptionsProvider
Enum Hierarchy
- java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
- io.github.flink.gcp.connector.bigquery.sink.CdcTableReconciliationPolicy
- io.github.flink.gcp.connector.bigquery.sink.CreateDisposition
- io.github.flink.gcp.connector.bigquery.sink.TableCreateOptions.TimePartitioningType
- io.github.flink.gcp.connector.bigquery.sink.WriteDisposition
- io.github.flink.gcp.connector.bigquery.sink.WriteMethod
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)