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

Class SortImpl.SingleBatchResults

java.lang.Object

org.apache.drill.exec.physical.impl.xsort.SortImpl.SingleBatchResults

All Implemented Interfaces:

SortImpl.SortResults

Enclosing class:

SortImpl

public static class SortImpl.SingleBatchResults
extends Object
implements SortImpl.SortResults

Return results for a single input batch. No merge is needed; the original (sorted) input batch is simply passed as the result. Note that this version requires replacing the operator output container with the batch container. (Vector ownership transfer was already done when accepting the input batch.)

Constructor Summary

Constructors

Constructor	Description
SingleBatchResults(InputBatch batch, VectorContainer outputContainer)

Method Summary

Modifier and Type	Method	Description
void	close()
int	getBatchCount()
VectorContainer	getContainer()	Container into which results are delivered.
int	getRecordCount()
SelectionVector2	getSv2()
SelectionVector4	getSv4()
boolean	next()
void	updateOutputContainer(VectorContainer container, SelectionVector4 sv4, RecordBatch.IterOutcome outcome, BatchSchema schema)

Methods inherited from class java.lang.Object

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

Constructor Details

SingleBatchResults

public SingleBatchResults(InputBatch batch,
 VectorContainer outputContainer)

Method Details

next

public boolean next()

Specified by:

next in interface SortImpl.SortResults

close

public void close()

Specified by:

close in interface SortImpl.SortResults

getBatchCount

public int getBatchCount()

Specified by:

getBatchCount in interface SortImpl.SortResults

getRecordCount

public int getRecordCount()

Specified by:

getRecordCount in interface SortImpl.SortResults

getSv4

public SelectionVector4 getSv4()

Specified by:

getSv4 in interface SortImpl.SortResults

getSv2

public SelectionVector2 getSv2()

Specified by:

getSv2 in interface SortImpl.SortResults

getContainer

public VectorContainer getContainer()

Description copied from interface: SortImpl.SortResults

Container into which results are delivered. May the the original operator container, or may be a different one. This is the container that should be sent downstream. This is a fixed value for all returned results.

Specified by:

getContainer in interface SortImpl.SortResults

Returns:

updateOutputContainer

public void updateOutputContainer(VectorContainer container,
 SelectionVector4 sv4,
 RecordBatch.IterOutcome outcome,
 BatchSchema schema)

Specified by:

updateOutputContainer in interface SortImpl.SortResults