public class IntIntTextVertexValueInputFormat.IntIntTextVertexValueReader extends TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed<IntPair>
VertexValueReader
associated with
IntIntTextVertexValueInputFormat
.Constructor and Description |
---|
IntIntTextVertexValueReader() |
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.io.IntWritable |
getId(IntPair data)
Reads vertex id from the preprocessed line.
|
protected org.apache.hadoop.io.IntWritable |
getValue(IntPair data)
Reads vertex value from the preprocessed line.
|
protected IntPair |
preprocessLine(org.apache.hadoop.io.Text line)
Preprocess the line so other methods can easily read necessary
information for creating vertex.
|
getCurrentVertexId, getCurrentVertexValue, nextVertex
close, createLineRecordReader, getContext, getProgress, getRecordReader, initialize
getCurrentVertex
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
protected IntPair preprocessLine(org.apache.hadoop.io.Text line) throws IOException
TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed
preprocessLine
in class TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed<IntPair>
line
- the current line to be readIOException
- exception that can be thrown while readingprotected org.apache.hadoop.io.IntWritable getId(IntPair data) throws IOException
TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed
getId
in class TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed<IntPair>
data
- the object obtained by preprocessing the lineIOException
- exception that can be thrown while readingprotected org.apache.hadoop.io.IntWritable getValue(IntPair data) throws IOException
TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed
getValue
in class TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed<IntPair>
data
- the object obtained by preprocessing the lineIOException
- exception that can be thrown while readingCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.