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. |
Class and Description |
---|
PubSubSubscriber
Used by
PubSubSource to pull and acknowledge messages. |
PubSubSubscriberFactory
A factory class to create a
SubscriberStub . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.