| Package | Description |
|---|---|
| org.apache.drill.common.exceptions |
Various exceptions used in logical, physical and execution contexts.
|
| 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.framework |
Defines the projection, vector continuity and other operations for
a set of one or more readers.
|
| 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 |
Provides the "version 3" scan framework (which can also be thought of
as EVF version 2).
|
| 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.impl.scan.v3.schema |
Provides run-time semantic analysis of the projection list for the
scan operator.
|
| 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.
|
| org.apache.drill.exec.physical.resultSet.project | |
| org.apache.drill.exec.store.easy.json.loader | |
| org.apache.drill.exec.store.hdf5.writers | |
| org.apache.drill.exec.store.http.util | |
| org.apache.drill.exec.store.xml |
| Modifier and Type | Class and Description |
|---|---|
class |
ChildErrorContext
Represents an additional level of error context detail that
adds to that provided by some outer context.
|
class |
EmptyErrorContext |
| Modifier and Type | Field and Description |
|---|---|
static CustomErrorContext |
EmptyErrorContext.INSTANCE |
| Modifier and Type | Method and Description |
|---|---|
UserException.Builder |
UserException.Builder.addContext(CustomErrorContext context) |
| Constructor and Description |
|---|
ChildErrorContext(CustomErrorContext parent) |
| Modifier and Type | Class and Description |
|---|---|
static class |
FileScanFramework.FileRowSetContext |
| Modifier and Type | Method and Description |
|---|---|
CustomErrorContext |
FileScanFramework.FileReaderFactory.errorContext() |
| Constructor and Description |
|---|
FileRowSetContext(CustomErrorContext parent,
org.apache.hadoop.mapred.FileSplit split) |
| Modifier and Type | Field and Description |
|---|---|
protected CustomErrorContext |
SchemaNegotiatorImpl.context |
| Modifier and Type | Method and Description |
|---|---|
CustomErrorContext |
SchemaNegotiatorImpl.errorContext() |
CustomErrorContext |
ManagedScanFramework.errorContext() |
CustomErrorContext |
SchemaNegotiatorImpl.parentErrorContext() |
CustomErrorContext |
SchemaNegotiator.parentErrorContext()
The context to use as a parent when creating a custom context.
|
| Modifier and Type | Method and Description |
|---|---|
void |
SchemaNegotiatorImpl.setErrorContext(CustomErrorContext context) |
void |
SchemaNegotiator.setErrorContext(CustomErrorContext context)
Specify an advanced error context which allows the reader to
fill in custom context values.
|
| Modifier and Type | Field and Description |
|---|---|
CustomErrorContext |
ScanSchemaOrchestrator.ScanSchemaOptions.context
Context for error messages.
|
protected CustomErrorContext |
ScanLevelProjection.errorContext
Context used with error messages.
|
protected CustomErrorContext |
ScanLevelProjection.Builder.errorContext
Context used with error messages.
|
| Modifier and Type | Method and Description |
|---|---|
CustomErrorContext |
ScanLevelProjection.context() |
CustomErrorContext |
ScanSchemaOrchestrator.ScanOrchestratorBuilder.errorContext() |
| Modifier and Type | Method and Description |
|---|---|
void |
ScanSchemaOrchestrator.ScanOrchestratorBuilder.errorContext(CustomErrorContext context) |
ScanLevelProjection.Builder |
ScanLevelProjection.Builder.errorContext(CustomErrorContext context) |
ResultSetLoader |
ReaderSchemaOrchestrator.makeTableLoader(CustomErrorContext errorContext,
TupleMetadata readerSchema) |
| Modifier and Type | Field and Description |
|---|---|
protected CustomErrorContext |
ScanLifecycleBuilder.errorContext
Context for error messages.
|
| Modifier and Type | Method and Description |
|---|---|
CustomErrorContext |
ScanLifecycleBuilder.errorContext() |
CustomErrorContext |
SchemaNegotiator.errorContext()
Returns the error context to use for this reader: either the
parent or the reader-specific context set in
SchemaNegotiator.setErrorContext(CustomErrorContext). |
CustomErrorContext |
SchemaNegotiator.parentErrorContext()
The context to use as a parent when creating a custom context.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ScanLifecycleBuilder.errorContext(CustomErrorContext context) |
void |
SchemaNegotiator.setErrorContext(CustomErrorContext context)
Specify an advanced error context which allows the reader to
fill in custom context values.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FileSchemaNegotiatorImpl.SplitErrorContext |
| Constructor and Description |
|---|
ImplicitColumnResolver(ImplicitColumnResolver.ImplicitColumnOptions options,
CustomErrorContext errorContext) |
SplitErrorContext(CustomErrorContext parent) |
| Modifier and Type | Field and Description |
|---|---|
protected CustomErrorContext |
SchemaNegotiatorImpl.baseErrorContext |
CustomErrorContext |
BaseTestScanLifecycle.FailingReader.ec |
protected CustomErrorContext |
SchemaNegotiatorImpl.readerErrorContext |
| Modifier and Type | Method and Description |
|---|---|
CustomErrorContext |
SchemaNegotiatorImpl.errorContext() |
CustomErrorContext |
ReaderLifecycle.errorContext() |
CustomErrorContext |
ScanLifecycle.errorContext() |
CustomErrorContext |
SchemaNegotiatorImpl.parentErrorContext() |
| Modifier and Type | Method and Description |
|---|---|
void |
SchemaNegotiatorImpl.setErrorContext(CustomErrorContext errorContext) |
| Modifier and Type | Field and Description |
|---|---|
protected static CustomErrorContext |
TestSchemaTrackerEarlyReaderSchema.ERROR_CONTEXT |
protected static CustomErrorContext |
BaseTestSchemaTracker.ERROR_CONTEXT |
protected CustomErrorContext |
AbstractSchemaTracker.errorContext |
protected CustomErrorContext |
DynamicSchemaFilter.errorContext |
| Modifier and Type | Method and Description |
|---|---|
CustomErrorContext |
AbstractSchemaTracker.errorContext() |
CustomErrorContext |
ScanSchemaTracker.errorContext()
The scan-level error context used for errors which may occur before the
first reader starts.
|
| Modifier and Type | Method and Description |
|---|---|
void |
SchemaBasedTracker.applyReaderSchema(TupleMetadata readerOutputSchema,
CustomErrorContext errorContext) |
void |
ProjectionSchemaTracker.applyReaderSchema(TupleMetadata readerOutputSchema,
CustomErrorContext errorContext) |
void |
ScanSchemaTracker.applyReaderSchema(TupleMetadata readerOutputSchema,
CustomErrorContext errorContext)
Once a reader has read a batch, the reader will have provided a type
for each projected column which the reader knows about.
|
ScanSchemaConfigBuilder |
ScanSchemaConfigBuilder.errorContext(CustomErrorContext errorContext) |
static ProjectionFilter |
DynamicSchemaFilter.DynamicTupleFilter.filterFor(DynamicColumn col,
boolean allowMapAdditions,
CustomErrorContext errorContext,
String source) |
ProjectionFilter |
SchemaBasedTracker.projectionFilter(CustomErrorContext errorContext)
Set up a projection filter using the defined schema
|
ProjectionFilter |
ProjectionSchemaTracker.projectionFilter(CustomErrorContext errorContext)
Set up a projection filter using the reader input schema returned
from
AbstractSchemaTracker.readerInputSchema(). |
ProjectionFilter |
ScanSchemaTracker.projectionFilter(CustomErrorContext errorContext)
A reader is responsible for reading columns in the reader input schema.
|
static void |
SchemaUtils.verifyCompatibility(ProjectedColumn colReq,
ColumnMetadata actual,
String source,
CustomErrorContext errorContext)
Perform the column-level projection as described in
#isConsistent(RequestedColumn, ColumnMetadata), and raise a
UserException if the column is not consistent with projection. |
static void |
SchemaUtils.verifyConsistency(ColumnMetadata existing,
ColumnMetadata revised,
String source,
CustomErrorContext errorContext) |
static void |
SchemaUtils.verifyProjection(ColumnMetadata existing,
ColumnMetadata revised,
String source,
CustomErrorContext errorContext) |
| Modifier and Type | Method and Description |
|---|---|
CustomErrorContext |
ResultSetLoader.errorContext()
Context for error messages.
|
| Modifier and Type | Field and Description |
|---|---|
protected CustomErrorContext |
ProjectionFilter.BaseSchemaProjectionFilter.errorContext |
protected CustomErrorContext |
ResultSetOptionBuilder.errorContext
Error message context
|
protected CustomErrorContext |
ResultSetLoaderImpl.ResultSetOptions.errorContext
Context for error messages.
|
| Modifier and Type | Method and Description |
|---|---|
CustomErrorContext |
ResultSetLoaderImpl.errorContext() |
| Modifier and Type | Method and Description |
|---|---|
static ProjectionFilter |
ProjectionFilter.definedSchemaFilter(TupleMetadata definedSchema,
CustomErrorContext errorContext) |
ResultSetOptionBuilder |
ResultSetOptionBuilder.errorContext(CustomErrorContext context)
Provides context for error messages.
|
static ProjectionFilter |
ProjectionFilter.projectionFilter(RequestedTuple tupleProj,
CustomErrorContext errorContext) |
static ProjectionFilter |
ProjectionFilter.providedSchemaFilter(RequestedTuple tupleProj,
TupleMetadata providedSchema,
CustomErrorContext errorContext) |
| Constructor and Description |
|---|
DirectProjectionFilter(RequestedTuple projectionSet,
CustomErrorContext errorContext) |
SchemaProjectionFilter(TupleMetadata definedSchema,
CustomErrorContext errorContext) |
TypeProjectionFilter(TupleMetadata providedSchema,
CustomErrorContext errorContext) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
RequestedTupleImpl.enforceProjection(ColumnMetadata columnSchema,
CustomErrorContext errorContext) |
boolean |
ImpliedTupleRequest.enforceProjection(ColumnMetadata columnSchema,
CustomErrorContext errorContext) |
boolean |
RequestedTuple.enforceProjection(ColumnMetadata columnSchema,
CustomErrorContext errorContext) |
static void |
ProjectionChecker.validateProjection(RequestedColumn colReq,
ColumnMetadata readCol,
CustomErrorContext errorContext)
Perform the column-level projection as described in
ProjectionChecker.isConsistent(RequestedColumn, ColumnMetadata), and raise a
UserException if the column is not consistent with projection. |
| Modifier and Type | Field and Description |
|---|---|
CustomErrorContext |
BaseJsonLoaderTest.JsonLoaderFixture.errorContext |
| Modifier and Type | Method and Description |
|---|---|
JsonLoaderImpl.JsonLoaderBuilder |
JsonLoaderImpl.JsonLoaderBuilder.errorContext(CustomErrorContext errorContext) |
| Modifier and Type | Field and Description |
|---|---|
CustomErrorContext |
WriterSpec.errorContext |
| Constructor and Description |
|---|
WriterSpec(TupleWriter tupleWriter,
TupleMetadata providedSchema,
CustomErrorContext errorContext) |
| Constructor and Description |
|---|
SimpleHttp(HttpSubScan scanDefn,
okhttp3.HttpUrl url,
File tempDir,
HttpProxyConfig proxyConfig,
CustomErrorContext errorContext) |
| Modifier and Type | Method and Description |
|---|---|
void |
XMLReader.open(RowSetLoader rootRowWriter,
CustomErrorContext errorContext) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.