T
- type of the materialized recordspublic class ParquetRecordReader<T> extends org.apache.hadoop.mapreduce.RecordReader<Void,T>
ParquetInputFormat
Constructor and Description |
---|
ParquetRecordReader(ReadSupport<T> readSupport) |
ParquetRecordReader(ReadSupport<T> readSupport,
UnboundRecordFilter filter) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Void |
getCurrentKey()
always returns null
|
T |
getCurrentValue() |
float |
getProgress() |
void |
initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit,
org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.mapred.Reporter reporter) |
void |
initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
boolean |
nextKeyValue() |
public ParquetRecordReader(ReadSupport<T> readSupport)
readSupport
- Object which helps reads files of the given type, e.g. Thrift, Avro.public ParquetRecordReader(ReadSupport<T> readSupport, UnboundRecordFilter filter)
readSupport
- Object which helps reads files of the given type, e.g. Thrift, Avro.filter
- Optional filter for only returning matching records.public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class org.apache.hadoop.mapreduce.RecordReader<Void,T>
IOException
public Void getCurrentKey() throws IOException, InterruptedException
getCurrentKey
in class org.apache.hadoop.mapreduce.RecordReader<Void,T>
IOException
InterruptedException
public T getCurrentValue() throws IOException, InterruptedException
getCurrentValue
in class org.apache.hadoop.mapreduce.RecordReader<Void,T>
IOException
InterruptedException
public float getProgress() throws IOException, InterruptedException
getProgress
in class org.apache.hadoop.mapreduce.RecordReader<Void,T>
IOException
InterruptedException
public void initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
initialize
in class org.apache.hadoop.mapreduce.RecordReader<Void,T>
IOException
InterruptedException
public void initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.mapred.Reporter reporter) throws IOException, InterruptedException
IOException
InterruptedException
public boolean nextKeyValue() throws IOException, InterruptedException
nextKeyValue
in class org.apache.hadoop.mapreduce.RecordReader<Void,T>
IOException
InterruptedException
Copyright © 2015. All rights reserved.