Package io.github.flink.gcp.connector.bigtable.sink
package io.github.flink.gcp.connector.bigtable.sink
-
ClassDescriptionSelects eager writes or checkpoint-owned, replay-protected writes.At-least-once sink applying one row mutation per record through the
MutateRowsbulk batcher ofgoogle-cloud-bigtable.Entry point for building a Bigtable sink.Builder for Bigtable sinks, obtained fromBigtableSink.builder().Immutable sink configuration assembled byBigtableSinkBuilder.Settings for checkpoint-owned writes.Builds an immutable staged configuration.Tuning options for the sink's writer: the batch thresholds handed to the client, and the writer's own bounds on unacknowledged entries.Builder forBigtableWriterOptions.The value type of a column family created by the connector.Whether the sink may create the destination table when it does not exist.CrossVersionSink<InputT>The cross-version seam every sink in this module implements instead ofSinkdirectly.Resolves the destination table for each record, enabling one sink instance to write to many tables (dynamic destinations).A single row mutation that terminally failed to be written to Bigtable, as passed to aFailureHandler<FailedMutation>.ADestinationResolverreturning one fixed destination for every record, which is whatBigtableSinkBuilder.table(...)builds.A garbage-collection rule for a column family the sink creates, mirroring the four rule shapes Bigtable's admin API takes: a version cap, an age cap, and their union and intersection.The rule shapes Bigtable's admin API takes.The settings for the table the sink creates underCreateDisposition.CREATE_IF_NEEDED: its column families, theirvalue typesand optionalgarbage-collection rules.Builder forTableCreateOptions.