Uses of Package
io.github.flink.gcp.connector.bigtable.sink
Packages that use io.github.flink.gcp.connector.bigtable.sink
Package
Description
Google Cloud Bigtable connector for Apache Flink.
-
Classes in io.github.flink.gcp.connector.bigtable.sink used by io.github.flink.gcp.connector.bigtableClassDescriptionResolves the destination table for each record, enabling one sink instance to write to many tables (dynamic destinations).
-
Classes in io.github.flink.gcp.connector.bigtable.sink used by io.github.flink.gcp.connector.bigtable.sinkClassDescriptionSelects 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.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.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>.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. -
Classes in io.github.flink.gcp.connector.bigtable.sink used by io.github.flink.gcp.connector.bigtable.sink.conditionalClassDescriptionThe cross-version seam every sink in this module implements instead of
Sinkdirectly.Resolves the destination table for each record, enabling one sink instance to write to many tables (dynamic destinations). -
Classes in io.github.flink.gcp.connector.bigtable.sink used by io.github.flink.gcp.connector.bigtable.sink.mutaterows.writerClassDescriptionImmutable sink configuration assembled by
BigtableSinkBuilder.Tuning options for the sink's writer: the batch thresholds handed to the client, and the writer's own bounds on unacknowledged entries.The settings for the table the sink creates underCreateDisposition.CREATE_IF_NEEDED: its column families, theirvalue typesand optionalgarbage-collection rules. -
Classes in io.github.flink.gcp.connector.bigtable.sink used by io.github.flink.gcp.connector.bigtable.sink.readmodifywriteClassDescriptionThe cross-version seam every sink in this module implements instead of
Sinkdirectly.Resolves the destination table for each record, enabling one sink instance to write to many tables (dynamic destinations). -
Classes in io.github.flink.gcp.connector.bigtable.sink used by io.github.flink.gcp.connector.bigtable.sink.singlerowClassDescriptionImmutable sink configuration assembled by
BigtableSinkBuilder.Settings for checkpoint-owned writes.The value type of a column family created by the connector.The cross-version seam every sink in this module implements instead ofSinkdirectly. -
Classes in io.github.flink.gcp.connector.bigtable.sink used by io.github.flink.gcp.connector.bigtable.sink.singlerow.committerClassDescriptionSettings for checkpoint-owned writes.The value type of a column family created by the connector.
-
Classes in io.github.flink.gcp.connector.bigtable.sink used by io.github.flink.gcp.connector.bigtable.sink.singlerow.writerClassDescriptionImmutable sink configuration assembled by
BigtableSinkBuilder.Settings for checkpoint-owned writes.Resolves the destination table for each record, enabling one sink instance to write to many tables (dynamic destinations). -
Classes in io.github.flink.gcp.connector.bigtable.sink used by io.github.flink.gcp.connector.bigtable.sink.tablesClassDescriptionThe value type of a column family created by the connector.The settings for the table the sink creates under
CreateDisposition.CREATE_IF_NEEDED: its column families, theirvalue typesand optionalgarbage-collection rules. -
Classes in io.github.flink.gcp.connector.bigtable.sink used by io.github.flink.gcp.connector.bigtable.tableClassDescriptionSelects eager writes or checkpoint-owned, replay-protected writes.Whether the sink may create the destination table when it does not exist.
-
Classes in io.github.flink.gcp.connector.bigtable.sink used by io.github.flink.gcp.connector.bigtable.table.sinkClassDescriptionSelects eager writes or checkpoint-owned, replay-protected writes.Settings for checkpoint-owned writes.Tuning options for the sink's writer: the batch thresholds handed to the client, and the writer's own bounds on unacknowledged entries.The value type of a column family created by the connector.Whether the sink may create the destination table when it does not exist.The settings for the table the sink creates under
CreateDisposition.CREATE_IF_NEEDED: its column families, theirvalue typesand optionalgarbage-collection rules.