Package io.deephaven.engine.table.iterators

Class ChunkedIntegerColumnIterator

java.lang.Object

io.deephaven.engine.table.iterators.ChunkedColumnIterator<Integer,IntChunk<? extends Any>>

io.deephaven.engine.table.iterators.ChunkedIntegerColumnIterator

All Implemented Interfaces:

CloseableIterator<Integer>, CloseablePrimitiveIterator<Integer,IntConsumer>, CloseablePrimitiveIteratorOfInt, ValueIterator<Integer>, ValueIteratorOfInt, ColumnIterator<Integer>, IntegerColumnIterator, SafeCloseable, AutoCloseable, Iterator<Integer>, PrimitiveIterator<Integer,IntConsumer>, PrimitiveIterator.OfInt

public final class ChunkedIntegerColumnIterator
extends ChunkedColumnIterator<Integer,IntChunk<? extends Any>>
implements IntegerColumnIterator

Chunked IntegerColumnIterator implementation for chunk sources of primitive ints.

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.PrimitiveIterator

PrimitiveIterator.OfDouble, PrimitiveIterator.OfInt, PrimitiveIterator.OfLong

Field Summary

Fields inherited from class io.deephaven.engine.table.iterators.ChunkedColumnIterator

DEFAULT_CHUNK_SIZE

Fields inherited from interface io.deephaven.engine.primitive.value.iterator.ValueIterator

EMPTY

Fields inherited from interface io.deephaven.engine.primitive.value.iterator.ValueIteratorOfInt

EMPTY

Constructor Summary

Constructors

Constructor	Description
ChunkedIntegerColumnIterator(@NotNull ChunkSource<? extends Any> chunkSource, @NotNull RowSequence rowSequence)	Create a new ChunkedIntegerColumnIterator.
ChunkedIntegerColumnIterator(@NotNull ChunkSource<? extends Any> chunkSource, @NotNull RowSequence rowSequence, int chunkSize, long firstRowKey, long length)	Create a new ChunkedIntegerColumnIterator.

Method Summary

Modifier and Type	Method	Description
void	forEachRemaining(@NotNull IntConsumer action)
int	nextInt()

Methods inherited from class io.deephaven.engine.table.iterators.ChunkedColumnIterator

close, hasNext, make, make, remaining

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.engine.table.iterators.ColumnIterator

close

Methods inherited from interface java.util.Iterator

hasNext, remove

Methods inherited from interface io.deephaven.engine.primitive.value.iterator.ValueIterator

remaining

Methods inherited from interface io.deephaven.engine.primitive.value.iterator.ValueIteratorOfInt

forEachRemaining, intStream, next, stream

Constructor Details

ChunkedIntegerColumnIterator

public ChunkedIntegerColumnIterator(@NotNull
 @NotNull ChunkSource<? extends Any> chunkSource,
 @NotNull
 @NotNull RowSequence rowSequence,
 int chunkSize,
 long firstRowKey,
 long length)

Create a new ChunkedIntegerColumnIterator.

Parameters:

chunkSource - The ChunkSource to fetch values from; must have chunk type of ChunkType.Int

rowSequence - The RowSequence to iterate over

chunkSize - The buffer size to use when fetching data

firstRowKey - The first row key from rowSequence to iterate

length - The total number of rows to iterate

ChunkedIntegerColumnIterator

public ChunkedIntegerColumnIterator(@NotNull
 @NotNull ChunkSource<? extends Any> chunkSource,
 @NotNull
 @NotNull RowSequence rowSequence)

Create a new ChunkedIntegerColumnIterator.

Parameters:

chunkSource - The ChunkSource to fetch values from; must have chunk type of ChunkType.Int

rowSequence - The RowSequence to iterate over

Method Details

nextInt

public int nextInt()

Specified by:

nextInt in interface PrimitiveIterator.OfInt

forEachRemaining

public void forEachRemaining(@NotNull
 @NotNull IntConsumer action)

Specified by:

forEachRemaining in interface PrimitiveIterator<Integer,IntConsumer>

Specified by:

forEachRemaining in interface PrimitiveIterator.OfInt