com.facebook.presto.spi.block

Class RowBlockBuilder

java.lang.Object

com.facebook.presto.spi.block.AbstractRowBlock

com.facebook.presto.spi.block.RowBlockBuilder

All Implemented Interfaces:

Block, BlockBuilder

public class RowBlockBuilder
extends AbstractRowBlock
implements BlockBuilder

Field Summary

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

numFields

Constructor Summary

Constructors

Constructor and Description
RowBlockBuilder(List<Type> fieldTypes, BlockBuilderStatus blockBuilderStatus, int expectedEntries)

Method Summary

Modifier and Type	Method and Description
BlockBuilder	appendNull() Appends a null value to the block.
BlockBuilder	appendStructure(Block block) Append a struct to the block and close the entry.
BlockBuilder	appendStructureInternal(Block block, int position) Do not use this interface outside block package.
SingleRowBlockWriter	beginBlockEntry() Return a writer to the current entry.
Block	build() Builds the block.
BlockBuilder	closeEntry() Write a byte to the current entry;
protected int[]	getFieldBlockOffsets()
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.
BlockBuilder	newBlockBuilderLike(BlockBuilderStatus blockBuilderStatus) Creates a new block builder of the same type based on the current usage statistics of this block builder.
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.BlockBuilder

getPositions, writeByte, writeBytes, writeInt, writeLong, writeShort

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

bytesCompare, bytesEqual, compareTo, copyPositions, copyRegion, equals, getByte, getEncodingName, getEstimatedDataSizeForStats, getInt, getLoadedBlock, getLogicalSizeInBytes, getLong, getLong, getObject, getPositionsSizeInBytes, getRegion, getRegionSizeInBytes, getShort, getSingleValueBlock, getSlice, getSliceLength, hash, isNull, mayHaveNull, writeBytesTo, writePositionTo

Constructor Detail

RowBlockBuilder

public RowBlockBuilder(List<Type> fieldTypes,
                       BlockBuilderStatus blockBuilderStatus,
                       int expectedEntries)

Method Detail

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

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.

Specified by:

getPositionCount in interface 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.

Specified by:

getSizeInBytes in interface Block

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.

Specified by:

getRetainedSizeInBytes in interface Block

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

Specified by:

retainedBytesForEachPart in interface Block

beginBlockEntry

public SingleRowBlockWriter beginBlockEntry()

Description copied from interface: BlockBuilder

Return a writer to the current entry. The caller can operate on the returned caller to incrementally build the object. This is generally more efficient than building the object elsewhere and call writeObject afterwards because a large chunk of memory could potentially be unnecessarily copied in this process.

Specified by:

beginBlockEntry in interface BlockBuilder

closeEntry

public BlockBuilder closeEntry()

Description copied from interface: BlockBuilder

Write a byte to the current entry;

Specified by:

closeEntry in interface BlockBuilder

appendNull

public BlockBuilder appendNull()

Description copied from interface: BlockBuilder

Appends a null value to the block.

Specified by:

appendNull in interface BlockBuilder

build

public Block build()

Description copied from interface: BlockBuilder

Builds the block. This method can be called multiple times.

Specified by:

build in interface BlockBuilder

toString

public String toString()

Overrides:

toString in class Object

appendStructure

public BlockBuilder appendStructure(Block block)

Description copied from interface: BlockBuilder

Append a struct to the block and close the entry.

Specified by:

appendStructure in interface BlockBuilder

appendStructureInternal

public BlockBuilder appendStructureInternal(Block block,
                                            int position)

Description copied from interface: BlockBuilder

Do not use this interface outside block package. Instead, use Block.writePositionTo(BlockBuilder, position)

Specified by:

appendStructureInternal in interface BlockBuilder

newBlockBuilderLike

public BlockBuilder newBlockBuilderLike(BlockBuilderStatus blockBuilderStatus)

Description copied from interface: BlockBuilder

Creates a new block builder of the same type based on the current usage statistics of this block builder.

Specified by:

newBlockBuilderLike in interface BlockBuilder