| Constructor and Description |
|---|
RunLengthEncodedBlock(Block value,
int positionCount) |
| Modifier and Type | Method and Description |
|---|---|
int |
bytesCompare(int position,
int offset,
int length,
io.airlift.slice.Slice otherSlice,
int otherOffset,
int otherLength)
Compares the byte sequences at
offset in the value at position
to the byte sequence at otherOffset in otherSlice. |
boolean |
bytesEqual(int position,
int offset,
io.airlift.slice.Slice otherSlice,
int otherOffset,
int length)
Is the byte sequences at
offset in the value at position equal
to the byte sequence at otherOffset in otherSlice. |
int |
compareTo(int leftPosition,
int leftOffset,
int leftLength,
Block rightBlock,
int rightPosition,
int rightOffset,
int rightLength)
Compares the byte sequences at
offset in the value at position
to the byte sequence at otherOffset in the value at otherPosition
in otherBlock. |
Block |
copyPositions(int[] positions,
int offset,
int length)
Returns a block containing the specified positions.
|
Block |
copyRegion(int positionOffset,
int length)
Returns a block starting at the specified position and extends for the
specified length.
|
static Block |
create(Type type,
Object value,
int positionCount) |
boolean |
equals(int position,
int offset,
Block otherBlock,
int otherPosition,
int otherOffset,
int length)
Is the byte sequences at
offset in the value at position equal
to the byte sequence at otherOffset in the value at otherPosition
in otherBlock. |
byte |
getByte(int position)
Gets a byte in the value at
position. |
String |
getEncodingName()
Get the encoding for this block.
|
long |
getEstimatedDataSizeForStats(int position)
Returns the estimated in memory data size for stats of position.
|
int |
getInt(int position)
Gets a little endian int in the value at
position. |
Block |
getLoadedBlock()
Returns a block that assures all data is in memory.
|
long |
getLogicalSizeInBytes()
Returns the size of the block contents, regardless of internal representation.
|
long |
getLong(int position)
Gets a little endian long in the value at
position. |
long |
getLong(int position,
int offset)
Gets a little endian long at
offset in the value at position. |
<T> T |
getObject(int position,
Class<T> clazz)
Gets an object in the value at
position. |
int |
getPositionCount()
Returns the number of positions in this block.
|
Block |
getPositions(int[] positions,
int offset,
int length)
Create a new block from the current block by keeping the same elements
only with respect to
positions that starts at offset and has length of length. |
long |
getPositionsSizeInBytes(boolean[] positions)
Returns the size of of all positions marked true in the positions array.
|
Block |
getRegion(int positionOffset,
int length)
Returns a block starting at the specified position and extends for the
specified length.
|
long |
getRegionSizeInBytes(int position,
int length)
Returns the size of
block.getRegion(position, length). |
long |
getRetainedSizeInBytes()
Returns the retained size of this block in memory, including over-allocations.
|
short |
getShort(int position)
Gets a little endian short at in the value at
position. |
Block |
getSingleValueBlock(int position)
Gets the value at the specified position as a single element block.
|
long |
getSizeInBytes()
Returns the size of this block as if it was compacted, ignoring any over-allocations.
|
io.airlift.slice.Slice |
getSlice(int position,
int offset,
int length)
Gets a slice at
offset in the value at position. |
int |
getSliceLength(int position)
Gets the length of the value at the
position. |
Block |
getValue() |
long |
hash(int position,
int offset,
int length)
Calculates the hash code the byte sequences at
offset in the
value at position. |
boolean |
isNull(int position)
Is the specified position null?
|
void |
retainedBytesForEachPart(BiConsumer<Object,Long> consumer)
consumer visits each of the internal data container and accepts the size for it. |
String |
toString() |
void |
writeBytesTo(int position,
int offset,
int length,
BlockBuilder blockBuilder)
Appends the byte sequences at
offset in the value at position
to blockBuilder. |
void |
writePositionTo(int position,
BlockBuilder blockBuilder)
Appends the value at
position to blockBuilder and close the entry. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitmayHaveNullpublic RunLengthEncodedBlock(Block value, int positionCount)
public Block getValue()
public int getPositionCount()
BlockgetPositionCount in interface Blockpublic long getSizeInBytes()
BlockgetSizeInBytes in interface Blockpublic long getLogicalSizeInBytes()
BlockBlock.getSizeInBytes() for certain block
types. For RLE, it will be N times larger. For dictionary, it will be
larger based on how many times dictionary entries are reused.getLogicalSizeInBytes in interface Blockpublic long getRetainedSizeInBytes()
BlockgetRetainedSizeInBytes in interface Blockpublic long getEstimatedDataSizeForStats(int position)
BlockgetEstimatedDataSizeForStats in interface Blockpublic void retainedBytesForEachPart(BiConsumer<Object,Long> consumer)
Blockconsumer visits each of the internal data container and accepts the size for it.
This method can be helpful in cases such as memory counting for internal data structure.
Also, the method should be non-recursive, only visit the elements at the top level,
and specifically should not call retainedBytesForEachPart on nested blocks
consumer should be called at least once with the current block and
must include the instance size of the current blockretainedBytesForEachPart in interface Blockpublic String getEncodingName()
BlockgetEncodingName in interface Blockpublic Block getPositions(int[] positions, int offset, int length)
Blockpositions that starts at offset and has length of length.
May return a view over the data in this block or may return a copygetPositions in interface Blockpublic Block copyPositions(int[] positions, int offset, int length)
Blockpositions array
that starts at offset and has length of length.
All specified positions must be valid for this block.
The returned block must be a compact representation of the original block.
copyPositions in interface Blockpublic Block getRegion(int positionOffset, int length)
BlockThe region can be a view over this block. If this block is released the region block may also be released. If the region block is released this block may also be released.
public long getRegionSizeInBytes(int position,
int length)
Blockblock.getRegion(position, length).
The method can be expensive. Do not use it outside an implementation of Block.getRegionSizeInBytes in interface Blockpublic long getPositionsSizeInBytes(boolean[] positions)
Blockblock.getRegionSizeInBytes(position, length)
where you mark all positions for the regions first.getPositionsSizeInBytes in interface Blockpublic Block copyRegion(int positionOffset, int length)
BlockThe region returned must be a compact representation of the original block, unless their internal representation will be exactly the same. This method is useful for operators that hold on to a range of values without holding on to the entire block.
copyRegion in interface Blockpublic int getSliceLength(int position)
Blockposition.
This method must be implemented if @{code getSlice} is implemented.getSliceLength in interface Blockpublic byte getByte(int position)
Blockposition.public short getShort(int position)
Blockposition.public int getInt(int position)
Blockposition.public long getLong(int position)
Blockposition.public long getLong(int position,
int offset)
Blockoffset in the value at position.public io.airlift.slice.Slice getSlice(int position,
int offset,
int length)
Blockoffset in the value at position.public <T> T getObject(int position,
Class<T> clazz)
Blockposition.public boolean bytesEqual(int position,
int offset,
io.airlift.slice.Slice otherSlice,
int otherOffset,
int length)
Blockoffset in the value at position equal
to the byte sequence at otherOffset in otherSlice.
This method must be implemented if @{code getSlice} is implemented.bytesEqual in interface Blockpublic int bytesCompare(int position,
int offset,
int length,
io.airlift.slice.Slice otherSlice,
int otherOffset,
int otherLength)
Blockoffset in the value at position
to the byte sequence at otherOffset in otherSlice.
This method must be implemented if @{code getSlice} is implemented.bytesCompare in interface Blockpublic void writeBytesTo(int position,
int offset,
int length,
BlockBuilder blockBuilder)
Blockoffset in the value at position
to blockBuilder.
This method must be implemented if @{code getSlice} is implemented.writeBytesTo in interface Blockpublic void writePositionTo(int position,
BlockBuilder blockBuilder)
Blockposition to blockBuilder and close the entry.writePositionTo in interface Blockpublic boolean equals(int position,
int offset,
Block otherBlock,
int otherPosition,
int otherOffset,
int length)
Blockoffset in the value at position equal
to the byte sequence at otherOffset in the value at otherPosition
in otherBlock.
This method must be implemented if @{code getSlice} is implemented.public long hash(int position,
int offset,
int length)
Blockoffset in the
value at position.
This method must be implemented if @{code getSlice} is implemented.public int compareTo(int leftPosition,
int leftOffset,
int leftLength,
Block rightBlock,
int rightPosition,
int rightOffset,
int rightLength)
Blockoffset in the value at position
to the byte sequence at otherOffset in the value at otherPosition
in otherBlock.
This method must be implemented if @{code getSlice} is implemented.public Block getSingleValueBlock(int position)
BlockThis method is useful for operators that hold on to a single value without holding on to the entire block.
getSingleValueBlock in interface Blockpublic boolean isNull(int position)
Blockpublic Block getLoadedBlock()
BlockThis allows streaming data sources to skip sections that are not accessed in a query.
getLoadedBlock in interface BlockCopyright © 2012–2019. All rights reserved.