com.facebook.presto.spi.block

Class MapBlock

java.lang.Object

com.facebook.presto.spi.block.AbstractMapBlock

com.facebook.presto.spi.block.MapBlock

All Implemented Interfaces:

Block

public class MapBlock
extends AbstractMapBlock

Nested Class Summary

Nested classes/interfaces inherited from class com.facebook.presto.spi.block.AbstractMapBlock

AbstractMapBlock.HashTables

Field Summary

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

keyBlockHashCode, keyBlockNativeEquals, keyNativeHashCode, keyType

Method Summary

Modifier and Type	Method and Description
static MapBlock	createMapBlockInternal(int startOffset, int positionCount, Optional<boolean[]> mapIsNull, int[] offsets, Block keyBlock, Block valueBlock, AbstractMapBlock.HashTables hashTables, Type keyType, MethodHandle keyBlockNativeEquals, MethodHandle keyNativeHashCode, MethodHandle keyBlockHashCode) Create a map block directly without per element validations.
protected void	ensureHashTableLoaded()
static MapBlock	fromKeyValueBlock(Optional<boolean[]> mapIsNull, int[] offsets, Block keyBlock, Block valueBlock, MapType mapType, MethodHandle keyBlockNativeEquals, MethodHandle keyNativeHashCode, MethodHandle keyBlockHashCode) Create a map block directly from columnar nulls, keys, values, and offsets into the keys and values.
protected AbstractMapBlock.HashTables	getHashTables()
Block	getLoadedBlock() Returns a block that assures all data is in memory.
protected boolean[]	getMapIsNull()
protected int	getOffsetBase() offset is entry-based, not position-based.
protected int[]	getOffsets() offset is entry-based, not position-based.
int	getPositionCount() Returns the number of positions in this block.
protected Block	getRawKeyBlock()
protected Block	getRawValueBlock()
long	getRetainedSizeInBytes() Returns the retained size of this block in memory, including over-allocations.
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.AbstractMapBlock

copyPositions, copyRegion, getEncodingName, getEstimatedDataSizeForStats, getObject, getPositionsSizeInBytes, getRegion, getRegionSizeInBytes, getSingleValueBlock, isHashTablesPresent, 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

fromKeyValueBlock

public static MapBlock fromKeyValueBlock(Optional<boolean[]> mapIsNull,
                                         int[] offsets,
                                         Block keyBlock,
                                         Block valueBlock,
                                         MapType mapType,
                                         MethodHandle keyBlockNativeEquals,
                                         MethodHandle keyNativeHashCode,
                                         MethodHandle keyBlockHashCode)

Create a map block directly from columnar nulls, keys, values, and offsets into the keys and values. A null map must have no entries.

Parameters:

mapType - key type K

keyBlockNativeEquals - equality between key stack type and a block+position; signature is (K, Block, int)boolean

keyNativeHashCode - hash of a key stack type; signature is (K)long

createMapBlockInternal

public static MapBlock createMapBlockInternal(int startOffset,
                                              int positionCount,
                                              Optional<boolean[]> mapIsNull,
                                              int[] offsets,
                                              Block keyBlock,
                                              Block valueBlock,
                                              AbstractMapBlock.HashTables hashTables,
                                              Type keyType,
                                              MethodHandle keyBlockNativeEquals,
                                              MethodHandle keyNativeHashCode,
                                              MethodHandle keyBlockHashCode)

Create a map block directly without per element validations.

Internal use by this package and com.facebook.presto.spi.Type only.

Parameters:

keyType - key type K

keyBlockNativeEquals - equality between key stack type and a block+position; signature is (K, Block, int)boolean

keyNativeHashCode - hash of a key stack type; signature is (K)long

getRawKeyBlock

protected Block getRawKeyBlock()

Specified by:

getRawKeyBlock in class AbstractMapBlock

getRawValueBlock

protected Block getRawValueBlock()

Specified by:

getRawValueBlock in class AbstractMapBlock

getHashTables

protected AbstractMapBlock.HashTables getHashTables()

Specified by:

getHashTables in class AbstractMapBlock

getOffsets

protected int[] getOffsets()

Description copied from class: AbstractMapBlock

offset is entry-based, not position-based. In other words, if offset[1] is 6, it means the first map has 6 key-value pairs, not 6 key/values (which would be 3 pairs).

Specified by:

getOffsets in class AbstractMapBlock

getOffsetBase

protected int getOffsetBase()

Description copied from class: AbstractMapBlock

offset is entry-based, not position-based. (see getOffsets)

Specified by:

getOffsetBase in class AbstractMapBlock

getMapIsNull

@Nullable
protected boolean[] getMapIsNull()

Specified by:

getMapIsNull in class AbstractMapBlock

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.

ensureHashTableLoaded

protected void ensureHashTableLoaded()

Specified by:

ensureHashTableLoaded in class AbstractMapBlock