BlockBasedSource.Block (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Class BlockBasedSource.Block<T>

    • Constructor Detail

      • Block

        protected Block()
    • Method Detail

      • getCurrentRecord

        public abstract T getCurrentRecord()
        Returns the current record.
      • readNextRecord

        public abstract boolean readNextRecord()
                                        throws IOException
        Reads the next record from the block and returns true iff one exists.
      • getFractionOfBlockConsumed

        public abstract double getFractionOfBlockConsumed()
        Returns the fraction of the block already consumed, if possible, as a value in [0, 1]. It should not include the current record. Successive results from this method must be monotonically increasing.

        If it is not possible to compute the fraction of the block consumed this method may return zero. For example, when the total number of records in the block is unknown.

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

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

Dataflow: Stream & Batch Processing
도움이 필요하시나요? 지원 페이지를 방문하세요.