Package io.deephaven.engine.table.iterators

Class ChunkedByteColumnIterator

java.lang.Object

io.deephaven.engine.table.iterators.ChunkedColumnIterator<Byte,ByteChunk<? extends Any>>

io.deephaven.engine.table.iterators.ChunkedByteColumnIterator

All Implemented Interfaces:

CloseableIterator<Byte>, CloseablePrimitiveIterator<Byte,ByteConsumer>, CloseablePrimitiveIteratorOfByte, ValueIterator<Byte>, ValueIteratorOfByte, ByteColumnIterator, ColumnIterator<Byte>, SafeCloseable, AutoCloseable, Iterator<Byte>, PrimitiveIterator<Byte,ByteConsumer>

public final class ChunkedByteColumnIterator
extends ChunkedColumnIterator<Byte,ByteChunk<? extends Any>>
implements ByteColumnIterator

Chunked ByteColumnIterator implementation for chunk sources of primitive bytes.

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.ValueIteratorOfByte

EMPTY

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	forEachRemaining(@NotNull ByteConsumer action)
byte	nextByte()	Returns the next byte element in the iteration.

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.primitive.iterator.CloseablePrimitiveIteratorOfByte

adaptToOfInt

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

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

forEachRemaining, next, streamAsInt, streamAsInt

Constructor Details

ChunkedByteColumnIterator

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

Create a new ChunkedByteColumnIterator.

Parameters:

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

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

ChunkedByteColumnIterator

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

Create a new ChunkedByteColumnIterator.

Parameters:

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

rowSequence - The RowSequence to iterate over

Method Details

nextByte

public byte nextByte()

Description copied from interface: CloseablePrimitiveIteratorOfByte

Returns the next byte element in the iteration.

Specified by:

nextByte in interface CloseablePrimitiveIteratorOfByte

Returns:

The next byte element in the iteration

forEachRemaining

public void forEachRemaining(@NotNull
 @NotNull ByteConsumer action)

Specified by:

forEachRemaining in interface CloseablePrimitiveIteratorOfByte

Specified by:

forEachRemaining in interface PrimitiveIterator<Byte,ByteConsumer>