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

Class CloudTasksCreateTaskSink<T>

java.lang.Object

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

Type Parameters:

T - type of the records written by the sink

All Implemented Interfaces:

CrossVersionSink<T>, Serializable, org.apache.flink.api.connector.sink2.Sink<T>

@Internal
public class CloudTasksCreateTaskSink<T>
extends Object
implements CrossVersionSink<T>

At-least-once sink creating one Cloud Tasks task per record through the CreateTask RPC, with fixed or per-record queue destinations.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
CloudTasksCreateTaskSink(CloudTasksSinkConfig<T> config)	Creates the sink; called by CloudTasksSinkBuilder.

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.connector.sink2.SinkWriter<T>	createWriter(TaskCreator creator, org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor, org.apache.flink.metrics.groups.SinkWriterMetricGroup metricGroup)	Creates the writer against injected collaborators.
org.apache.flink.api.connector.sink2.SinkWriter<T>	createWriter(org.apache.flink.api.connector.sink2.WriterInitContext context)
CloudTasksSinkConfig<T>	getConfig()	Returns the sink configuration.
DefaultTaskCreatorFactory	taskCreatorFactory()	The factory the production path builds.

Methods inherited from class java.lang.Object

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

Constructor Details

CloudTasksCreateTaskSink

public CloudTasksCreateTaskSink(CloudTasksSinkConfig<T> config)

Creates the sink; called by CloudTasksSinkBuilder.

Parameters:

config - the sink configuration

Method Details

getConfig

public CloudTasksSinkConfig<T> getConfig()

Returns the sink configuration.

createWriter

public org.apache.flink.api.connector.sink2.SinkWriter<T> createWriter(org.apache.flink.api.connector.sink2.WriterInitContext context)
                                                                throws IOException

Specified by:

createWriter in interface org.apache.flink.api.connector.sink2.Sink<T>

Throws:

IOException

taskCreatorFactory

@VisibleForTesting
public DefaultTaskCreatorFactory taskCreatorFactory()

The factory the production path builds. A separate method so a test can assert the configuration actually reaches it — the wiring is three config lookups, and a dropped or swapped one compiles.

createWriter

@VisibleForTesting
public org.apache.flink.api.connector.sink2.SinkWriter<T> createWriter(TaskCreator creator,
 org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor,
 org.apache.flink.metrics.groups.SinkWriterMetricGroup metricGroup)

Creates the writer against injected collaborators. Deliberately does not open the failure handler: opening belongs to the production path above, and a test driving this overload opens whatever it needs itself.