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

Class CloudTasksSinkConfig<T>

java.lang.Object

io.github.flink.gcp.connector.cloudtasks.sink.CloudTasksSinkConfig<T>

Type Parameters:

T - type of the records written by the sink

All Implemented Interfaces:

Serializable

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

Immutable sink configuration assembled by CloudTasksSinkBuilder.

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
DestinationResolver<? super T>	getDestinationResolver()	Returns the per-record destination resolver.
EmulatorEndpoint	getEmulatorEndpoint()	Returns the emulator endpoint, or null for production Cloud Tasks.
FailureHandler<? super FailedTask>	getFailedTaskHandler()	Returns the policy for tasks that terminally fail.
CloudTasksSerializationSchema<? super T>	getSerializer()	Returns the record serialization schema.
String	getServiceAccountKeyFile()	Returns the service-account key-file path, or null for ADC.
TaskIdExtractor<? super T>	getTaskIdExtractor()	Returns the deduplication-key extractor, or null when none was configured.
CloudTasksWriterOptions	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

getDestinationResolver

public DestinationResolver<? super T> getDestinationResolver()

Returns the per-record destination resolver.

getSerializer

public CloudTasksSerializationSchema<? super T> getSerializer()

Returns the record serialization schema.

getTaskIdExtractor

@Nullable
public TaskIdExtractor<? super T> getTaskIdExtractor()

Returns the deduplication-key extractor, or null when none was configured.

getWriterOptions

public CloudTasksWriterOptions getWriterOptions()

Returns the writer tuning options.

getFailedTaskHandler

public FailureHandler<? super FailedTask> getFailedTaskHandler()

Returns the policy for tasks that terminally fail.

getServiceAccountKeyFile

@Nullable
public String getServiceAccountKeyFile()

Returns the service-account key-file path, or null for ADC.

getEmulatorEndpoint

@Nullable
public EmulatorEndpoint getEmulatorEndpoint()

Returns the emulator endpoint, or null for production Cloud Tasks.