I
- Vertex index valueE
- Edge valuepublic abstract class GeneratedEdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> extends EdgeReader<I,E>
Modifier and Type | Field and Description |
---|---|
static LongConfOption |
DEFAULT_READER_EDGES
Default edges produced by this reader
|
protected BspInputSplit |
inputSplit
The input split from initialize().
|
protected long |
recordsRead
Records read so far
|
protected long |
totalRecords
Total records to read (on this split alone)
|
Constructor and Description |
---|
GeneratedEdgeReader()
Default constructor for reflection.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
float |
getProgress() |
void |
initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
getCurrentEdge, getCurrentSourceId, nextEdge
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
public static final LongConfOption DEFAULT_READER_EDGES
protected long recordsRead
protected long totalRecords
protected BspInputSplit inputSplit
public GeneratedEdgeReader()
public final void initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
initialize
in class EdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
IOException
public void close() throws IOException
close
in class EdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
IOException
public final float getProgress() throws IOException
getProgress
in class EdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
IOException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.