CountingSource.CounterMark (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Class CountingSource.CounterMark

    • Constructor Detail

      • CounterMark

        public CounterMark(long lastEmitted,
                           Instant startTime)
        Creates a checkpoint mark reflecting the last emitted value.
    • Method Detail

      • getLastEmitted

        public long getLastEmitted()
        Returns the last value emitted by the reader.
      • getStartTime

        public Instant getStartTime()
        Returns the time the reader was started.
      • finalizeCheckpoint

        public void finalizeCheckpoint()
                                throws IOException
        Description copied from interface: UnboundedSource.CheckpointMark
        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.

        Specified by:
        finalizeCheckpoint in interface UnboundedSource.CheckpointMark