| Package | Description |
|---|---|
| org.apache.drill.exec.physical.impl | |
| org.apache.drill.exec.planner.sql.handlers | |
| org.apache.drill.exec.store | |
| org.apache.drill.exec.store.dfs.easy | |
| org.apache.drill.exec.store.direct | |
| org.apache.drill.exec.store.druid | |
| org.apache.drill.exec.store.easy.json | |
| org.apache.drill.exec.store.hbase | |
| org.apache.drill.exec.store.hive.readers | |
| org.apache.drill.exec.store.kudu | |
| org.apache.drill.exec.store.ltsv | |
| org.apache.drill.exec.store.mapr.db.json | |
| org.apache.drill.exec.store.mock |
Defines a mock data source which generates dummy test data for use
in testing.
|
| org.apache.drill.exec.store.mongo |
MongoDB storage plugin.
|
| org.apache.drill.exec.store.openTSDB | |
| org.apache.drill.exec.store.parquet.columnreaders | |
| org.apache.drill.exec.store.parquet2 | |
| org.apache.drill.exec.store.pojo | |
| org.apache.drill.test |
Provides a variety of test framework tools to simplify Drill unit
tests and ad-hoc tests created while developing features.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
static Iterator<RecordReader> |
PhysicalOpUnitTestBase.getJsonReadersFromBatchString(List<String> jsonBatches,
FragmentContext fragContext,
List<SchemaPath> columnsToRead)
Create
JSONRecordReader from input strings. |
static Iterator<RecordReader> |
PhysicalOpUnitTestBase.getJsonReadersFromInputFiles(DrillFileSystem fs,
List<org.apache.hadoop.fs.Path> inputPaths,
FragmentContext fragContext,
List<SchemaPath> columnsToRead)
Create JSONRecordReader from files on a file system.
|
List<RecordReader> |
PhysicalOpUnitTestBase.getReaderListForJsonBatches(List<String> jsonBatches,
FragmentContext fragContext) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.