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

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

Related Packages

Package	Description
io.github.flink.gcp.connector.cloudtasks	Google Cloud Tasks connector for Apache Flink.
io.github.flink.gcp.connector.cloudtasks.sink.serializer
io.github.flink.gcp.connector.cloudtasks.sink.writer
io.github.flink.gcp.connector.cloudtasks.table

Class	Description
AppEngineTargetChecks	Checks and normalizes App Engine request fields shared by all sink APIs.
CloudTasksCreateTaskSink<T>	At-least-once sink creating one Cloud Tasks task per record through the CreateTask RPC, with fixed or per-record queue destinations.
CloudTasksSink	Entry point for building a Cloud Tasks sink.
CloudTasksSinkBuilder<T>	Builder for Cloud Tasks sinks, obtained from CloudTasksSink.builder().
CloudTasksSinkConfig<T>	Immutable sink configuration assembled by CloudTasksSinkBuilder.
CloudTasksWriterOptions	Tuning options for the sink's writer: the in-flight cap, the transport channel pool and the two retry budgets.
CloudTasksWriterOptions.Builder	Builder for CloudTasksWriterOptions.
CrossVersionSink<InputT>	The cross-version seam every sink in this module implements instead of Sink directly.
DestinationResolver<T>	Resolves the destination queue for each record, enabling one sink instance to write to many queues (dynamic destinations).
FailedTask	A single task that terminally failed to be created in Cloud Tasks, as passed to a FailureHandler<FailedTask>.
FixedDestinationResolver	A DestinationResolver returning one fixed destination for every record.
QueueDestination	A fully-qualified Cloud Tasks queue reference: project, location and queue.
TaskIdExtractor<T>	Extracts the deduplication key of a record, opting the sink into named tasks.