Uses of Package
io.github.flink.gcp.connector.pubsub.sink

Packages that use io.github.flink.gcp.connector.pubsub.sink

Package	Description
io.github.flink.gcp.connector.pubsub.deadletter
io.github.flink.gcp.connector.pubsub.sink
io.github.flink.gcp.connector.pubsub.sink.topics
io.github.flink.gcp.connector.pubsub.sink.writer
io.github.flink.gcp.connector.pubsub.source
io.github.flink.gcp.connector.pubsub.table
io.github.flink.gcp.connector.pubsub.table.sink

Classes in io.github.flink.gcp.connector.pubsub.sink used by io.github.flink.gcp.connector.pubsub.deadletter

Class	Description
TopicDestination	A fully-qualified Pub/Sub topic reference: project and topic.

Classes in io.github.flink.gcp.connector.pubsub.sink used by io.github.flink.gcp.connector.pubsub.sink

Class	Description
CreateDisposition	Whether the sink may create destination topics that do not exist.
CrossVersionSink	The cross-version seam every sink in this module implements instead of Sink directly.
DestinationResolver	Resolves the destination topic for each record, enabling one sink instance to publish to many topics (dynamic destinations).
FailedMessage	A single message that terminally failed to be published to Pub/Sub, as passed to a FailureHandler<FailedMessage>.
PubSubPublisherOptions	Tuning options for the sink's Pub/Sub publishers and its writer: SDK batching and publish-retry settings, message ordering, the writer's in-flight caps, the backoff budget of the topic auto-creation recovery, and the writer's shutdown budget.
PubSubPublisherOptions.Builder	Builder for PubSubPublisherOptions.
PubSubPublisherSink	At-least-once sink publishing through google-cloud-pubsub Publisher instances with dynamic per-record topic destinations.
PubSubSinkBuilder	Builder for Pub/Sub sinks, obtained from PubSubSink.builder().
PubSubSinkConfig	Immutable sink configuration assembled by PubSubSinkBuilder.
TopicCreateOptions	Settings the sink applies when it creates a topic that does not exist.
TopicCreateOptions.Builder	Builder for TopicCreateOptions.
TopicDestination	A fully-qualified Pub/Sub topic reference: project and topic.

Classes in io.github.flink.gcp.connector.pubsub.sink used by io.github.flink.gcp.connector.pubsub.sink.topics

Class	Description
TopicCreateOptions	Settings the sink applies when it creates a topic that does not exist.
TopicDestination	A fully-qualified Pub/Sub topic reference: project and topic.

Classes in io.github.flink.gcp.connector.pubsub.sink used by io.github.flink.gcp.connector.pubsub.sink.writer

Class	Description
PubSubPublisherOptions	Tuning options for the sink's Pub/Sub publishers and its writer: SDK batching and publish-retry settings, message ordering, the writer's in-flight caps, the backoff budget of the topic auto-creation recovery, and the writer's shutdown budget.
PubSubSinkConfig	Immutable sink configuration assembled by PubSubSinkBuilder.
TopicDestination	A fully-qualified Pub/Sub topic reference: project and topic.

Classes in io.github.flink.gcp.connector.pubsub.sink used by io.github.flink.gcp.connector.pubsub.source

Class	Description
TopicDestination	A fully-qualified Pub/Sub topic reference: project and topic.

Classes in io.github.flink.gcp.connector.pubsub.sink used by io.github.flink.gcp.connector.pubsub.table

Class	Description
CreateDisposition	Whether the sink may create destination topics that do not exist.

Classes in io.github.flink.gcp.connector.pubsub.sink used by io.github.flink.gcp.connector.pubsub.table.sink

Class	Description
CreateDisposition	Whether the sink may create destination topics that do not exist.
PubSubPublisherOptions	Tuning options for the sink's Pub/Sub publishers and its writer: SDK batching and publish-retry settings, message ordering, the writer's in-flight caps, the backoff budget of the topic auto-creation recovery, and the writer's shutdown budget.
TopicCreateOptions	Settings the sink applies when it creates a topic that does not exist.
TopicDestination	A fully-qualified Pub/Sub topic reference: project and topic.