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

Packages that use io.github.flink.gcp.connector.bigquery.sink

Package	Description
io.github.flink.gcp.connector.bigquery	Google BigQuery connector for Apache Flink.
io.github.flink.gcp.connector.bigquery.sink
io.github.flink.gcp.connector.bigquery.sink.failure
io.github.flink.gcp.connector.bigquery.sink.fileloads
io.github.flink.gcp.connector.bigquery.sink.fileloads.committer
io.github.flink.gcp.connector.bigquery.sink.fileloads.loadjob
io.github.flink.gcp.connector.bigquery.sink.fileloads.writer
io.github.flink.gcp.connector.bigquery.sink.serializer
io.github.flink.gcp.connector.bigquery.sink.serializer.avro
io.github.flink.gcp.connector.bigquery.sink.serializer.json
io.github.flink.gcp.connector.bigquery.sink.serializer.proto
io.github.flink.gcp.connector.bigquery.sink.storage
io.github.flink.gcp.connector.bigquery.sink.storage.committer
io.github.flink.gcp.connector.bigquery.sink.storage.writer
io.github.flink.gcp.connector.bigquery.sink.tables
io.github.flink.gcp.connector.bigquery.source
io.github.flink.gcp.connector.bigquery.source.query
io.github.flink.gcp.connector.bigquery.table
io.github.flink.gcp.connector.bigquery.table.sink
io.github.flink.gcp.connector.bigquery.table.source

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery

Class	Description
DestinationResolver	Resolves the destination table for each record, enabling one sink instance to write to many tables (dynamic destinations).
TableDestination	A fully-qualified BigQuery table reference: project, dataset and table.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.sink

Class	Description
BigQuerySinkBuilder	Builder for BigQuery sinks, obtained from BigQuerySink.builder().
CdcTableOptions	Desired BigQuery table contract for CDC writes.
CdcTableOptions.Builder	Builder for CdcTableOptions.
CdcTableOptionsProvider	Supplies the desired CDC table contract for each destination.
CdcTableReconciliationPolicy	Policy for a BigQuery CDC destination table that already exists.
CreateDisposition	Whether the sink may create destination tables that do not exist.
DestinationResolution	The result of resolving a BigQuery destination for one record.
DestinationResolutionDispatcher.Visitor	Handles every destination-resolution result supported by the connector.
DestinationResolver	Resolves the destination table for each record, enabling one sink instance to write to many tables (dynamic destinations).
SchemaUpdateOptions	Options gating connector-driven destination table schema updates.
SchemaUpdateOptions.Builder	Builder for SchemaUpdateOptions.
TableCreateOptions	Options applied when the sink creates a destination table under CreateDisposition.CREATE_IF_NEEDED: time partitioning and clustering.
TableCreateOptions.Builder	Builder for TableCreateOptions.
TableCreateOptions.TimePartitioningType	Granularity of time-based partitioning.
TableCreateOptionsProvider	Supplies per-destination TableCreateOptions for tables created under CreateDisposition.CREATE_IF_NEEDED.
TableDestination	A fully-qualified BigQuery table reference: project, dataset and table.
UnroutableRecord	An explicit, record-specific destination-resolution failure.
WriteDisposition	How data lands in a destination table that already contains data.
WriteMethod	The mechanism used to write records to BigQuery.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.sink.failure

Class	Description
TableDestination	A fully-qualified BigQuery table reference: project, dataset and table.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.sink.fileloads

Class	Description
BigQueryLineageSink	Internal Table metadata handoff shared by the concrete BigQuery write methods.
BigQuerySinkConfig	Immutable configuration shared by all WriteMethod implementations, assembled by BigQuerySinkBuilder.
CrossVersionSink	The cross-version seam every sink in this module implements instead of Sink directly.
TableDestination	A fully-qualified BigQuery table reference: project, dataset and table.
WriteDisposition	How data lands in a destination table that already contains data.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.sink.fileloads.committer

Class	Description
BigQuerySinkConfig	Immutable configuration shared by all WriteMethod implementations, assembled by BigQuerySinkBuilder.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.sink.fileloads.loadjob

Class	Description
BigQuerySinkConfig	Immutable configuration shared by all WriteMethod implementations, assembled by BigQuerySinkBuilder.
TableDestination	A fully-qualified BigQuery table reference: project, dataset and table.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.sink.fileloads.writer

Class	Description
BigQuerySinkConfig	Immutable configuration shared by all WriteMethod implementations, assembled by BigQuerySinkBuilder.
DestinationResolutionDispatcher.Visitor	Handles every destination-resolution result supported by the connector.
TableDestination	A fully-qualified BigQuery table reference: project, dataset and table.
UnroutableRecord	An explicit, record-specific destination-resolution failure.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.sink.serializer

Class	Description
TableDestination	A fully-qualified BigQuery table reference: project, dataset and table.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.sink.serializer.avro

Class	Description
TableDestination	A fully-qualified BigQuery table reference: project, dataset and table.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.sink.serializer.json

Class	Description
TableDestination	A fully-qualified BigQuery table reference: project, dataset and table.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.sink.serializer.proto

Class	Description
TableDestination	A fully-qualified BigQuery table reference: project, dataset and table.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.sink.storage

Class	Description
BigQueryLineageSink	Internal Table metadata handoff shared by the concrete BigQuery write methods.
BigQuerySinkConfig	Immutable configuration shared by all WriteMethod implementations, assembled by BigQuerySinkBuilder.
CrossVersionSink	The cross-version seam every sink in this module implements instead of Sink directly.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.sink.storage.committer

Class	Description
CreateDisposition	Whether the sink may create destination tables that do not exist.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.sink.storage.writer

Class	Description
BigQuerySinkConfig	Immutable configuration shared by all WriteMethod implementations, assembled by BigQuerySinkBuilder.
DestinationResolutionDispatcher.Visitor	Handles every destination-resolution result supported by the connector.
TableDestination	A fully-qualified BigQuery table reference: project, dataset and table.
UnroutableRecord	An explicit, record-specific destination-resolution failure.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.sink.tables

Class	Description
CdcTableOptions	Desired BigQuery table contract for CDC writes.
CdcTableReconciliationPolicy	Policy for a BigQuery CDC destination table that already exists.
CreateDisposition	Whether the sink may create destination tables that do not exist.
SchemaUpdateOptions	Options gating connector-driven destination table schema updates.
TableCreateOptions	Options applied when the sink creates a destination table under CreateDisposition.CREATE_IF_NEEDED: time partitioning and clustering.
TableCreateOptionsProvider	Supplies per-destination TableCreateOptions for tables created under CreateDisposition.CREATE_IF_NEEDED.
TableDestination	A fully-qualified BigQuery table reference: project, dataset and table.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.source

Class	Description
TableDestination	A fully-qualified BigQuery table reference: project, dataset and table.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.source.query

Class	Description
TableDestination	A fully-qualified BigQuery table reference: project, dataset and table.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.table

Class	Description
CdcTableReconciliationPolicy	Policy for a BigQuery CDC destination table that already exists.
CreateDisposition	Whether the sink may create destination tables that do not exist.
TableCreateOptions.TimePartitioningType	Granularity of time-based partitioning.
WriteDisposition	How data lands in a destination table that already contains data.
WriteMethod	The mechanism used to write records to BigQuery.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.table.sink

Class	Description
CdcTableOptions	Desired BigQuery table contract for CDC writes.
CdcTableReconciliationPolicy	Policy for a BigQuery CDC destination table that already exists.
CreateDisposition	Whether the sink may create destination tables that do not exist.
SchemaUpdateOptions	Options gating connector-driven destination table schema updates.
TableCreateOptions	Options applied when the sink creates a destination table under CreateDisposition.CREATE_IF_NEEDED: time partitioning and clustering.
TableDestination	A fully-qualified BigQuery table reference: project, dataset and table.
WriteMethod	The mechanism used to write records to BigQuery.

Classes in io.github.flink.gcp.connector.bigquery.sink used by io.github.flink.gcp.connector.bigquery.table.source

Class	Description
TableDestination	A fully-qualified BigQuery table reference: project, dataset and table.