Package io.github.flink.gcp.connector.spanner.sink
package io.github.flink.gcp.connector.spanner.sink
-
ClassDescriptionWhat the sink does with a mutation Spanner refuses for violating a constraint.CrossVersionSink<InputT>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.At-least-once sink applying one mutation per record throughbatchWriteAtLeastOnceofgoogle-cloud-spanner.Entry point for building a Spanner sink.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.