org.apache.drill.exec.physical.impl.partitionsender

Class PartitionerTemplate.OutgoingRecordBatch

java.lang.Object

org.apache.drill.exec.physical.impl.partitionsender.PartitionerTemplate.OutgoingRecordBatch

All Implemented Interfaces:

Iterable<VectorWrapper<?>>, PartitionOutgoingBatch, VectorAccessible

Enclosing class:

PartitionerTemplate

public class PartitionerTemplate.OutgoingRecordBatch
extends Object
implements PartitionOutgoingBatch, VectorAccessible

Constructor Summary

Constructors

Constructor and Description
OutgoingRecordBatch(OperatorStats stats, HashPartitionSender operator, AccountingDataTunnel tunnel, FragmentContext context, BufferAllocator allocator, int oppositeMinorFragmentId)

Method Summary

Modifier and Type	Method and Description
void	clear()
protected void	copy(int inIndex)
protected void	doEval(int inIndex, int outIndex)
protected void	doSetup(RecordBatch incoming, VectorAccessible outgoing)
void	flush(boolean schemaChanged)
int	getRecordCount() Get the number of records.
BatchSchema	getSchema() Get the schema of the current RecordBatch.
SelectionVector2	getSelectionVector2()
SelectionVector4	getSelectionVector4()
long	getTotalRecords()
VectorWrapper<?>	getValueAccessorById(Class<?> clazz, int... fieldIds)
TypedFieldId	getValueVectorId(SchemaPath path) Get the value vector type and id for the given schema path.
WritableBatch	getWritableBatch()
void	initializeBatch() Initialize the OutgoingBatch based on the current schema in incoming RecordBatch
Iterator<VectorWrapper<?>>	iterator()
void	resetBatch()
void	setIsLast()
void	terminate()
void	updateStats(FragmentWritableBatch writableBatch)

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

OutgoingRecordBatch

public OutgoingRecordBatch(OperatorStats stats,
                           HashPartitionSender operator,
                           AccountingDataTunnel tunnel,
                           FragmentContext context,
                           BufferAllocator allocator,
                           int oppositeMinorFragmentId)

Method Detail

copy

protected void copy(int inIndex)
             throws IOException

Throws:

IOException

terminate

public void terminate()

Specified by:

terminate in interface PartitionOutgoingBatch

doSetup

protected void doSetup(@Named(value="incoming")
                       RecordBatch incoming,
                       @Named(value="outgoing")
                       VectorAccessible outgoing)
                throws SchemaChangeException

Throws:

SchemaChangeException

doEval

protected void doEval(@Named(value="inIndex")
                      int inIndex,
                      @Named(value="outIndex")
                      int outIndex)
               throws SchemaChangeException

Throws:

SchemaChangeException

flush

public void flush(boolean schemaChanged)
           throws IOException

Throws:

IOException

updateStats

public void updateStats(FragmentWritableBatch writableBatch)

initializeBatch

public void initializeBatch()

Initialize the OutgoingBatch based on the current schema in incoming RecordBatch

resetBatch

public void resetBatch()

setIsLast

public void setIsLast()

getSchema

public BatchSchema getSchema()

Description copied from interface: VectorAccessible

Get the schema of the current RecordBatch. This changes if and only if a *_NEW_SCHEMA IterOutcome is provided.

Specified by:

getSchema in interface VectorAccessible

Returns:

schema of the current batch

getRecordCount

public int getRecordCount()

Description copied from interface: VectorAccessible

Get the number of records.

Specified by:

getRecordCount in interface VectorAccessible

Returns:

number of records

getTotalRecords

public long getTotalRecords()

Specified by:

getTotalRecords in interface PartitionOutgoingBatch

getValueVectorId

public TypedFieldId getValueVectorId(SchemaPath path)

Description copied from interface: VectorAccessible

Get the value vector type and id for the given schema path. The TypedFieldId should store a fieldId which is the same as the ordinal position of the field within the Iterator provided this classes implementation of Iterable<ValueVector>.

Specified by:

getValueVectorId in interface VectorAccessible

Parameters:

path - the path where the vector should be located.

Returns:

the local field id associated with this vector. If no field matches this path, this will return a null TypedFieldId

getValueAccessorById

public VectorWrapper<?> getValueAccessorById(Class<?> clazz,
                                             int... fieldIds)

Specified by:

getValueAccessorById in interface VectorAccessible

iterator

public Iterator<VectorWrapper<?>> iterator()

Specified by:

iterator in interface Iterable<VectorWrapper<?>>

getSelectionVector2

public SelectionVector2 getSelectionVector2()

Specified by:

getSelectionVector2 in interface VectorAccessible

getSelectionVector4

public SelectionVector4 getSelectionVector4()

Specified by:

getSelectionVector4 in interface VectorAccessible

getWritableBatch

public WritableBatch getWritableBatch()

clear

public void clear()