Uses of Package
io.github.flink.gcp.connector.spanner.sink
Packages that use io.github.flink.gcp.connector.spanner.sink
Package
Description
-
Classes in io.github.flink.gcp.connector.spanner.sink used by io.github.flink.gcp.connector.spanner.sinkClassDescriptionWhat the sink does with a mutation Spanner refuses for violating a constraint.The cross-version seam every sink in this module implements instead of
Sinkdirectly.A single mutation that terminally failed to be applied to Spanner, as passed to aFailureHandler<FailedMutation>.Whether the sink applies mutations of one row in the order a sink subtask received them.Builder for the Spanner sink; created throughSpannerSink.builder().The immutable configurationSpannerSinkBuilderbuilds and the sink carries to the task managers.Tuning options for the sink's writer: how large a batch write request grows, how Spanner should schedule it, the recovery budget the writer spends on transient failures, and the order of mutations of one row.Builder forSpannerWriterOptions. -
Classes in io.github.flink.gcp.connector.spanner.sink used by io.github.flink.gcp.connector.spanner.sink.writerClassDescriptionThe immutable configuration
SpannerSinkBuilderbuilds and the sink carries to the task managers.Tuning options for the sink's writer: how large a batch write request grows, how Spanner should schedule it, the recovery budget the writer spends on transient failures, and the order of mutations of one row. -
Classes in io.github.flink.gcp.connector.spanner.sink used by io.github.flink.gcp.connector.spanner.tableClassDescriptionWhether the sink applies mutations of one row in the order a sink subtask received them.
-
Classes in io.github.flink.gcp.connector.spanner.sink used by io.github.flink.gcp.connector.spanner.table.sinkClassDescriptionTuning options for the sink's writer: how large a batch write request grows, how Spanner should schedule it, the recovery budget the writer spends on transient failures, and the order of mutations of one row.