Package io.github.flink.gcp.connector.cloudtasks.sink
package io.github.flink.gcp.connector.cloudtasks.sink
-
ClassDescriptionChecks and normalizes App Engine request fields shared by all sink APIs.One immutable checkpoint committable.Bounded v1 framing for one envelope; the Flink collector owns batch counts and redistribution.At-least-once sink creating one Cloud Tasks task per record through the
CreateTaskRPC, with fixed or per-record queue destinations.Delivery modes for Cloud Tasks task creation, distinct from handler execution.Immutable observation of an owned batch, containing no task payload or durable state.Entry point for building a Cloud Tasks sink.Builder for Cloud Tasks sinks, obtained fromCloudTasksSink.builder().Immutable sink configuration assembled byCloudTasksSinkBuilder.Checkpointed named creation with a stateless staging writer and a bounded committer.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.CrossVersionSink<InputT>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>.ADestinationResolverreturning one fixed destination for every record.A fully-qualified Cloud Tasks queue reference: project, location and queue.Extracts the deduplication key of a record, opting the sink into named tasks.