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

이 페이지가 도움이 되었나요? 평가를 부탁드립니다.

다음에 대한 의견 보내기...

도움이 필요하시나요? 지원 페이지를 방문하세요.