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

Class SampleSortTemplate

java.lang.Object

org.apache.drill.exec.physical.impl.orderedpartitioner.SampleSortTemplate

All Implemented Interfaces:

SampleSorter, org.apache.hadoop.util.IndexedSortable

public abstract class SampleSortTemplate
extends Object
implements SampleSorter, org.apache.hadoop.util.IndexedSortable

Field Summary

Fields inherited from interface org.apache.drill.exec.physical.impl.orderedpartitioner.SampleSorter

TEMPLATE_DEFINITION

Constructor Summary

Constructors

Constructor	Description
SampleSortTemplate()

Method Summary

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.physical.impl.orderedpartitioner.SampleSorter

setup

Constructor Details

SampleSortTemplate

public SampleSortTemplate()

Method Details

setup

public void setup(FragmentContext context,
 VectorContainer sampleBatch,
 SelectionVector2 vector2)
           throws SchemaChangeException

Throws:

SchemaChangeException

sort

public void sort(SelectionVector2 vector2,
 VectorContainer container)

Specified by:

sort in interface SampleSorter

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("context")
 FragmentContext context,
 @Named("incoming")
 VectorContainer incoming,
 @Named("outgoing")
 RecordBatch outgoing)

doEval

public abstract int doEval(@Named("leftIndex")
 int leftIndex,
 @Named("rightIndex")
 int rightIndex)