public static class AggregatorsTestComputation.SimpleEdgeReader extends GeneratedEdgeReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable>
DEFAULT_READER_EDGES, inputSplit, recordsRead, totalRecords
Constructor and Description |
---|
SimpleEdgeReader() |
Modifier and Type | Method and Description |
---|---|
Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> |
getCurrentEdge() |
org.apache.hadoop.io.LongWritable |
getCurrentSourceId() |
boolean |
nextEdge() |
close, getProgress, initialize
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
public boolean nextEdge()
nextEdge
in class EdgeReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable>
public Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> getCurrentEdge() throws IOException
getCurrentEdge
in class EdgeReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable>
IOException
public org.apache.hadoop.io.LongWritable getCurrentSourceId() throws IOException, InterruptedException
getCurrentSourceId
in class EdgeReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable>
IOException
InterruptedException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.