Constructor and Description |
---|
ScanBatch(FragmentContext context,
OperatorContext oContext,
List<? extends RecordReader> readerList,
List<Map<String,String>> implicitColumnList) |
ScanBatch(PhysicalOperator subScanConfig,
FragmentContext context,
List<RecordReader> readers) |
ScanBatch(PhysicalOperator subScanConfig,
FragmentContext context,
List<RecordReader> readerList,
boolean isRepeatableScan) |
Modifier and Type | Class and Description |
---|---|
static class |
FindLimit0Visitor.RelDataTypeReader
Reader for column names and types.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractRecordReader |
class |
CommonParquetRecordReader |
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 | Field and Description |
---|---|
protected RecordReader |
DirectGroupScan.reader |
Modifier and Type | Method and Description |
---|---|
RecordReader |
DirectSubScan.getReader() |
Constructor and Description |
---|
DirectGroupScan(RecordReader reader) |
DirectGroupScan(RecordReader reader,
ScanStats stats) |
DirectSubScan(RecordReader reader) |
MetadataDirectGroupScan(RecordReader reader,
org.apache.hadoop.fs.Path selectionRoot,
int numFiles,
ScanStats stats,
boolean usedMetadataSummaryFile,
boolean usedMetastore) |
Modifier and Type | Class and Description |
---|---|
class |
DruidRecordReader |
Modifier and Type | Class and Description |
---|---|
class |
JSONRecordReader |
Modifier and Type | Method and Description |
---|---|
RecordReader |
JSONFormatPlugin.getRecordReader(FragmentContext context,
DrillFileSystem dfs,
FileWork fileWork,
List<SchemaPath> columns,
String userName) |
Modifier and Type | Class and Description |
---|---|
class |
HBaseRecordReader |
Modifier and Type | Class and Description |
---|---|
class |
HiveDefaultRecordReader
Reader which uses complex writer underneath to fill in value vectors with data read from Hive.
|
class |
HiveTextRecordReader
Reading of Hive table stored in text format may require to skip few header/footer records.
|
Modifier and Type | Method and Description |
---|---|
static List<RecordReader> |
ReadersInitializer.init(ExecutorFragmentContext ctx,
HiveSubScan config)
Selects reader constructor reference as
HiveReaderFactory readerFactory. |
Modifier and Type | Class and Description |
---|---|
class |
KuduRecordReader |
Modifier and Type | Class and Description |
---|---|
class |
LTSVRecordReader |
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 |
MaprDBJsonRecordReader |
class |
RestrictedJsonRecordReader |
Modifier and Type | Class and Description |
---|---|
class |
MockRecordReader |
Modifier and Type | Class and Description |
---|---|
class |
MongoRecordReader |
Modifier and Type | Class and Description |
---|---|
class |
OpenTSDBRecordReader |
Modifier and Type | Class and Description |
---|---|
class |
ParquetRecordReader |
Modifier and Type | Class and Description |
---|---|
class |
DrillParquetReader |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPojoRecordReader<T>
Parent class for all pojo readers.
|
class |
DynamicPojoRecordReader<T>
Dynamically reads values from the given list of records.
|
class |
PojoRecordReader<T>
Reads values from the given list of pojo instances.
|
Copyright © 1970 The Apache Software Foundation. All rights reserved.