Package io.github.flink.gcp.connector.bigquery.sink
package io.github.flink.gcp.connector.bigquery.sink
-
ClassDescriptionInternal Table metadata handoff shared by the concrete BigQuery write methods.Entry 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.Whether theWriteMethod.STORAGE_API_AT_LEAST_ONCEwriter commits a table's append requests in the order a sink subtask sent them, so that no row commits ahead of a row the subtask received earlier and sent in an earlier request.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, clustering, and the table's description and labels.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.