Package io.github.flink.gcp.connector.pubsub.source

package io.github.flink.gcp.connector.pubsub.source

Related Packages

Package	Description
io.github.flink.gcp.connector.pubsub	Google Cloud Pub/Sub connector for Apache Flink: an at-least-once sink with dynamic per-record topic destinations, and an at-least-once source consuming one or more subscriptions.
io.github.flink.gcp.connector.pubsub.source.serializer
io.github.flink.gcp.connector.pubsub.source.streamingpull
io.github.flink.gcp.connector.pubsub.source.subscriptions
io.github.flink.gcp.connector.pubsub.deadletter
io.github.flink.gcp.connector.pubsub.sink
io.github.flink.gcp.connector.pubsub.table

Class	Description
DeserializationFailurePolicy	What the source does with a message its deserialization schema cannot convert.
OrderingMode	Whether the source preserves Pub/Sub ordering-key delivery order.
PubSubSource	Entry point for building Pub/Sub sources.
PubSubSourceBuilder<T>	Builder for Pub/Sub sources, obtained from PubSubSource.builder().
PubSubSourceConfig<T>	Immutable configuration of a Pub/Sub source, assembled by PubSubSourceBuilder and shipped in the job graph.
PubSubStartPosition	Where the source starts consuming a subscription.
PubSubStartPosition.Mode	Which starting point a PubSubStartPosition names.
PubSubSubscriberOptions	Tuning options for the source's Pub/Sub subscribers and its reader: SDK flow control, the streaming-pull connection count and the acknowledgement-deadline extension settings, plus the source's own drain size, subscriber shutdown budget and first-checkpoint watchdog.
PubSubSubscriberOptions.Builder	Builder for PubSubSubscriberOptions.
SubscriptionCreateOptions	Settings the source applies when it creates a subscription that does not exist.
SubscriptionCreateOptions.Builder	Builder for SubscriptionCreateOptions.
SubscriptionDestination	A fully-qualified Pub/Sub subscription reference: project and subscription.