public static class SparkBinaryInputFormat.BinaryInputRecordReader extends org.apache.hadoop.mapred.SequenceFileRecordReader<MRContainer,MRContainer>
Modifier and Type | Field and Description |
---|---|
(package private) MRContainer |
result |
Constructor and Description |
---|
BinaryInputRecordReader(org.apache.hadoop.mapred.FileSplit split,
org.apache.hadoop.mapred.JobConf job) |
Modifier and Type | Method and Description |
---|---|
boolean |
next(MRContainer key,
MRContainer value) |
final MRContainer result
public BinaryInputRecordReader(org.apache.hadoop.mapred.FileSplit split, org.apache.hadoop.mapred.JobConf job) throws IOException
IOException
public boolean next(MRContainer key, MRContainer value) throws IOException
next
in interface org.apache.hadoop.mapred.RecordReader<MRContainer,MRContainer>
next
in class org.apache.hadoop.mapred.SequenceFileRecordReader<MRContainer,MRContainer>
IOException
Copyright © 2013-2016 The Apache Software Foundation. All Rights Reserved.