org.apache.drill.exec.vector.complex

Class AbstractContainerVector

java.lang.Object

org.apache.drill.exec.vector.complex.AbstractContainerVector

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<ValueVector>, ValueVector

Direct Known Subclasses:

AbstractMapVector, RepeatedListVector

public abstract class AbstractContainerVector
extends Object
implements ValueVector

Base class for composite vectors. This class implements common functionality of composite vectors.

Nested Class Summary

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

ValueVector.Accessor, ValueVector.Mutator

Field Summary

Fields

Modifier and Type	Field and Description
protected BufferAllocator	allocator
protected CallBack	callBack
protected MaterializedField	field

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

BITS_VECTOR_NAME, MAX_BUFFER_SIZE, MAX_ROW_COUNT, MIN_ROW_COUNT, OFFSETS_VECTOR_NAME, VALUES_VECTOR_NAME

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractContainerVector(MaterializedField field, BufferAllocator allocator, CallBack callBack)

Method Summary

Modifier and Type	Method and Description
abstract <T extends ValueVector> T	addOrGet(String name, TypeProtos.MajorType type, Class<T> clazz)
void	allocateNew() Allocate new buffers.
void	close() Clears out all underlying child vectors.
BufferAllocator	getAllocator()
ValueVector	getChild(String name) Returns a ValueVector corresponding to the given field name if exists or null.
abstract <T extends ValueVector> T	getChild(String name, Class<T> clazz)
protected Collection<String>	getChildFieldNames() Returns a sequence of field names in the order that they show up in the schema.
abstract VectorWithOrdinal	getChildVectorWithOrdinal(String name)
MaterializedField	getField() Returns the field definition of this instance.
abstract int	size()
protected boolean	supportsDirectRead()
protected <T extends ValueVector> T	typeify(ValueVector v, Class<T> clazz)

Methods inherited from class java.lang.Object

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

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

allocateNewSafe, clear, collectLedgers, copyEntry, exchange, getAccessor, getAllocatedSize, getBuffers, getBufferSize, getBufferSizeFor, getMetadata, getMutator, getPayloadByteCount, getReader, getTransferPair, getTransferPair, getValueCapacity, load, makeTransferPair, setInitialCapacity, toNullable

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Field Detail

field

protected MaterializedField field

allocator

protected final BufferAllocator allocator

callBack

protected final CallBack callBack

Constructor Detail

AbstractContainerVector

protected AbstractContainerVector(MaterializedField field,
                                  BufferAllocator allocator,
                                  CallBack callBack)

Method Detail

allocateNew

public void allocateNew()
                 throws OutOfMemoryException

Description copied from interface: ValueVector

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

Specified by:

allocateNew in interface ValueVector

Throws:

OutOfMemoryException - Thrown if no memory can be allocated.

getAllocator

public BufferAllocator getAllocator()

Specified by:

getAllocator in interface ValueVector

getField

public MaterializedField getField()

Returns the field definition of this instance.

Specified by:

getField in interface ValueVector

getChild

public ValueVector getChild(String name)

Returns a ValueVector corresponding to the given field name if exists or null.

getChildFieldNames

protected Collection<String> getChildFieldNames()

Returns a sequence of field names in the order that they show up in the schema.

close

public void close()

Clears out all underlying child vectors.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ValueVector

typeify

protected <T extends ValueVector> T typeify(ValueVector v,
                                            Class<T> clazz)

supportsDirectRead

protected boolean supportsDirectRead()

size

public abstract int size()

addOrGet

public abstract <T extends ValueVector> T addOrGet(String name,
                                                   TypeProtos.MajorType type,
                                                   Class<T> clazz)

getChild

public abstract <T extends ValueVector> T getChild(String name,
                                                   Class<T> clazz)

getChildVectorWithOrdinal

public abstract VectorWithOrdinal getChildVectorWithOrdinal(String name)