Package io.deephaven.engine.rowset.impl.rsp.container

Class RunShortBatchIterator

java.lang.Object
io.deephaven.engine.rowset.impl.rsp.container.RunShortBatchIterator
All Implemented Interfaces:
ContainerShortBatchIterator
public class RunShortBatchIterator extends Object implements ContainerShortBatchIterator

  • Constructor Summary

    Constructors
    Constructor
    Description
    RunShortBatchIterator(RunContainer runs, int initialSkipCount)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    forEach(ShortConsumer sc)
    Starting from the next iterator position (if any), feed values to the consumer until it returns false.
    boolean
    hasNext()
    Whether the underlying container is exhausted or not
    int
    next(short[] buffer, int offset, int maxCount)
    Writes to buffer the next batch of values, and returns how much of the buffer was used.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • RunShortBatchIterator

      public RunShortBatchIterator(RunContainer runs, int initialSkipCount)

  • Method Details

    • next

      public int next(short[] buffer, int offset, int maxCount)
      Description copied from interface: ContainerShortBatchIterator
      Writes to buffer the next batch of values, and returns how much of the buffer was used.
      Specified by:
      next in interface ContainerShortBatchIterator
      Parameters:
      buffer - the buffer to write values onto.
      offset - first position to start writing in buffer.
      maxCount - max number of elements to write to buffer.
      Returns:
      how many values were written.

    • hasNext

      public boolean hasNext()
      Description copied from interface: ContainerShortBatchIterator
      Whether the underlying container is exhausted or not
      Specified by:
      hasNext in interface ContainerShortBatchIterator
      Returns:
      true if there is data remaining

    • forEach

      public boolean forEach(ShortConsumer sc)
      Description copied from interface: ContainerShortBatchIterator
      Starting from the next iterator position (if any), feed values to the consumer until it returns false. After each value is consumed, the current iterator position is moving forward; eg, a call to forEach that consumes 4 elements effectively works as if next was called 4 times.
      Specified by:
      forEach in interface ContainerShortBatchIterator
      Parameters:
      sc - a ShortConsumer to feed values to.
      Returns:
      false if the processing was stopped by the consumer returning false, true otherwise.