org.apache.drill.exec.physical.impl.partitionsender

Interface Partitioner

All Known Implementing Classes:

PartitionerTemplate

public interface Partitioner

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_RECORD_BATCH_SIZE
static TemplateClassDefinition<Partitioner>	TEMPLATE_DEFINITION

Method Summary

Modifier and Type	Method and Description
void	clear()
void	flushOutgoingBatches(boolean isLastBatch, boolean schemaChanged)
PartitionOutgoingBatch	getOutgoingBatch(int index) Get PartitionOutgoingBatch based on the fact that there can be > 1 Partitioner
List<? extends PartitionOutgoingBatch>	getOutgoingBatches()
OperatorStats	getStats()
void	initialize()
void	partitionBatch(RecordBatch incoming)
void	setup(ExchangeFragmentContext context, RecordBatch incoming, HashPartitionSender popConfig, OperatorStats stats, OperatorContext oContext, ClassGenerator<?> cg, int start, int count)

Field Detail

DEFAULT_RECORD_BATCH_SIZE

static final int DEFAULT_RECORD_BATCH_SIZE

See Also:

Constant Field Values

TEMPLATE_DEFINITION

static final TemplateClassDefinition<Partitioner> TEMPLATE_DEFINITION

Method Detail

setup

void setup(ExchangeFragmentContext context,
           RecordBatch incoming,
           HashPartitionSender popConfig,
           OperatorStats stats,
           OperatorContext oContext,
           ClassGenerator<?> cg,
           int start,
           int count)
    throws SchemaChangeException

Throws:

SchemaChangeException

partitionBatch

void partitionBatch(RecordBatch incoming)
             throws IOException

Throws:

IOException

flushOutgoingBatches

void flushOutgoingBatches(boolean isLastBatch,
                          boolean schemaChanged)
                   throws IOException

Throws:

IOException

initialize

void initialize()

clear

void clear()

getOutgoingBatches

List<? extends PartitionOutgoingBatch> getOutgoingBatches()

getOutgoingBatch

PartitionOutgoingBatch getOutgoingBatch(int index)

Get PartitionOutgoingBatch based on the fact that there can be > 1 Partitioner

Parameters:

index -

Returns:

PartitionOutgoingBatch that matches index within Partitioner. This method can return null if index does not fall within boundary of this Partitioner

getStats

OperatorStats getStats()