public class KuduRecordReader extends AbstractRecordReader
DEFAULT_TEXT_COLS_TO_READ
ALLOCATOR_INITIAL_RESERVATION, ALLOCATOR_MAX_RESERVATION
Constructor and Description |
---|
KuduRecordReader(org.apache.kudu.client.KuduClient client,
KuduSubScan.KuduSubScanSpec 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.
|
String |
toString() |
allocate, getColumns, getDefaultColumnsToRead, hasNext, isSkipQuery, isStarQuery, setColumns, transformColumns
public KuduRecordReader(org.apache.kudu.client.KuduClient client, KuduSubScan.KuduSubScanSpec subScanSpec, List<SchemaPath> projectedColumns)
public void setup(OperatorContext context, OutputMutator output) throws ExecutionSetupException
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.ExecutionSetupException
public int next()
RecordReader
public void close()
public String toString()
toString
in class AbstractRecordReader
Copyright © 1970 The Apache Software Foundation. All rights reserved.