Uses of Package
io.github.flink.gcp.connector.bigtable.sink
Packages that use io.github.flink.gcp.connector.bigtable.sink
Package
Description
-
Classes in io.github.flink.gcp.connector.bigtable.sink used by io.github.flink.gcp.connector.bigtable.sinkClassDescriptionBuilder for Bigtable sinks, obtained from
BigtableSink.builder().Immutable sink configuration assembled byBigtableSinkBuilder.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.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 and, per family, an optionalgarbage-collection rule.Builder forTableCreateOptions. -
Classes in io.github.flink.gcp.connector.bigtable.sink used by io.github.flink.gcp.connector.bigtable.sink.tablesClassDescriptionThe settings for the table the sink creates under
CreateDisposition.CREATE_IF_NEEDED: its column families and, per family, an optionalgarbage-collection rule. -
Classes in io.github.flink.gcp.connector.bigtable.sink used by io.github.flink.gcp.connector.bigtable.sink.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. -
Classes in io.github.flink.gcp.connector.bigtable.sink used by io.github.flink.gcp.connector.bigtable.tableClassDescriptionWhether 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.sinkClassDescriptionTuning options for the sink's writer: the batch thresholds handed to the client, and the writer's own bounds on unacknowledged entries.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 and, per family, an optionalgarbage-collection rule.