UnboundedSource.CheckpointMark (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

com.google.cloud.dataflow.sdk.io

Interface UnboundedSource.CheckpointMark

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method and Description
      void finalizeCheckpoint()
      Perform any finalization that needs to happen after a bundle of data read from the source has been processed and committed.
    • Method Detail

      • finalizeCheckpoint

        void finalizeCheckpoint()
                         throws IOException
        Perform any finalization that needs to happen after a bundle of data read from the source has been processed and committed.

        For example, this could be sending acknowledgement requests to an external data source such as Pub/Sub.

        This may be called from any thread, potentially at the same time as calls to the UnboundedReader that created it.

        Throws:
        IOException


Was this page helpful? Let us know how we did:

Send feedback about...

Cloud Dataflow
Need help? Visit our support page.