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

Interface Partitioner

All Known Implementing Classes:

PartitionerTemplate

public interface Partitioner

Field Summary

Fields

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

Method Summary

Modifier and Type	Method	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 Details

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 Details

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()