Package | Description |
---|---|
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.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.
|
org.apache.drill.exec.store.easy.json.loader | |
org.apache.drill.exec.store.kafka.decoders | |
org.apache.drill.exec.store.phoenix |
Modifier and Type | Field and Description |
---|---|
protected ResultSetLoader |
ShimBatchReader.tableLoader |
Modifier and Type | Method and Description |
---|---|
ResultSetLoader |
SchemaNegotiator.build()
Build the schema, plan the required projections and static
columns and return a loader used to populate value vectors.
|
ResultSetLoader |
SchemaNegotiatorImpl.build()
Callback from the schema negotiator to build the schema from information from
both the table and scan operator.
|
ResultSetLoader |
SchemaNegotiatorImpl.NegotiatorListener.build(SchemaNegotiatorImpl schemaNegotiator) |
ResultSetLoader |
ShimBatchReader.build(SchemaNegotiatorImpl schemaNegotiator) |
Modifier and Type | Field and Description |
---|---|
protected ResultSetLoader |
StaticColumnLoader.loader |
Modifier and Type | Method and Description |
---|---|
ResultSetLoader |
ReaderSchemaOrchestrator.makeTableLoader(CustomErrorContext errorContext,
TupleMetadata readerSchema,
long localLimit) |
ResultSetLoader |
ReaderSchemaOrchestrator.makeTableLoader(TupleMetadata readerSchema) |
Modifier and Type | Method and Description |
---|---|
ResultSetLoader |
SchemaNegotiator.build()
Build the schema, plan the required projections and static
columns and return a loader used to populate value vectors.
|
Modifier and Type | Field and Description |
---|---|
protected ResultSetLoader |
StaticBatchBuilder.loader |
protected ResultSetLoader |
ReaderLifecycle.tableLoader |
Modifier and Type | Method and Description |
---|---|
ResultSetLoader |
SchemaNegotiatorImpl.build()
Callback from the schema negotiator to build the schema from information from
both the table and scan operator.
|
ResultSetLoader |
ReaderLifecycle.buildLoader() |
ResultSetLoader |
ReaderLifecycle.tableLoader() |
Modifier and Type | Method and Description |
---|---|
ResultSetLoader |
RowSetLoader.loader() |
ResultSetLoader |
ResultSetLoader.setRow(Object... values)
Load a row using column values passed as variable-length arguments.
|
Modifier and Type | Class and Description |
---|---|
class |
ResultSetLoaderImpl
Implementation of the result set loader.
|
Modifier and Type | Method and Description |
---|---|
ResultSetLoader |
RowSetLoaderImpl.loader() |
ResultSetLoader |
ResultSetLoaderImpl.setRow(Object... values) |
Modifier and Type | Method and Description |
---|---|
JsonLoaderImpl.JsonLoaderBuilder |
JsonLoaderImpl.JsonLoaderBuilder.resultSetLoader(ResultSetLoader rsLoader) |
Modifier and Type | Method and Description |
---|---|
ResultSetLoader |
MessageReader.getResultSetLoader() |
ResultSetLoader |
AvroMessageReader.getResultSetLoader() |
ResultSetLoader |
JsonMessageReader.getResultSetLoader() |
Constructor and Description |
---|
PhoenixReader(ResultSetLoader loader,
PhoenixReader.ColumnDefn[] columns,
ResultSet results) |
Copyright © 1970 The Apache Software Foundation. All rights reserved.