public final class BlockPackedReaderIterator
extends java.lang.Object
BlockPackedWriter.BlockPackedWriter| Modifier and Type | Field and Description |
|---|---|
(package private) byte[] |
blocks |
(package private) int |
blockSize |
(package private) DataInput |
in |
(package private) int |
off |
(package private) long |
ord |
(package private) int |
packedIntsVersion |
(package private) long |
valueCount |
(package private) long[] |
values |
(package private) LongsRef |
valuesRef |
| Constructor and Description |
|---|
BlockPackedReaderIterator(DataInput in,
int packedIntsVersion,
int blockSize,
long valueCount)
Sole constructor.
|
| Modifier and Type | Method and Description |
|---|---|
long |
next()
Read the next value.
|
LongsRef |
next(int count)
Read between 1 and
count values. |
long |
ord()
Return the offset of the next value to read.
|
(package private) static long |
readVLong(DataInput in) |
private void |
refill() |
void |
reset(DataInput in,
long valueCount)
Reset the current reader to wrap a stream of
valueCount
values contained in in. |
void |
skip(long count)
Skip exactly
count values. |
private void |
skipBytes(long count) |
DataInput in
final int packedIntsVersion
long valueCount
final int blockSize
final long[] values
final LongsRef valuesRef
byte[] blocks
int off
long ord
public BlockPackedReaderIterator(DataInput in, int packedIntsVersion, int blockSize, long valueCount)
blockSize - the number of values of a block, must be equal to the
block size of the BlockPackedWriter which has
been used to write the streamstatic long readVLong(DataInput in) throws java.io.IOException
java.io.IOExceptionpublic void reset(DataInput in, long valueCount)
valueCount
values contained in in. The block size remains unchanged.public void skip(long count)
throws java.io.IOException
count values.java.io.IOExceptionprivate void skipBytes(long count)
throws java.io.IOException
java.io.IOExceptionpublic long next()
throws java.io.IOException
java.io.IOExceptionpublic LongsRef next(int count) throws java.io.IOException
count values.java.io.IOExceptionprivate void refill()
throws java.io.IOException
java.io.IOExceptionpublic long ord()