Package io.deephaven.engine.table.iterators

Class ChunkedColumnIterator<DATA_TYPE,CHUNK_TYPE extends Chunk<? extends Any>>

java.lang.Object

io.deephaven.engine.table.iterators.ChunkedColumnIterator<DATA_TYPE,CHUNK_TYPE>

All Implemented Interfaces:

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

Direct Known Subclasses:

ChunkedByteColumnIterator, ChunkedCharacterColumnIterator, ChunkedDoubleColumnIterator, ChunkedFloatColumnIterator, ChunkedIntegerColumnIterator, ChunkedLongColumnIterator, ChunkedObjectColumnIterator, ChunkedShortColumnIterator

public abstract class ChunkedColumnIterator<DATA_TYPE,CHUNK_TYPE extends Chunk<? extends Any>>
extends Object
implements ColumnIterator<DATA_TYPE>

Iteration support for values supplied by a ChunkSource. Implementations retrieve chunks of values at a time in a common Deephaven engine retrieval pattern. This is expected to be high throughput relative to SerialColumnIterator implementations, but may have material initialization and teardown costs for small or sparse iterations.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_CHUNK_SIZE	The default for chunkSize used by constructors that don't accept an explicit size.

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

EMPTY

Method Summary

Modifier and Type	Method	Description
final void	close()
final boolean	hasNext()
static <DATA_TYPE> ColumnIterator<DATA_TYPE>	make(@NotNull ChunkSource<? extends Any> chunkSource, @NotNull RowSequence rowSequence)
static <DATA_TYPE> ColumnIterator<DATA_TYPE>	make(@NotNull ChunkSource<? extends Any> chunkSource, @NotNull RowSequence rowSequence, int chunkSize)
final long	remaining()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, next, remove

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

stream

Field Details

DEFAULT_CHUNK_SIZE

public static final int DEFAULT_CHUNK_SIZE

The default for chunkSize used by constructors that don't accept an explicit size.

See Also:

• Constant Field Values

Method Details

remaining

public final long remaining()

Specified by:

remaining in interface ValueIterator<DATA_TYPE>

Returns:

The number of elements remaining in this ValueIterator

hasNext

public final boolean hasNext()

Specified by:

hasNext in interface Iterator<DATA_TYPE>

close

public final void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface CloseableIterator<DATA_TYPE>

Specified by:

close in interface ColumnIterator<DATA_TYPE>

Specified by:

close in interface SafeCloseable

make

public static <DATA_TYPE> ColumnIterator<DATA_TYPE> make(@NotNull
 @NotNull ChunkSource<? extends Any> chunkSource,
 @NotNull
 @NotNull RowSequence rowSequence)

make

public static <DATA_TYPE> ColumnIterator<DATA_TYPE> make(@NotNull
 @NotNull ChunkSource<? extends Any> chunkSource,
 @NotNull
 @NotNull RowSequence rowSequence,
 int chunkSize)