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

Class ColumnState.BaseContainerColumnState

java.lang.Object

org.apache.drill.exec.physical.resultSet.impl.ColumnState

org.apache.drill.exec.physical.resultSet.impl.ColumnState.BaseContainerColumnState

Direct Known Subclasses:

RepeatedListState.RepeatedListColumnState, TupleState.DictColumnState, TupleState.MapColumnState, UnionState.UnionColumnState

Enclosing class:

ColumnState

public abstract static class ColumnState.BaseContainerColumnState
extends ColumnState

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.exec.physical.resultSet.impl.ColumnState

ColumnState.BaseContainerColumnState, ColumnState.PrimitiveColumnState, ColumnState.State

Field Summary

Fields inherited from class org.apache.drill.exec.physical.resultSet.impl.ColumnState

addVersion, cardinality, loader, outputIndex, state, vectorState, writer

Constructor Summary

Constructors

Constructor	Description
BaseContainerColumnState(org.apache.drill.exec.physical.resultSet.impl.LoaderInternals loader, AbstractObjectWriter writer, VectorState vectorState)

Method Summary

Modifier and Type	Method	Description
void	close()
abstract ContainerState	container()
void	harvestWithLookAhead()	Writing of a row batch is complete.
void	rollover()	A column within the row batch overflowed.
void	startBatch(boolean schemaOnly)	Prepare the column for a new row batch after overflow on the previous batch.
void	updateCardinality(int cardinality)

Methods inherited from class org.apache.drill.exec.physical.resultSet.impl.ColumnState

allocateVectors, buildOutput, dump, innerCardinality, isProjected, outerCardinality, outputSchema, schema, vector, vectorState, writer

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BaseContainerColumnState

public BaseContainerColumnState(org.apache.drill.exec.physical.resultSet.impl.LoaderInternals loader,
 AbstractObjectWriter writer,
 VectorState vectorState)

Method Details

container

public abstract ContainerState container()

updateCardinality

public void updateCardinality(int cardinality)

Overrides:

updateCardinality in class ColumnState

startBatch

public void startBatch(boolean schemaOnly)

Description copied from class: ColumnState

Prepare the column for a new row batch after overflow on the previous batch. Restore the look-ahead buffer to the active vector so we start writing where we left off.

Overrides:

startBatch in class ColumnState

rollover

public void rollover()

Description copied from class: ColumnState

A column within the row batch overflowed. Prepare to absorb the rest of the in-flight row by rolling values over to a new vector, saving the complete vector for later. This column could have a value for the overflow row, or for some previous row, depending on exactly when and where the overflow occurs.

Overrides:

rollover in class ColumnState

harvestWithLookAhead

public void harvestWithLookAhead()

Description copied from class: ColumnState

Writing of a row batch is complete. Prepare the vector for harvesting to send downstream. If this batch encountered overflow, set aside the look-ahead vector and put the full vector buffer back into the active vector.

Overrides:

harvestWithLookAhead in class ColumnState

close

public void close()

Overrides:

close in class ColumnState