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

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

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.table.sink
io.github.flink.gcp.connector.pubsub.table.source
io.github.flink.gcp.connector.pubsub.deadletter
io.github.flink.gcp.connector.pubsub.sink
io.github.flink.gcp.connector.pubsub.source

Classes

Class	Description
OptionSetters	Applies Table API option values to DataStream builder setters, renaming a rejected value's failure to the option key the SQL caller actually wrote (issue #1030, ADR-0133).
PubSubConnectorOptions	The WITH options of the pubsub table connector.
PubSubDynamicTableFactory	The pubsub table connector factory.