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

package 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.

Related Packages

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

Classes

Class	Description
PubSubCredentials	Loads the credentials shared by the Pub/Sub source and sink client families.
PubSubMetricNames	Every metric name this connector registers itself, in one place so that this file is the connector's inventory: what it reports can be read here without opening a writer, a reader or the enumerator.
PubSubShutdownResidue	What this connector's bounded teardowns leave behind, counted for the lifetime of the class loader rather than of a task.
ResidueCounter	A read-only Counter view of one PubSubShutdownResidue adder, so a residue registers as the counter it is rather than as a gauge over a monotonic total.