Package io.github.flink.gcp.connector.spanner.sink

Class SpannerSinkConfig<T>

java.lang.Object

io.github.flink.gcp.connector.spanner.sink.SpannerSinkConfig<T>

Type Parameters:

T - type of the records written by the sink

All Implemented Interfaces:

Serializable

@Internal
public final class SpannerSinkConfig<T>
extends Object
implements Serializable

The immutable configuration SpannerSinkBuilder builds and the sink carries to the task managers.

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
ConstraintViolationPolicy	getConstraintViolationPolicy()	Returns what happens to a mutation refused for violating a constraint.
DatabaseDestination	getDatabase()	Returns the database to write to.
EmulatorEndpoint	getEmulatorEndpoint()	Returns the emulator endpoint, or null when writing to the real service.
FailureHandler<? super FailedMutation>	getFailedMutationHandler()	Returns the policy applied to terminally failed mutations.
SpannerMutationSerializationSchema<? super T>	getSerializer()	Returns the serialization schema.
String	getServiceAccountKeyFile()	Returns the service-account key-file path, or null when no override is configured.
SpannerWriterOptions	getWriterOptions()	Returns the writer tuning options.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getDatabase

public DatabaseDestination getDatabase()

Returns the database to write to.

getSerializer

public SpannerMutationSerializationSchema<? super T> getSerializer()

Returns the serialization schema.

getWriterOptions

public SpannerWriterOptions getWriterOptions()

Returns the writer tuning options.

getFailedMutationHandler

public FailureHandler<? super FailedMutation> getFailedMutationHandler()

Returns the policy applied to terminally failed mutations.

getConstraintViolationPolicy

public ConstraintViolationPolicy getConstraintViolationPolicy()

Returns what happens to a mutation refused for violating a constraint.

getServiceAccountKeyFile

@Nullable
public String getServiceAccountKeyFile()

Returns the service-account key-file path, or null when no override is configured.

getEmulatorEndpoint

@Nullable
public EmulatorEndpoint getEmulatorEndpoint()

Returns the emulator endpoint, or null when writing to the real service.