public class LlapArrowBatchRecordReader extends LlapBaseRecordReader<ArrowWrapperWritable>
LlapBaseRecordReader.ReaderEvent
cin, clazz, client, din, readerEvents, readerThread, schema
Constructor and Description |
---|
LlapArrowBatchRecordReader(InputStream in,
Schema schema,
Class<ArrowWrapperWritable> clazz,
org.apache.hadoop.mapred.JobConf job,
Closeable client,
Socket socket,
long arrowAllocatorLimit) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
next(org.apache.hadoop.io.NullWritable key,
ArrowWrapperWritable value) |
createKey, createValue, failOnInterruption, getPos, getProgress, getReaderEvent, getReaderThread, getSchema, handleEvent, hasInput, processReaderEvent, setReaderThread
public LlapArrowBatchRecordReader(InputStream in, Schema schema, Class<ArrowWrapperWritable> clazz, org.apache.hadoop.mapred.JobConf job, Closeable client, Socket socket, long arrowAllocatorLimit) throws IOException
IOException
public boolean next(org.apache.hadoop.io.NullWritable key, ArrowWrapperWritable value) throws IOException
next
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,ArrowWrapperWritable>
next
in class LlapBaseRecordReader<ArrowWrapperWritable>
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,ArrowWrapperWritable>
close
in class LlapBaseRecordReader<ArrowWrapperWritable>
IOException
Copyright © 2022 The Apache Software Foundation. All rights reserved.