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.