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

Class InputBatch

java.lang.Object

org.apache.drill.exec.physical.impl.xsort.BatchGroup

org.apache.drill.exec.physical.impl.xsort.InputBatch

All Implemented Interfaces:

AutoCloseable, Iterable<VectorWrapper<?>>, VectorAccessible

public class InputBatch
extends BatchGroup

The input batch group gathers batches buffered in memory before spilling. The structure of the data is:

• Contains a single batch received from the upstream (input) operator.
• Associated selection vector that provides a sorted indirection to the values in the batch.

Field Summary

Fields inherited from class org.apache.drill.exec.physical.impl.xsort.BatchGroup

allocator, currentContainer, mergeIndex, schema

Constructor Summary

Constructors

Constructor	Description
InputBatch(VectorContainer container, SelectionVector2 sv2, BufferAllocator allocator, long dataSize)

Method Summary

Modifier and Type	Method	Description
void	close()
long	getDataSize()
int	getNextIndex()
int	getRecordCount()	Get the number of records.
SelectionVector2	getSv2()

Methods inherited from class org.apache.drill.exec.physical.impl.xsort.BatchGroup

closeAll, getContainer, getSchema, getSelectionVector2, getSelectionVector4, getUnfilteredRecordCount, getValueAccessorById, getValueVectorId, iterator, setSchema

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

InputBatch

public InputBatch(VectorContainer container,
 SelectionVector2 sv2,
 BufferAllocator allocator,
 long dataSize)

Method Details

getSv2

public SelectionVector2 getSv2()

getDataSize

public long getDataSize()

getRecordCount

public int getRecordCount()

Description copied from interface: VectorAccessible

Get the number of records.

Specified by:

getRecordCount in interface VectorAccessible

Overrides:

getRecordCount in class BatchGroup

Returns:

number of records

getNextIndex

public int getNextIndex()

Overrides:

getNextIndex in class BatchGroup

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Overrides:

close in class BatchGroup

Throws:

IOException