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

Interface Unnest

All Known Implementing Classes:

UnnestImpl

public interface Unnest

Placeholder for future unnest implementation that may require code generation. Current implementation does not require any

See Also:

• UnnestImpl

Method Summary

Modifier and Type	Method	Description
void	close()
RepeatedValueVector	getUnnestField()
void	resetGroupIndex()	Reset the index at which the incoming vector is being processed.
void	setOutputCount(int outputCount)	Set the maximum number of values allowed in the output.
void	setRowIdVector(IntVector v)	Set the vector for the rowId implicit column
void	setUnnestField(RepeatedValueVector repeatedColumn)	Set the field to be unnested
void	setup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing, List<TransferPair> transfers)
int	unnestRecords(int recordCount)	Performs the actual unnest operation.

Method Details

setup

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

Throws:

SchemaChangeException

unnestRecords

int unnestRecords(int recordCount)

Performs the actual unnest operation.

Parameters:

recordCount -

Returns:

number of values in output

setUnnestField

void setUnnestField(RepeatedValueVector repeatedColumn)

Set the field to be unnested

Parameters:

repeatedColumn -

setOutputCount

void setOutputCount(int outputCount)

Set the maximum number of values allowed in the output.

Parameters:

outputCount -

getUnnestField

RepeatedValueVector getUnnestField()

setRowIdVector

void setRowIdVector(IntVector v)

Set the vector for the rowId implicit column

resetGroupIndex

void resetGroupIndex()

Reset the index at which the incoming vector is being processed. Called every time a new batch comes in.

close

void close()