| Package | Description |
|---|---|
| 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.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BaseMockBatchReader
Base class for the "mock" readers used in this test.
|
protected static class |
BaseScanTest.EofOnOpenReader
Mock reader that returns no schema and no records.
|
protected static class |
BaseScanTest.MockEarlySchemaReader
Mock reader that pretends to have a schema at open time
like an HBase or JDBC reader.
|
| Modifier and Type | Field and Description |
|---|---|
ManagedReader |
BaseScanTest.ObservableCreator.reader |
| Modifier and Type | Method and Description |
|---|---|
<T extends ManagedReader> |
BaseScanTest.ObservableCreator.reader() |
| Modifier and Type | Method and Description |
|---|---|
abstract ManagedReader |
BaseScanTest.ObservableCreator.create(SchemaNegotiator negotiator) |
ManagedReader |
BaseScanTest.ReaderCreator.instance(SchemaNegotiator negotiator) |
ManagedReader |
BaseScanTest.ObservableCreator.instance(SchemaNegotiator negotiator) |
ManagedReader |
BaseScanTest.ReaderFactoryFixture.next(SchemaNegotiator negotiator) |
ManagedReader |
ScanLifecycleBuilder.DummyReaderFactory.next(SchemaNegotiator negotiator) |
ManagedReader |
ReaderFactory.next(T negotiator) |
| Modifier and Type | Method and Description |
|---|---|
ManagedReader |
BaseFileScanTest.ReaderCreator.instance(FileSchemaNegotiator negotiator) |
ManagedReader |
BaseFileScanTest.ReaderFactoryFixture.newReader(FileSchemaNegotiator negotiator) |
abstract ManagedReader |
FileReaderFactory.newReader(FileSchemaNegotiator negotiator) |
ManagedReader |
FileSchemaNegotiatorImpl.newReader(ReaderFactory<?> readerFactory) |
ManagedReader |
FileReaderFactory.next(FileSchemaNegotiator negotiator) |
| Modifier and Type | Class and Description |
|---|---|
protected static class |
BaseTestScanLifecycle.BaseMockBatchReader
Base class for the "mock" readers used in this test.
|
protected static class |
BaseTestScanLifecycle.FailingReader |
protected static class |
BaseTestScanLifecycle.MockEarlySchemaReader
"Early schema" refers to the case in which the reader can provide a schema
when the reader is opened.
|
protected static class |
BaseTestScanLifecycle.MockEarlySchemaTypeConflictReader |
protected static class |
BaseTestScanLifecycle.MockEmptySchemaReader |
protected static class |
BaseTestScanLifecycle.MockLateSchemaReader |
protected static class |
BaseTestScanLifecycle.MockLateSchemaTypeConflictReader |
protected static class |
BaseTestScanLifecycle.MockModeConflictReader |
protected static class |
BaseTestScanLifecycle.MockReorderedReader |
protected static class |
BaseTestScanLifecycle.MockSingleColReader |
protected static class |
BaseTestScanLifecycle.MockThreeColReader |
protected static class |
BaseTestScanLifecycle.NoDataReader
Mock reader with no data or schema, indicated by an early EOF
exception.
|
| Modifier and Type | Method and Description |
|---|---|
abstract ManagedReader |
BaseTestScanLifecycle.TwoReaderFactory.firstReader(SchemaNegotiator negotiator) |
ManagedReader |
SchemaNegotiatorImpl.newReader(ReaderFactory<?> readerFactory) |
ManagedReader |
BaseTestScanLifecycle.TwoReaderFactory.next(SchemaNegotiator negotiator) |
abstract ManagedReader |
BaseTestScanLifecycle.TwoReaderFactory.secondReader(SchemaNegotiator negotiator) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.