Package io.github.flink.gcp.connector.bigquery.sink
package io.github.flink.gcp.connector.bigquery.sink
-
ClassDescriptionEntry point for building a BigQuery sink.Builder for BigQuery sinks, obtained from
BigQuerySink.builder().Immutable configuration shared by allWriteMethodimplementations, assembled byBigQuerySinkBuilder.Desired BigQuery table contract for CDC writes.Builder forCdcTableOptions.Supplies the desired CDC table contract for each destination.Policy for a BigQuery CDC destination table that already exists.Whether the sink may create destination tables that do not exist.CrossVersionSink<InputT>The cross-version seam every sink in this module implements instead ofSinkdirectly.The result of resolving a BigQuery destination for one record.Dispatches destination-resolution results to the writer that owns the record.Handles every destination-resolution result supported by the connector.Resolves the destination table for each record, enabling one sink instance to write to many tables (dynamic destinations).ADestinationResolverreturning one fixed destination for every record.Options gating connector-driven destination table schema updates.Builder forSchemaUpdateOptions.Options applied when the sink creates a destination table underCreateDisposition.CREATE_IF_NEEDED: time partitioning and clustering.Builder forTableCreateOptions.Granularity of time-based partitioning.Supplies per-destinationTableCreateOptionsfor tables created underCreateDisposition.CREATE_IF_NEEDED.A fully-qualified BigQuery table reference: project, dataset and table.An explicit, record-specific destination-resolution failure.How data lands in a destination table that already contains data.The mechanism used to write records to BigQuery.