Package 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	Description
static interface	Flattener.Monitor

Field Summary

Fields

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

Method Summary

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

TEMPLATE_DEFINITION

static final TemplateClassDefinition<Flattener> TEMPLATE_DEFINITION

Method Details

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