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.sinkClassDescriptionOne immutable checkpoint committable.Delivery modes for Cloud Tasks task creation, distinct from handler execution.Immutable observation of an owned batch, containing no task payload or durable state.Builder for Cloud Tasks sinks, obtained from
CloudTasksSink.builder().Immutable sink configuration assembled byCloudTasksSinkBuilder.Immutable staging and recovery settings for checkpointed Cloud Tasks creation.Builder for immutable checkpointed creation settings.Explicit recovery decisions outside the guarantee after an envelope expires.Internal staging settings.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.committerClassDescriptionOne immutable checkpoint committable.Immutable staging and recovery settings for checkpointed Cloud Tasks creation.Tuning options for the sink's writer: the in-flight cap, the transport channel pool and the two retry budgets.
-
Classes in io.github.flink.gcp.connector.cloudtasks.sink used by io.github.flink.gcp.connector.cloudtasks.sink.writerClassDescriptionOne immutable checkpoint committable.Immutable sink configuration assembled by
CloudTasksSinkBuilder.Internal staging settings. -
Classes in io.github.flink.gcp.connector.cloudtasks.sink used by io.github.flink.gcp.connector.cloudtasks.tableClassDescriptionDelivery modes for Cloud Tasks task creation, distinct from handler execution.Explicit recovery decisions outside the guarantee after an envelope expires.
-
Classes in io.github.flink.gcp.connector.cloudtasks.sink used by io.github.flink.gcp.connector.cloudtasks.table.sinkClassDescriptionDelivery modes for Cloud Tasks task creation, distinct from handler execution.Immutable staging and recovery settings for checkpointed Cloud Tasks creation.Tuning 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.