| Package | Description |
|---|---|
| org.apache.drill.exec.physical.impl.scan |
Defines the scan operation implementation.
|
| 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.v3.file | |
| org.apache.drill.exec.store.dfs | |
| org.apache.drill.exec.store.dfs.easy | |
| org.apache.drill.exec.store.easy.json | |
| org.apache.drill.exec.store.ltsv | |
| org.apache.drill.exec.store.parquet | |
| org.apache.drill.exec.store.schedule |
| Modifier and Type | Class and Description |
|---|---|
static class |
TestFileScanFramework.DummyFileWork
For schema-based testing, we only need the file path from the file work.
|
| Modifier and Type | Method and Description |
|---|---|
void |
FileScanFramework.FileScanBuilder.setFiles(List<? extends FileWork> files) |
| Modifier and Type | Class and Description |
|---|---|
static class |
BaseFileScanTest.DummyFileWork
For schema-based testing, we only need the file path from the file work.
|
| Modifier and Type | Field and Description |
|---|---|
List<FileWork> |
BaseFileScanTest.FileScanFixtureBuilder.blocks |
| Modifier and Type | Method and Description |
|---|---|
FileWork |
FileDescrip.fileWork() |
| Modifier and Type | Method and Description |
|---|---|
List<FileWork> |
FileScanLifecycleBuilder.splits() |
| Modifier and Type | Method and Description |
|---|---|
void |
BaseFileScanTest.FileScanFixtureBuilder.addReader(BaseFileScanTest.ReaderCreator reader,
FileWork block) |
void |
FileSchemaNegotiatorImpl.bindSplit(FileWork fileWork) |
FileDescrip |
ImplicitFileColumnsHandler.makeDescrip(FileWork fileWork) |
| Modifier and Type | Method and Description |
|---|---|
void |
FileScanLifecycleBuilder.fileSplits(List<FileWork> splits) |
| Constructor and Description |
|---|
FileDescrip(DrillFileSystem dfs,
FileWork fileWork,
org.apache.hadoop.fs.Path selectionRoot) |
| Modifier and Type | Class and Description |
|---|---|
class |
ReadEntryFromHDFS |
| Modifier and Type | Method and Description |
|---|---|
RecordReader |
EasyFormatPlugin.getRecordReader(FragmentContext context,
DrillFileSystem dfs,
FileWork fileWork,
List<SchemaPath> columns,
String userName)
Return a record reader for the specific file format, when using the original
ScanBatch scanner. |
| Modifier and Type | Method and Description |
|---|---|
RecordReader |
JSONFormatPlugin.getRecordReader(FragmentContext context,
DrillFileSystem dfs,
FileWork fileWork,
List<SchemaPath> columns,
String userName) |
| Modifier and Type | Method and Description |
|---|---|
RecordReader |
LTSVFormatPlugin.getRecordReader(FragmentContext context,
DrillFileSystem dfs,
FileWork fileWork,
List<SchemaPath> columns,
String userName) |
| Modifier and Type | Class and Description |
|---|---|
class |
RowGroupInfo |
class |
RowGroupReadEntry |
| Modifier and Type | Class and Description |
|---|---|
class |
CompleteFileWork |
static class |
CompleteFileWork.FileWorkImpl |
| Modifier and Type | Method and Description |
|---|---|
EndpointByteMap |
BlockMapBuilder.getEndpointByteMap(Set<String> noDrillbitHosts,
FileWork work)
For a given FileWork, calculate how many bytes are available on each on drillbit endpoint
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.