public static class AggregatorsTestComputation.SimpleEdgeInputFormat extends EdgeInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable>
Constructor and Description |
---|
SimpleEdgeInputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
checkInputSpecs(org.apache.hadoop.conf.Configuration conf) |
EdgeReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> |
createEdgeReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
List<org.apache.hadoop.mapreduce.InputSplit> |
getSplits(org.apache.hadoop.mapreduce.JobContext context,
int minSplitCountHint) |
readInputSplit, writeInputSplit
getConf, setConf
public void checkInputSpecs(org.apache.hadoop.conf.Configuration conf)
checkInputSpecs
in class GiraphInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.FloatWritable>
public EdgeReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> createEdgeReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
createEdgeReader
in class EdgeInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable>
IOException
public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context, int minSplitCountHint) throws IOException, InterruptedException
getSplits
in class GiraphInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.FloatWritable>
IOException
InterruptedException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.