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

Class TupleState.DictArrayVectorState

java.lang.Object

org.apache.drill.exec.physical.resultSet.impl.TupleState.DictVectorState<RepeatedDictVector>

org.apache.drill.exec.physical.resultSet.impl.TupleState.DictArrayVectorState

All Implemented Interfaces:

VectorState

Enclosing class:

TupleState

public static class TupleState.DictArrayVectorState
extends TupleState.DictVectorState<RepeatedDictVector>

Field Summary

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

offsets, vector

Constructor Summary

Constructors

Constructor	Description
DictArrayVectorState(RepeatedDictVector vector, VectorState offsets, VectorState dictOffsets)

Method Summary

Modifier and Type	Method	Description
int	allocate(int cardinality)	Allocate a new vector with the number of elements given.
void	close()	Clear the vector(s) associated with this state.
void	harvestWithLookAhead()	A batch is being harvested after an overflow.
void	rollover(int cardinality)	A vector has overflowed.
void	startBatchWithLookAhead()	A new batch is starting while an look-ahead vector exists.

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

dump, isProjected, offsetVectorState, vector

Methods inherited from class java.lang.Object

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

Constructor Details

DictArrayVectorState

public DictArrayVectorState(RepeatedDictVector vector,
 VectorState offsets,
 VectorState dictOffsets)

Method Details

allocate

public int allocate(int cardinality)

Description copied from interface: VectorState

Allocate a new vector with the number of elements given. If the vector is an array, then the cardinality given is the number of arrays.

Specified by:

allocate in interface VectorState

Overrides:

allocate in class TupleState.DictVectorState<RepeatedDictVector>

Parameters:

cardinality - number of elements desired in the allocated vector

Returns:

the number of bytes allocated

rollover

public void rollover(int cardinality)

Description copied from interface: VectorState

A vector has overflowed. Create a new look-ahead vector of the given cardinality, then copy the overflow values from the main vector to the look-ahead vector.

Specified by:

rollover in interface VectorState

Overrides:

rollover in class TupleState.DictVectorState<RepeatedDictVector>

Parameters:

cardinality - the number of elements in the new vector. If this vector is an array, then this is the number of arrays

harvestWithLookAhead

public void harvestWithLookAhead()

Description copied from interface: VectorState

A batch is being harvested after an overflow. Put the full batch back into the main vector so it can be harvested.

Specified by:

harvestWithLookAhead in interface VectorState

Overrides:

harvestWithLookAhead in class TupleState.DictVectorState<RepeatedDictVector>

startBatchWithLookAhead

public void startBatchWithLookAhead()

Description copied from interface: VectorState

A new batch is starting while an look-ahead vector exists. Move the look-ahead buffers into the main vector to prepare for writing the rest of the batch.

Specified by:

startBatchWithLookAhead in interface VectorState

Overrides:

startBatchWithLookAhead in class TupleState.DictVectorState<RepeatedDictVector>

close

public void close()

Description copied from interface: VectorState

Clear the vector(s) associated with this state.

Specified by:

close in interface VectorState

Overrides:

close in class TupleState.DictVectorState<RepeatedDictVector>