public static class BSPBinaryInputFormat.BinaryInputRecordReader extends org.apache.hama.bsp.SequenceFileRecordReader<MRContainer,MRContainer>
Modifier and Type | Field and Description |
---|---|
(package private) MRContainer |
result |
(package private) MRData |
source_num_data |
(package private) int |
source_number |
Constructor and Description |
---|
BSPBinaryInputFormat.BinaryInputRecordReader(org.apache.hama.bsp.FileSplit split,
org.apache.hama.bsp.BSPJob job,
int source_number) |
Modifier and Type | Method and Description |
---|---|
boolean |
next(MRContainer key,
MRContainer value) |
final MRContainer result
final MRData source_num_data
final int source_number
public BSPBinaryInputFormat.BinaryInputRecordReader(org.apache.hama.bsp.FileSplit split, org.apache.hama.bsp.BSPJob job, int source_number) throws IOException
IOException
public boolean next(MRContainer key, MRContainer value) throws IOException
next
in interface org.apache.hama.bsp.RecordReader<MRContainer,MRContainer>
next
in class org.apache.hama.bsp.SequenceFileRecordReader<MRContainer,MRContainer>
IOException
Copyright © 2013 The Apache Software Foundation. All rights reserved.