| Package | Description |
|---|---|
| org.apache.drill.exec.physical.impl.scan |
Defines the scan operation implementation.
|
| 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.resultSet |
Provides a second-generation row set (AKA "record batch") writer used
by client code to
Define the schema of a result set.
Write data into the vectors backing a row set.
|
| org.apache.drill.exec.physical.resultSet.impl |
Handles the details of the result set loader implementation.
|
| org.apache.drill.exec.store.avro | |
| org.apache.drill.exec.store.easy.text.reader |
Version 3 of the text reader.
|
| org.apache.drill.exec.store.httpd | |
| org.apache.drill.exec.store.image | |
| org.apache.drill.exec.store.splunk | |
| org.apache.drill.exec.store.xml |
| Modifier and Type | Method and Description |
|---|---|
protected void |
BaseScanOperatorExecTest.BaseMockBatchReader.writeRow(RowSetLoader writer,
int col1,
String col2) |
| Modifier and Type | Method and Description |
|---|---|
RowSetLoader |
FixedReceiver.rowWriter() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
BaseMockBatchReader.writeRow(RowSetLoader writer,
int col1,
String col2) |
| Modifier and Type | Method and Description |
|---|---|
RowSetLoader |
RowSetLoader.addRow(Object... values)
Write a row of values, given by Java objects.
|
RowSetLoader |
RowSetLoader.addSingleCol(Object value)
Similar to
addRow(Object...), but for the odd case in which a
row consists of a single column that is an object array (such as for
a list or map) and so is ambiguous. |
RowSetLoader |
ResultSetLoader.writer()
Writer for the top-level tuple (the entire row).
|
| Modifier and Type | Class and Description |
|---|---|
class |
RowSetLoaderImpl
Implementation of the row set loader.
|
| Modifier and Type | Method and Description |
|---|---|
RowSetLoader |
RowSetLoaderImpl.addRow(Object... values) |
RowSetLoader |
RowSetLoaderImpl.addSingleCol(Object value) |
RowSetLoader |
ResultSetLoaderImpl.writer() |
| Modifier and Type | Method and Description |
|---|---|
List<ColumnConverter> |
AvroColumnConverterFactory.initConverters(TupleMetadata providedSchema,
TupleMetadata readerSchema,
RowSetLoader rowWriter)
Based on given converted Avro schema and current row writer generates list of
column converters based on column type.
|
| Modifier and Type | Field and Description |
|---|---|
protected RowSetLoader |
BaseFieldOutput.writer |
| Constructor and Description |
|---|
BaseFieldOutput(RowSetLoader writer,
int maxField,
boolean[] projectionMask)
Initialize the field output for one of three scenarios:
SELECT all: SELECT *, SELECT columns.
|
RepeatedVarCharOutput(RowSetLoader loader,
boolean[] projectionMask)
Provide the row set loader (which must have just one repeated Varchar
column) and an optional array projection mask.
|
| Modifier and Type | Method and Description |
|---|---|
void |
HttpdLogRecord.addField(nl.basjes.parse.core.Parser<HttpdLogRecord> parser,
RowSetLoader rowWriter,
Map<String,nl.basjes.parse.core.Casts> columnCasts,
String parserFieldName,
String drillFieldName,
Map<String,TypeProtos.MinorType> mappedColumns)
This record will be used with a single parser.
|
void |
HttpdParser.addFieldsToParser(RowSetLoader rowWriter) |
| Modifier and Type | Method and Description |
|---|---|
void |
ImageBatchReader.ColumnDefn.bind(RowSetLoader loader) |
void |
ImageBatchReader.MapColumnDefn.bind(RowSetLoader loader) |
ImageBatchReader.MapColumnDefn |
ImageBatchReader.MapColumnDefn.builder(RowSetLoader loader) |
| Constructor and Description |
|---|
SplunkColumnWriter(String colName,
RowSetLoader rowWriter,
int columnIndex) |
| Modifier and Type | Method and Description |
|---|---|
void |
XMLReader.open(RowSetLoader rootRowWriter,
CustomErrorContext errorContext) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.