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

Class SingleBatchSorterTemplate

java.lang.Object

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

All Implemented Interfaces:

SingleBatchSorter, org.apache.hadoop.util.IndexedSortable

public abstract class SingleBatchSorterTemplate
extends Object
implements SingleBatchSorter, org.apache.hadoop.util.IndexedSortable

Field Summary

Fields inherited from interface org.apache.drill.exec.physical.impl.xsort.SingleBatchSorter

TEMPLATE_DEFINITION

Constructor Summary

Constructors

Constructor and Description
SingleBatchSorterTemplate()

Method Summary

Modifier and Type	Method and Description
int	compare(int leftIndex, int rightIndex)
abstract int	doEval(char leftIndex, char rightIndex)
abstract void	doSetup(FragmentContext context, VectorAccessible incoming, RecordBatch outgoing)
void	setup(FragmentContext context, SelectionVector2 vector2, VectorAccessible incoming)
void	sort(SelectionVector2 vector2)
void	swap(int sv0, int sv1)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleBatchSorterTemplate

public SingleBatchSorterTemplate()

Method Detail

setup

public void setup(FragmentContext context,
                  SelectionVector2 vector2,
                  VectorAccessible incoming)
           throws SchemaChangeException

Specified by:

setup in interface SingleBatchSorter

Throws:

SchemaChangeException

sort

public void sort(SelectionVector2 vector2)

Specified by:

sort in interface SingleBatchSorter

swap

public void swap(int sv0,
                 int sv1)

Specified by:

swap in interface org.apache.hadoop.util.IndexedSortable

compare

public int compare(int leftIndex,
                   int rightIndex)

Specified by:

compare in interface org.apache.hadoop.util.IndexedSortable

doSetup

public abstract void doSetup(@Named(value="context")
                             FragmentContext context,
                             @Named(value="incoming")
                             VectorAccessible incoming,
                             @Named(value="outgoing")
                             RecordBatch outgoing)
                      throws SchemaChangeException

Throws:

SchemaChangeException

doEval

public abstract int doEval(@Named(value="leftIndex")
                           char leftIndex,
                           @Named(value="rightIndex")
                           char rightIndex)
                    throws SchemaChangeException

Throws:

SchemaChangeException

toString

public String toString()

Overrides:

toString in class Object