com.facebook.presto.spi.block

Class RowBlock

java.lang.Object

com.facebook.presto.spi.block.AbstractRowBlock

com.facebook.presto.spi.block.RowBlock

All Implemented Interfaces:

Block

public class RowBlock
extends AbstractRowBlock

Field Summary

Fields inherited from class com.facebook.presto.spi.block.AbstractRowBlock

numFields

Method Summary

Modifier and Type	Method and Description
static Block	fromFieldBlocks(int positionCount, Optional<boolean[]> rowIsNull, Block[] fieldBlocks) Create a row block directly from columnar nulls and field blocks.
protected int[]	getFieldBlockOffsets()
Block	getLoadedBlock() Returns a block that assures all data is in memory.
protected int	getOffsetBase()
int	getPositionCount() Returns the number of positions in this block.
protected Block[]	getRawFieldBlocks()
long	getRetainedSizeInBytes() Returns the retained size of this block in memory, including over-allocations.
protected boolean[]	getRowIsNull()
long	getSizeInBytes() Returns the size of this block as if it was compacted, ignoring any over-allocations.
void	retainedBytesForEachPart(BiConsumer<Object,Long> consumer) consumer visits each of the internal data container and accepts the size for it.
String	toString()

Methods inherited from class com.facebook.presto.spi.block.AbstractRowBlock

copyPositions, copyRegion, getEncodingName, getEstimatedDataSizeForStats, getFieldBlockOffset, getObject, getPositionsSizeInBytes, getRegion, getRegionSizeInBytes, getSingleValueBlock, isNull, mayHaveNull, writePositionTo

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.facebook.presto.spi.block.Block

bytesCompare, bytesEqual, compareTo, equals, getByte, getInt, getLogicalSizeInBytes, getLong, getLong, getPositions, getShort, getSlice, getSliceLength, hash, writeBytesTo

Method Detail

fromFieldBlocks

public static Block fromFieldBlocks(int positionCount,
                                    Optional<boolean[]> rowIsNull,
                                    Block[] fieldBlocks)

Create a row block directly from columnar nulls and field blocks.

getRawFieldBlocks

protected Block[] getRawFieldBlocks()

Specified by:

getRawFieldBlocks in class AbstractRowBlock

getFieldBlockOffsets

protected int[] getFieldBlockOffsets()

Specified by:

getFieldBlockOffsets in class AbstractRowBlock

getOffsetBase

protected int getOffsetBase()

Specified by:

getOffsetBase in class AbstractRowBlock

getRowIsNull

@Nullable
protected boolean[] getRowIsNull()

Specified by:

getRowIsNull in class AbstractRowBlock

getPositionCount

public int getPositionCount()

Description copied from interface: Block

Returns the number of positions in this block.

getSizeInBytes

public long getSizeInBytes()

Description copied from interface: Block

Returns the size of this block as if it was compacted, ignoring any over-allocations. For example, in dictionary blocks, this only counts each dictionary entry once, rather than each time a value is referenced.

getRetainedSizeInBytes

public long getRetainedSizeInBytes()

Description copied from interface: Block

Returns the retained size of this block in memory, including over-allocations. This method is called from the inner most execution loop and must be fast.

retainedBytesForEachPart

public void retainedBytesForEachPart(BiConsumer<Object,Long> consumer)

Description copied from interface: Block

consumer 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 block

toString

public String toString()

Overrides:

toString in class Object

getLoadedBlock

public Block getLoadedBlock()

Description copied from interface: Block

Returns a block that assures all data is in memory. May return the same block if all block data is already in memory.

This allows streaming data sources to skip sections that are not accessed in a query.