Package | Description |
---|---|
org.apache.flink.streaming.connectors.gcp.pubsub | |
org.apache.flink.streaming.connectors.gcp.pubsub.common |
Class and Description |
---|
AcknowledgeIdsForCheckpoint
This class contains a checkpointId and a List of AcknowledgementIds.
|
AcknowledgeOnCheckpoint
Helper class for SourceFunctions to acknowledge messages to external systems after a successful checkpoint.
|
Acknowledger |
PubSubDeserializationSchema
The deserialization schema describes how to turn the PubsubMessages
into data types (Java/Scala objects) that are processed by Flink.
|
PubSubSubscriber
Used by
PubSubSource to pull and acknowledge messages. |
PubSubSubscriberFactory
A factory class to create a
SubscriberStub . |
Class and Description |
---|
AcknowledgeIdsForCheckpoint
This class contains a checkpointId and a List of AcknowledgementIds.
|
Acknowledger |
PubSubSubscriber
Used by
PubSubSource to pull and acknowledge messages. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.