org.apache.drill.exec.vector

Class RepeatedBitVector

java.lang.Object

org.apache.drill.exec.vector.BaseValueVector

org.apache.drill.exec.vector.complex.BaseRepeatedValueVector

org.apache.drill.exec.vector.RepeatedBitVector

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<ValueVector>, ContainerVectorLike, RepeatedFixedWidthVectorLike, RepeatedValueVector, ValueVector

public final class RepeatedBitVector
extends BaseRepeatedValueVector
implements RepeatedFixedWidthVectorLike

RepeatedBit implements a vector with multiple values per row (e.g. JSON array or repeated protobuf field). The implementation uses an additional value vectors to convert the index offset to the underlying element offset. The count of values comes from subtracting two successive offsets. NB: this class is automatically generated from RepeatedValueVectors.java and ValueVectorTypes.tdd using FreeMarker.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	RepeatedBitVector.Accessor
class	RepeatedBitVector.Mutator

Nested classes/interfaces inherited from class org.apache.drill.exec.vector.complex.BaseRepeatedValueVector

BaseRepeatedValueVector.BaseRepeatedAccessor, BaseRepeatedValueVector.BaseRepeatedMutator, BaseRepeatedValueVector.BaseRepeatedValueVectorTransferPair<T extends BaseRepeatedValueVector>

Nested classes/interfaces inherited from class org.apache.drill.exec.vector.BaseValueVector

BaseValueVector.BaseAccessor, BaseValueVector.BaseMutator

Nested classes/interfaces inherited from interface org.apache.drill.exec.vector.complex.RepeatedValueVector

RepeatedValueVector.RepeatedAccessor, RepeatedValueVector.RepeatedMutator

Field Summary

Fields inherited from class org.apache.drill.exec.vector.complex.BaseRepeatedValueVector

DATA_VECTOR_NAME, DEFAULT_DATA_VECTOR, offsets, OFFSETS_FIELD, OFFSETS_VECTOR_NAME, vector

Fields inherited from class org.apache.drill.exec.vector.BaseValueVector

allocator, field, INITIAL_VALUE_ALLOCATION, MAX_ALLOCATION_SIZE

Fields inherited from interface org.apache.drill.exec.vector.complex.RepeatedValueVector

DEFAULT_REPEAT_PER_RECORD

Fields inherited from interface org.apache.drill.exec.vector.ValueVector

BITS_VECTOR_NAME, MAX_BUFFER_SIZE, MAX_ROW_COUNT, MIN_ROW_COUNT, VALUES_VECTOR_NAME

Constructor Summary

Constructors

Constructor and Description
RepeatedBitVector(MaterializedField field, BufferAllocator allocator)

Method Summary

Modifier and Type	Method and Description
AddOrGetResult<BitVector>	addOrGetVector(VectorDescriptor descriptor) Creates and adds a child vector if none with the same name exists, else returns the vector instance.
void	allocateNew() Allocate new buffers.
void	allocateNew(int valueCount, int innerValueCount) Allocate a new memory space for this vector.
boolean	allocateNewSafe() Allocates new buffers.
void	copyEntry(int toIndex, ValueVector from, int fromIndex)
void	copyFrom(int inIndex, int outIndex, RepeatedBitVector v)
void	copyFromSafe(int inIndex, int outIndex, RepeatedBitVector v)
RepeatedBitVector.Accessor	getAccessor() Returns an accessor that is used to read from this vector instance.
BitVector	getDataVector()
RepeatedBitVector.Mutator	getMutator() Returns an mutator that is used to write to this vector instance.
FieldReader	getReader() Returns a field reader that supports reading values from this vector.
TransferPair	getTransferPair(BufferAllocator allocator) Returns a transfer pair, creating a new target vector of the same type.
TransferPair	getTransferPair(String ref, BufferAllocator allocator)
TransferPair	makeTransferPair(ValueVector to) Returns a new transfer pair that is used to transfer underlying buffers into the target vector.
void	splitAndTransferTo(int startIndex, int groups, RepeatedBitVector to)
void	transferTo(RepeatedBitVector target)

Methods inherited from class org.apache.drill.exec.vector.complex.BaseRepeatedValueVector

clear, collectLedgers, exchange, getAllocatedSize, getBuffers, getBufferSize, getBufferSizeFor, getMetadataBuilder, getOffsetVector, getPayloadByteCount, getValueCapacity, iterator, load, replaceDataVector, setChildVector, setInitialCapacity, size

Methods inherited from class org.apache.drill.exec.vector.BaseValueVector

checkBufRefs, close, fillBitsVector, getAllocator, getField, getField, getMetadata, toNullable, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.vector.ValueVector

close, getAllocator, getField, getMetadata, toNullable

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

RepeatedBitVector

public RepeatedBitVector(MaterializedField field,
                         BufferAllocator allocator)

Method Detail

getMutator

public RepeatedBitVector.Mutator getMutator()

Description copied from interface: ValueVector

Returns an mutator that is used to write to this vector instance.

Specified by:

getMutator in interface RepeatedValueVector

Specified by:

getMutator in interface ValueVector

getAccessor

public RepeatedBitVector.Accessor getAccessor()

Description copied from interface: ValueVector

Returns an accessor that is used to read from this vector instance.

Specified by:

getAccessor in interface RepeatedValueVector

Specified by:

getAccessor in interface ValueVector

getReader

public FieldReader getReader()

Description copied from interface: ValueVector

Returns a field reader that supports reading values from this vector.

Specified by:

getReader in interface ValueVector

getDataVector

public BitVector getDataVector()

Specified by:

getDataVector in interface RepeatedValueVector

Overrides:

getDataVector in class BaseRepeatedValueVector

Returns:

the underlying data vector or null if none exists.

getTransferPair

public TransferPair getTransferPair(BufferAllocator allocator)

Description copied from interface: ValueVector

Returns a transfer pair, creating a new target vector of the same type.

Specified by:

getTransferPair in interface ValueVector

Overrides:

getTransferPair in class BaseValueVector

getTransferPair

public TransferPair getTransferPair(String ref,
                                    BufferAllocator allocator)

Specified by:

getTransferPair in interface ValueVector

makeTransferPair

public TransferPair makeTransferPair(ValueVector to)

Description copied from interface: ValueVector

Returns a new transfer pair that is used to transfer underlying buffers into the target vector.

Specified by:

makeTransferPair in interface ValueVector

addOrGetVector

public AddOrGetResult<BitVector> addOrGetVector(VectorDescriptor descriptor)

Description copied from interface: ContainerVectorLike

Creates and adds a child vector if none with the same name exists, else returns the vector instance.

Specified by:

addOrGetVector in interface ContainerVectorLike

Overrides:

addOrGetVector in class BaseRepeatedValueVector

Parameters:

descriptor - vector descriptor

Returns:

result of operation wrapping vector corresponding to the given descriptor and whether it's newly created

transferTo

public void transferTo(RepeatedBitVector target)

splitAndTransferTo

public void splitAndTransferTo(int startIndex,
                               int groups,
                               RepeatedBitVector to)

copyFrom

public void copyFrom(int inIndex,
                     int outIndex,
                     RepeatedBitVector v)

copyFromSafe

public void copyFromSafe(int inIndex,
                         int outIndex,
                         RepeatedBitVector v)

copyEntry

public void copyEntry(int toIndex,
                      ValueVector from,
                      int fromIndex)

Specified by:

copyEntry in interface ValueVector

allocateNewSafe

public boolean allocateNewSafe()

Description copied from interface: ValueVector

Allocates new buffers. ValueVector implements logic to determine how much to allocate.

Specified by:

allocateNewSafe in interface ValueVector

Overrides:

allocateNewSafe in class BaseRepeatedValueVector

Returns:

Returns true if allocation was successful.

allocateNew

public void allocateNew()

Description copied from interface: ValueVector

Allocate new buffers. ValueVector implements logic to determine how much to allocate.

Specified by:

allocateNew in interface ValueVector

allocateNew

public void allocateNew(int valueCount,
                        int innerValueCount)

Description copied from interface: RepeatedFixedWidthVectorLike

Allocate a new memory space for this vector. Must be called prior to using the ValueVector.

Specified by:

allocateNew in interface RepeatedFixedWidthVectorLike

Parameters:

valueCount - Number of separate repeating groupings.

innerValueCount - Number of supported values in the vector.