| Package | Description |
|---|---|
| org.apache.drill.exec.physical.impl.scan.file |
Handles optional file metadata columns: implicit columns and
partition columns.
|
| org.apache.drill.exec.physical.impl.scan.project |
Provides run-time semantic analysis of the projection list for the
scan operator.
|
| org.apache.drill.exec.physical.impl.scan.v3.file | |
| org.apache.drill.exec.physical.impl.scan.v3.lifecycle |
Implements the details of the scan lifecycle for a set of readers,
primarily the process of resolving the scan output schema from a variety
of input schemas, then running each reader, each of which will produce
some number of batches.
|
| org.apache.drill.exec.physical.resultSet |
Provides a second-generation row set (AKA "record batch") writer used
by client code to
Define the schema of a result set.
Write data into the vectors backing a row set.
|
| org.apache.drill.exec.physical.resultSet.impl |
Handles the details of the result set loader implementation.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ImplicitColumnManager.bind(ResultVectorCache vectorCache) |
| Modifier and Type | Field and Description |
|---|---|
protected ResultVectorCache |
StaticColumnLoader.vectorCache |
| Modifier and Type | Method and Description |
|---|---|
void |
MetadataManager.bind(ResultVectorCache vectorCache) |
void |
NoOpMetadataManager.bind(ResultVectorCache vectorCache) |
void |
NullColumnBuilder.build(ResultVectorCache vectorCache) |
void |
ResolvedTuple.buildNulls(ResultVectorCache vectorCache) |
| Constructor and Description |
|---|
ConstantColumnLoader(ResultVectorCache vectorCache,
List<? extends ConstantColumnLoader.ConstantColumnSpec> defns) |
NullColumnLoader(ResultVectorCache vectorCache,
List<? extends NullColumnLoader.NullColumnSpec> defns,
TypeProtos.MajorType nullType,
boolean allowRequired) |
StaticColumnLoader(ResultVectorCache vectorCache) |
| Constructor and Description |
|---|
ImplicitFileColumnsHandler(DrillFileSystem dfs,
OptionSet options,
FileScanLifecycleBuilder scanOptions,
ResultVectorCache vectorCache,
ScanSchemaTracker schemaTracker) |
| Modifier and Type | Field and Description |
|---|---|
protected ResultVectorCache |
MissingColumnHandlerBuilder.vectorCache |
| Modifier and Type | Method and Description |
|---|---|
MissingColumnHandlerBuilder |
MissingColumnHandlerBuilder.vectorCache(ResultVectorCache vectorCache) |
| Constructor and Description |
|---|
NullBatchBuilder(ResultVectorCache vectorCache,
TupleMetadata schema) |
RepeatedBatchBuilder(ResultVectorCache vectorCache,
TupleMetadata schema,
Object[] values) |
StaticBatchBuilder(ResultVectorCache vectorCache,
TupleMetadata schema) |
| Modifier and Type | Method and Description |
|---|---|
ResultVectorCache |
ResultVectorCache.childCache(String colName) |
ResultVectorCache |
ResultSetLoader.vectorCache()
Peek at the internal vector cache for readers that need a bit of help
resolving types based on what was previously seen.
|
| Modifier and Type | Class and Description |
|---|---|
class |
NullResultVectorCacheImpl
A vector cache implementation which does not actually cache.
|
class |
ResultVectorCacheImpl
Manages an inventory of value vectors used across row batch readers.
|
| Modifier and Type | Field and Description |
|---|---|
protected ResultVectorCache |
ContainerState.vectorCache
Vector cache for this loader.
|
protected ResultVectorCache |
ResultSetOptionBuilder.vectorCache |
protected ResultVectorCache |
ResultSetLoaderImpl.ResultSetOptions.vectorCache |
| Modifier and Type | Method and Description |
|---|---|
ResultVectorCache |
ResultVectorCacheImpl.childCache(String colName) |
ResultVectorCache |
NullResultVectorCacheImpl.childCache(String colName) |
ResultVectorCache |
ContainerState.vectorCache() |
ResultVectorCache |
ResultSetLoaderImpl.vectorCache() |
| Modifier and Type | Method and Description |
|---|---|
ResultSetOptionBuilder |
ResultSetOptionBuilder.vectorCache(ResultVectorCache vectorCache)
Downstream operators require "vector persistence": the same vector
must represent the same column in every batch.
|
| Constructor and Description |
|---|
ContainerState(org.apache.drill.exec.physical.resultSet.impl.LoaderInternals loader,
ResultVectorCache vectorCache) |
ContainerState(org.apache.drill.exec.physical.resultSet.impl.LoaderInternals loader,
ResultVectorCache vectorCache,
ProjectionFilter projectionSet) |
DictArrayState(org.apache.drill.exec.physical.resultSet.impl.LoaderInternals events,
ResultVectorCache vectorCache,
ProjectionFilter projectionSet) |
DictState(org.apache.drill.exec.physical.resultSet.impl.LoaderInternals events,
ResultVectorCache vectorCache,
ProjectionFilter projectionSet) |
ListState(org.apache.drill.exec.physical.resultSet.impl.LoaderInternals loader,
ResultVectorCache vectorCache) |
MapArrayState(org.apache.drill.exec.physical.resultSet.impl.LoaderInternals events,
ResultVectorCache vectorCache,
ProjectionFilter projectionSet) |
MapState(org.apache.drill.exec.physical.resultSet.impl.LoaderInternals events,
ResultVectorCache vectorCache,
ProjectionFilter projectionSet) |
RepeatedListState(org.apache.drill.exec.physical.resultSet.impl.LoaderInternals loader,
ResultVectorCache vectorCache) |
RowState(ResultSetLoaderImpl rsLoader,
ResultVectorCache vectorCache) |
SingleDictState(org.apache.drill.exec.physical.resultSet.impl.LoaderInternals events,
ResultVectorCache vectorCache,
ProjectionFilter projectionSet) |
SingleMapState(org.apache.drill.exec.physical.resultSet.impl.LoaderInternals events,
ResultVectorCache vectorCache,
ProjectionFilter projectionSet) |
TupleState(org.apache.drill.exec.physical.resultSet.impl.LoaderInternals events,
ResultVectorCache vectorCache,
ProjectionFilter projectionSet) |
UnionState(org.apache.drill.exec.physical.resultSet.impl.LoaderInternals events,
ResultVectorCache vectorCache) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.