com.facebook.presto.spi.block

Class ArrayBlockBuilder

java.lang.Object

com.facebook.presto.spi.block.AbstractArrayBlock

com.facebook.presto.spi.block.ArrayBlockBuilder

All Implemented Interfaces:

Block, BlockBuilder

public class ArrayBlockBuilder
extends AbstractArrayBlock
implements BlockBuilder

Constructor Summary

Constructors

Constructor and Description
ArrayBlockBuilder(BlockBuilder valuesBlock, BlockBuilderStatus blockBuilderStatus, int expectedEntries) Caller of this constructor is responsible for making sure `valuesBlock` is constructed with the same `blockBuilderStatus` as the one in the argument
ArrayBlockBuilder(Type elementType, BlockBuilderStatus blockBuilderStatus, int expectedEntries)
ArrayBlockBuilder(Type elementType, BlockBuilderStatus blockBuilderStatus, int expectedEntries, int expectedBytesPerEntry)

Method Summary

Modifier and Type	Method and Description
BlockBuilder	appendNull() Appends a null value to the block.
void	assureLoaded() Assures that all data for the block is in memory.
ArrayElementBlockWriter	beginBlockEntry() Return a writer to the current entry.
ArrayBlock	build() Builds the block.
BlockBuilder	closeEntry() Write a byte to the current entry;
protected int	getOffsetBase()
protected io.airlift.slice.Slice	getOffsets()
int	getPositionCount() Returns the number of positions in this block.
int	getRetainedSizeInBytes() Returns the retained size of this block in memory.
int	getSizeInBytes() Returns the logical size of this block in memory.
protected io.airlift.slice.Slice	getValueIsNull()
protected Block	getValues()
String	toString()
BlockBuilder	writeByte(int value) Write a byte to the current entry;
BlockBuilder	writeBytes(io.airlift.slice.Slice source, int sourceIndex, int length) Write a byte sequences to the current entry;
BlockBuilder	writeDouble(double value) Write a double to the current entry;
BlockBuilder	writeFloat(float value) Write a float to the current entry;
BlockBuilder	writeInt(int value) Write a int to the current entry;
BlockBuilder	writeLong(long value) Write a long to the current entry;
BlockBuilder	writeObject(Object value) Write an object to the current entry;
BlockBuilder	writeShort(int value) Write a short to the current entry;

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

bytesCompare, bytesEqual, compareTo, copyPositions, copyRegion, equals, getByte, getDouble, getEncoding, getFloat, getInt, getLength, getLong, getObject, getRegion, getShort, getSingleValueBlock, getSlice, hash, isNull, writeBytesTo, 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, copyPositions, copyRegion, equals, getByte, getDouble, getEncoding, getFloat, getInt, getLength, getLong, getObject, getRegion, getShort, getSingleValueBlock, getSlice, hash, isNull, writeBytesTo, writePositionTo

Constructor Detail

ArrayBlockBuilder

public ArrayBlockBuilder(BlockBuilder valuesBlock,
                         BlockBuilderStatus blockBuilderStatus,
                         int expectedEntries)

Caller of this constructor is responsible for making sure `valuesBlock` is constructed with the same `blockBuilderStatus` as the one in the argument

ArrayBlockBuilder

public ArrayBlockBuilder(Type elementType,
                         BlockBuilderStatus blockBuilderStatus,
                         int expectedEntries,
                         int expectedBytesPerEntry)

ArrayBlockBuilder

public ArrayBlockBuilder(Type elementType,
                         BlockBuilderStatus blockBuilderStatus,
                         int expectedEntries)

Method Detail

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 int getSizeInBytes()

Description copied from interface: Block

Returns the logical size of this block in memory.

Specified by:

getSizeInBytes in interface Block

getRetainedSizeInBytes

public int getRetainedSizeInBytes()

Description copied from interface: Block

Returns the retained size of this block in memory.

Specified by:

getRetainedSizeInBytes in interface Block

getValues

protected Block getValues()

Specified by:

getValues in class AbstractArrayBlock

getOffsets

protected io.airlift.slice.Slice getOffsets()

Specified by:

getOffsets in class AbstractArrayBlock

getOffsetBase

protected int getOffsetBase()

Specified by:

getOffsetBase in class AbstractArrayBlock

getValueIsNull

protected io.airlift.slice.Slice getValueIsNull()

Specified by:

getValueIsNull in class AbstractArrayBlock

assureLoaded

public void assureLoaded()

Description copied from interface: Block

Assures that all data for the block is in memory.

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

Specified by:

assureLoaded in interface Block

writeByte

public BlockBuilder writeByte(int value)

Description copied from interface: BlockBuilder

Write a byte to the current entry;

Specified by:

writeByte in interface BlockBuilder

writeShort

public BlockBuilder writeShort(int value)

Description copied from interface: BlockBuilder

Write a short to the current entry;

Specified by:

writeShort in interface BlockBuilder

writeInt

public BlockBuilder writeInt(int value)

Description copied from interface: BlockBuilder

Write a int to the current entry;

Specified by:

writeInt in interface BlockBuilder

writeLong

public BlockBuilder writeLong(long value)

Description copied from interface: BlockBuilder

Write a long to the current entry;

Specified by:

writeLong in interface BlockBuilder

writeFloat

public BlockBuilder writeFloat(float value)

Description copied from interface: BlockBuilder

Write a float to the current entry;

Specified by:

writeFloat in interface BlockBuilder

writeDouble

public BlockBuilder writeDouble(double value)

Description copied from interface: BlockBuilder

Write a double to the current entry;

Specified by:

writeDouble in interface BlockBuilder

writeBytes

public BlockBuilder writeBytes(io.airlift.slice.Slice source,
                               int sourceIndex,
                               int length)

Description copied from interface: BlockBuilder

Write a byte sequences to the current entry;

Specified by:

writeBytes in interface BlockBuilder

writeObject

public BlockBuilder writeObject(Object value)

Description copied from interface: BlockBuilder

Write an object to the current entry;

Specified by:

writeObject in interface BlockBuilder

beginBlockEntry

public ArrayElementBlockWriter 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 ArrayBlock 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