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>.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, and the recovery budget the writer spends on transient failures.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, and the recovery budget the writer spends on transient failures. -
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, and the recovery budget the writer spends on transient failures.