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