public class OpenTSDBRecordReader extends AbstractRecordReader
DEFAULT_TEXT_COLS_TO_READ
ALLOCATOR_INITIAL_RESERVATION, ALLOCATOR_MAX_RESERVATION
Constructor and Description |
---|
OpenTSDBRecordReader(Service client,
OpenTSDBSubScan.OpenTSDBSubScanSpec subScanSpec,
List<SchemaPath> projectedColumns) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
int |
next()
Increments this record reader forward, writing via the provided output
mutator into the output batch.
|
void |
setup(OperatorContext context,
OutputMutator output)
Configure the RecordReader with the provided schema and the record batch that should be written to.
|
allocate, getColumns, getDefaultColumnsToRead, hasNext, isSkipQuery, isStarQuery, setColumns, toString, transformColumns
public OpenTSDBRecordReader(Service client, OpenTSDBSubScan.OpenTSDBSubScanSpec subScanSpec, List<SchemaPath> projectedColumns)
public void setup(OperatorContext context, OutputMutator output)
RecordReader
context
- operator context for the readeroutput
- The place where output for a particular scan should be written. The record reader is responsible for
mutating the set of schema values for that particular record.public int next()
RecordReader
public void close()
Copyright © 1970 The Apache Software Foundation. All rights reserved.