The deserialization schema describes how to turn the PubsubMessages into data types (Java/Scala objects) that are processed by Flink.
A factory class to create a
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–2020 The Apache Software Foundation. All rights reserved.