public class SimpleAggregatorWriter extends DefaultImmutableClassesGiraphConfigurable implements AggregatorWriter
LAST_SUPERSTEP
Constructor and Description |
---|
SimpleAggregatorWriter() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
static String |
getFilename() |
void |
initialize(org.apache.hadoop.mapreduce.Mapper.Context context,
long applicationAttempt) |
void |
writeAggregator(Iterable<Map.Entry<String,org.apache.hadoop.io.Writable>> aggregatorMap,
long superstep) |
getConf, setConf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getConf
setConf
public static String getFilename()
public void initialize(org.apache.hadoop.mapreduce.Mapper.Context context, long applicationAttempt) throws IOException
initialize
in interface AggregatorWriter
IOException
public void writeAggregator(Iterable<Map.Entry<String,org.apache.hadoop.io.Writable>> aggregatorMap, long superstep) throws IOException
writeAggregator
in interface AggregatorWriter
IOException
public void close() throws IOException
close
in interface AggregatorWriter
IOException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.