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

Class VectorContainerAccessor

java.lang.Object

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

All Implemented Interfaces:

BatchAccessor

Direct Known Subclasses:

IndirectContainerAccessor

public class VectorContainerAccessor
extends Object
implements BatchAccessor

Wraps a vector container and optional selection vector in an interface simpler than the entire RecordBatch. This implementation hosts a container only.

Separates the idea of a batch schema and data batch. The accessor can identify a schema even if it has no batches. This occurs for readers that can identify the schema, but produce no actual data.

This version is designed for the the scan operator which will produce a series of different vector containers (which, oddly, must all contain the same vectors.)

Field Summary

Fields

Modifier and Type	Field	Description
protected VectorContainer	container

Constructor Summary

Constructors

Constructor	Description
VectorContainerAccessor()

Method Summary

Modifier and Type	Method	Description
void	addBatch(VectorContainer container)	Define an output batch.
int	batchCount()
VectorContainer	container()
VectorWrapper<?>	getValueAccessorById(Class<?> clazz, int... ids)
TypedFieldId	getValueVectorId(SchemaPath path)
Iterator<VectorWrapper<?>>	iterator()
void	release()
int	rowCount()
BatchSchema	schema()
int	schemaVersion()
SelectionVector2	selectionVector2()
SelectionVector4	selectionVector4()
void	setSchema(VectorContainer container)	Define a schema that does not necessarily contain any data.
WritableBatch	writableBatch()

Methods inherited from class java.lang.Object

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

Field Details

container

protected VectorContainer container

Constructor Details

VectorContainerAccessor

public VectorContainerAccessor()

Method Details

setSchema

public void setSchema(VectorContainer container)

Define a schema that does not necessarily contain any data. Call this to declare a schema when there are no results to report.

addBatch

public void addBatch(VectorContainer container)

Define an output batch. Called each time a new batch is sent downstream. Checks if the schema of this batch is the same as that of any previous batch, and updates the schema version if the schema changes. May be called with the same container as the previous call, or a different one. A schema change occurs unless the vectors are identical across the two containers.

Parameters:

container - the container that holds vectors to be sent downstream

batchCount

public int batchCount()

schema

public BatchSchema schema()

Specified by:

schema in interface BatchAccessor

schemaVersion

public int schemaVersion()

Specified by:

schemaVersion in interface BatchAccessor

rowCount

public int rowCount()

Specified by:

rowCount in interface BatchAccessor

container

public VectorContainer container()

Specified by:

container in interface BatchAccessor

getValueVectorId

public TypedFieldId getValueVectorId(SchemaPath path)

Specified by:

getValueVectorId in interface BatchAccessor

getValueAccessorById

public VectorWrapper<?> getValueAccessorById(Class<?> clazz,
 int... ids)

Specified by:

getValueAccessorById in interface BatchAccessor

writableBatch

public WritableBatch writableBatch()

Specified by:

writableBatch in interface BatchAccessor

selectionVector2

public SelectionVector2 selectionVector2()

Specified by:

selectionVector2 in interface BatchAccessor

selectionVector4

public SelectionVector4 selectionVector4()

Specified by:

selectionVector4 in interface BatchAccessor

iterator

public Iterator<VectorWrapper<?>> iterator()

Specified by:

iterator in interface BatchAccessor

release

public void release()

Specified by:

release in interface BatchAccessor