org.apache.drill.exec.physical.impl.flatten

Interface Flattener

All Known Implementing Classes:

FlattenTemplate

public interface Flattener

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	Flattener.Monitor

Field Summary

Fields

Modifier and Type	Field and Description
static TemplateClassDefinition<Flattener>	TEMPLATE_DEFINITION

Method Summary

Modifier and Type	Method and Description
int	flattenRecords(int recordCount, int firstOutputIndex, Flattener.Monitor monitor)
RepeatedValueVector	getFlattenField()
void	resetGroupIndex()
void	setFlattenField(RepeatedValueVector repeatedColumn)
void	setOutputCount(int outputCount)
void	setup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing, List<TransferPair> transfers)

Field Detail

TEMPLATE_DEFINITION

static final TemplateClassDefinition<Flattener> TEMPLATE_DEFINITION

Method Detail

setup

void setup(FragmentContext context,
           RecordBatch incoming,
           RecordBatch outgoing,
           List<TransferPair> transfers)
    throws SchemaChangeException

Throws:

SchemaChangeException

flattenRecords

int flattenRecords(int recordCount,
                   int firstOutputIndex,
                   Flattener.Monitor monitor)

setFlattenField

void setFlattenField(RepeatedValueVector repeatedColumn)

setOutputCount

void setOutputCount(int outputCount)

getFlattenField

RepeatedValueVector getFlattenField()

resetGroupIndex

void resetGroupIndex()