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.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 | Method and Description |
---|---|
void |
FileScanFramework.FileScanBuilder.setFiles(List<? extends FileWork> files) |
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 |
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 © 1970 The Apache Software Foundation. All rights reserved.