org.apache.drill.exec.store

Class TestOutputMutator

java.lang.Object

org.apache.drill.exec.store.TestOutputMutator

All Implemented Interfaces:

Iterable<VectorWrapper<?>>, OutputMutator

public class TestOutputMutator
extends Object
implements OutputMutator, Iterable<VectorWrapper<?>>

Constructor Summary

Constructors

Constructor and Description
TestOutputMutator(BufferAllocator allocator)

Method Summary

Modifier and Type	Method and Description
<T extends ValueVector> T	addField(MaterializedField field, Class<T> clazz) Add a ValueVector for new (or existing) field.
void	addField(ValueVector vector)
void	allocate(int recordCount)
void	clear() Clear this mutator i.e.
CallBack	getCallBack()
VectorContainer	getContainer()
DrillBuf	getManagedBuffer() Allows a scanner to request a set of managed block of memory.
boolean	isNewSchema() Whether or not the fields added to the OutputMutator generated a new schema event.
Iterator<VectorWrapper<?>>	iterator()
void	removeField(MaterializedField field)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

TestOutputMutator

public TestOutputMutator(BufferAllocator allocator)

Method Detail

removeField

public void removeField(MaterializedField field)
                 throws SchemaChangeException

Throws:

SchemaChangeException

addField

public void addField(ValueVector vector)

iterator

public Iterator<VectorWrapper<?>> iterator()

Specified by:

iterator in interface Iterable<VectorWrapper<?>>

clear

public void clear()

Description copied from interface: OutputMutator

Clear this mutator i.e. reset it to pristine condition

Specified by:

clear in interface OutputMutator

isNewSchema

public boolean isNewSchema()

Description copied from interface: OutputMutator

Whether or not the fields added to the OutputMutator generated a new schema event.

Specified by:

isNewSchema in interface OutputMutator

Returns:

allocate

public void allocate(int recordCount)

Specified by:

allocate in interface OutputMutator

addField

public <T extends ValueVector> T addField(MaterializedField field,
                                          Class<T> clazz)
                                   throws SchemaChangeException

Description copied from interface: OutputMutator

Add a ValueVector for new (or existing) field.

Specified by:

addField in interface OutputMutator

Parameters:

field - The specification of the newly desired vector.

clazz - The expected ValueVector class. Also allows strongly typed use of this interface.

Returns:

The existing or new ValueVector associated with the provided field.

Throws:

SchemaChangeException - If the addition of this field is incompatible with this OutputMutator's capabilities.

getManagedBuffer

public DrillBuf getManagedBuffer()

Description copied from interface: OutputMutator

Allows a scanner to request a set of managed block of memory.

Specified by:

getManagedBuffer in interface OutputMutator

Returns:

A DrillBuf that will be released at the end of the current query (and can be resized as desired during use).

getCallBack

public CallBack getCallBack()

Specified by:

getCallBack in interface OutputMutator

Returns:

the CallBack object for this mutator

getContainer

public VectorContainer getContainer()