Package io.deephaven.engine.table.iterators

Class ChunkedObjectColumnIterator<DATA_TYPE>

java.lang.Object

io.deephaven.engine.table.iterators.ChunkedColumnIterator<DATA_TYPE,ObjectChunk<DATA_TYPE,? extends Any>>

io.deephaven.engine.table.iterators.ChunkedObjectColumnIterator<DATA_TYPE>

All Implemented Interfaces:

CloseableIterator<DATA_TYPE>, ColumnIterator<DATA_TYPE>, ObjectColumnIterator<DATA_TYPE>, SafeCloseable, AutoCloseable, Iterator<DATA_TYPE>

public final class ChunkedObjectColumnIterator<DATA_TYPE>
extends ChunkedColumnIterator<DATA_TYPE,ObjectChunk<DATA_TYPE,? extends Any>>
implements ObjectColumnIterator<DATA_TYPE>

ObjectColumnIterator implementation for chunk sources of objects.

Field Summary

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

DEFAULT_CHUNK_SIZE

Fields inherited from interface io.deephaven.engine.primitive.iterator.CloseableIterator

EMPTY

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	forEachRemaining(@NotNull Consumer<? super DATA_TYPE> action)
DATA_TYPE	next()

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, remaining

Methods inherited from interface java.util.Iterator

hasNext, remove

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

stream

Constructor Details

ChunkedObjectColumnIterator

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

Create a new ObjectColumnIterator.

Parameters:

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

rowSequence - The RowSequence to iterate over

chunkSize - The internal buffer size to use when fetching data

firstRowKey - The first row key from rowSequence to iterate

length - The total number of rows to iterate

ChunkedObjectColumnIterator

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

Create a new ObjectColumnIterator.

Parameters:

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

rowSequence - The RowSequence to iterate over

Method Details

next

public DATA_TYPE next()

Specified by:

next in interface Iterator<DATA_TYPE>

forEachRemaining

public void forEachRemaining(@NotNull
 @NotNull Consumer<? super DATA_TYPE> action)

Specified by:

forEachRemaining in interface Iterator<DATA_TYPE>