Package org.apache.drill.exec.physical.impl.aggregate

Class InternalBatch

java.lang.Object

org.apache.drill.exec.physical.impl.aggregate.InternalBatch

All Implemented Interfaces:

Iterable<VectorWrapper<?>>

public class InternalBatch
extends Object
implements Iterable<VectorWrapper<?>>

Constructor Summary

Constructors

Constructor	Description
InternalBatch(RecordBatch incoming, OperatorContext oContext)
InternalBatch(RecordBatch incoming, VectorWrapper<?>[] ignoreWrappers, OperatorContext oContext)

Method Summary

Modifier and Type	Method	Description
void	clear()
FragmentContext	getContext()
BatchSchema	getSchema()
SelectionVector2	getSv2()
SelectionVector4	getSv4()
VectorWrapper<?>	getValueAccessorById(Class<?> clazz, int[] fieldIds)
Iterator<VectorWrapper<?>>	iterator()

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 Details

InternalBatch

public InternalBatch(RecordBatch incoming,
 OperatorContext oContext)

InternalBatch

public InternalBatch(RecordBatch incoming,
 VectorWrapper<?>[] ignoreWrappers,
 OperatorContext oContext)

Method Details

getSchema

public BatchSchema getSchema()

getSv2

public SelectionVector2 getSv2()

getSv4

public SelectionVector4 getSv4()

iterator

public Iterator<VectorWrapper<?>> iterator()

Specified by:

iterator in interface Iterable<VectorWrapper<?>>

clear

public void clear()

getValueAccessorById

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

getContext

public FragmentContext getContext()