Uses of Package
io.github.flink.gcp.connector.cloudtasks.sink
Packages that use io.github.flink.gcp.connector.cloudtasks.sink
Package
Description
-
Classes in io.github.flink.gcp.connector.cloudtasks.sink used by io.github.flink.gcp.connector.cloudtasks.sinkClassDescriptionBuilder for Cloud Tasks sinks, obtained from
CloudTasksSink.builder().Immutable sink configuration assembled byCloudTasksSinkBuilder.Tuning options for the sink's writer: the in-flight cap, the transport channel pool and the two retry budgets.Builder forCloudTasksWriterOptions.The cross-version seam every sink in this module implements instead ofSinkdirectly.Resolves the destination queue for each record, enabling one sink instance to write to many queues (dynamic destinations).A single task that terminally failed to be created in Cloud Tasks, as passed to aFailureHandler<FailedTask>.A fully-qualified Cloud Tasks queue reference: project, location and queue.Extracts the deduplication key of a record, opting the sink into named tasks. -
Classes in io.github.flink.gcp.connector.cloudtasks.sink used by io.github.flink.gcp.connector.cloudtasks.sink.writer
-
Classes in io.github.flink.gcp.connector.cloudtasks.sink used by io.github.flink.gcp.connector.cloudtasks.table.sinkClassDescriptionTuning options for the sink's writer: the in-flight cap, the transport channel pool and the two retry budgets.A fully-qualified Cloud Tasks queue reference: project, location and queue.