Interface | Description |
---|---|
Acknowledger<AcknowledgeId> | |
PubSubDeserializationSchema<T> |
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 | Description |
---|---|
AcknowledgeIdsForCheckpoint<AcknowledgeId> |
This class contains a checkpointId and a List of AcknowledgementIds.
|
AcknowledgeOnCheckpoint<ACKID extends Serializable> |
Helper class for SourceFunctions to acknowledge messages to external systems after a successful
checkpoint.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.