org.apache.drill.exec.physical.impl.protocol

Class IndirectContainerAccessor

java.lang.Object

org.apache.drill.exec.physical.impl.protocol.VectorContainerAccessor

org.apache.drill.exec.physical.impl.protocol.IndirectContainerAccessor

All Implemented Interfaces:

BatchAccessor

public class IndirectContainerAccessor
extends VectorContainerAccessor

Extension of the container accessor that holds an optional selection vector, presenting the batch row count as the selection vector count.

Field Summary

Fields inherited from class org.apache.drill.exec.physical.impl.protocol.VectorContainerAccessor

container

Constructor Summary

Constructors

Constructor and Description
IndirectContainerAccessor()

Method Summary

Modifier and Type	Method and Description
void	addBatch(RecordBatch batch) Add a record batch, performing schema checks and picking out a selection vector, if provided.
void	release()
int	rowCount()
SelectionVector2	selectionVector2()
SelectionVector4	selectionVector4()
void	setSelectionVector(SelectionVector2 sv2)
void	setSelectionVector(SelectionVector4 sv4)

Methods inherited from class org.apache.drill.exec.physical.impl.protocol.VectorContainerAccessor

addBatch, batchCount, container, getValueAccessorById, getValueVectorId, iterator, schema, schemaVersion, setSchema, writableBatch

Methods inherited from class java.lang.Object

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

Constructor Detail

IndirectContainerAccessor

public IndirectContainerAccessor()

Method Detail

addBatch

public void addBatch(RecordBatch batch)

Add a record batch, performing schema checks and picking out a selection vector, if provided.

Parameters:

batch - batch of records in record batch format

setSelectionVector

public void setSelectionVector(SelectionVector2 sv2)

setSelectionVector

public void setSelectionVector(SelectionVector4 sv4)

selectionVector2

public SelectionVector2 selectionVector2()

Specified by:

selectionVector2 in interface BatchAccessor

Overrides:

selectionVector2 in class VectorContainerAccessor

selectionVector4

public SelectionVector4 selectionVector4()

Specified by:

selectionVector4 in interface BatchAccessor

Overrides:

selectionVector4 in class VectorContainerAccessor

rowCount

public int rowCount()

Specified by:

rowCount in interface BatchAccessor

Overrides:

rowCount in class VectorContainerAccessor

release

public void release()

Specified by:

release in interface BatchAccessor

Overrides:

release in class VectorContainerAccessor