HelloGiraph0p2

import org.apache.giraph.combiner.DoubleSumCombiner;
import org.apache.giraph.conf.GiraphConfiguration;
import org.apache.giraph.graph.GiraphJob;
import org.apache.giraph.io.formats.PseudoRandomVertexInputFormat;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.util.Tool;
import org.apache.hadoop.util.ToolRunner;

public class HelloGiraph0p2 implements Tool {

    private Configuration conf;

    @Override
    public Configuration getConf() {
        return conf;
    }

    @Override
    public void setConf(Configuration conf) {
        this.conf = conf;
    }

    @Override
    public final int run(final String[] args) throws Exception {

        String name = getClass().getName();

        GiraphJob job = new GiraphJob(getConf(), name);
        GiraphConfiguration configuration = job.getConfiguration();

        configuration.setVertexClass(EdgeListVertexTwoPlusTwo.class);

        configuration.setVertexInputFormatClass(PseudoRandomVertexInputFormat.class);
        configuration.setLong(PseudoRandomVertexInputFormat.AGGREGATE_VERTICES, 1000L );
        configuration.setLong(PseudoRandomVertexInputFormat.EDGES_PER_VERTEX, 10L );

        int workers = 30;
        configuration.setWorkerConfiguration(workers, workers, 100.0f);

        boolean isVerbose = true;
        if (job.run(isVerbose)) {
            return 0;
        } else {
            return -1;
        }
    }

    public static void main(final String[] args) throws Exception {
        System.exit(ToolRunner.run(new HelloGiraph0p2(), args));
    }
}