org.apache.giraph.benchmark

Class RandomMessageBenchmark

java.lang.Object

org.apache.giraph.benchmark.GiraphBenchmark

org.apache.giraph.benchmark.RandomMessageBenchmark

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

public class RandomMessageBenchmark
extends GiraphBenchmark

Random Message Benchmark for evaluating the messaging performance.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RandomMessageBenchmark.RandomMessageBenchmarkMasterCompute Master compute associated with RandomMessageBenchmark.
static class	RandomMessageBenchmark.RandomMessageBenchmarkWorkerContext WorkerContext forRandomMessageBenchmark.
static class	RandomMessageBenchmark.RandomMessageComputation Actual message computation (messaging in this case)

Field Summary

Fields

Modifier and Type	Field and Description
static String	AGG_SUPERSTEP_TOTAL_BYTES All bytes sent during this superstep
static String	AGG_SUPERSTEP_TOTAL_MESSAGES All messages during this superstep
static String	AGG_SUPERSTEP_TOTAL_MILLIS All millis during this superstep
static String	AGG_TOTAL_BYTES All bytes sent during this application
static String	AGG_TOTAL_MESSAGES All messages during this application
static String	AGG_TOTAL_MILLIS All millis during this application
static int	DEFAULT_NUM_BYTES_PER_MESSAGE Default bytes per message
static int	DEFAULT_NUM_MESSAGES_PER_EDGE Default messages per edge
static String	NUM_BYTES_PER_MESSAGE How many bytes per message
static String	NUM_MESSAGES_PER_EDGE How many messages per edge
static String	SUPERSTEP_COUNT How many supersteps to run
static String	WORKERS_NUM Workers for that superstep

Constructor Summary

Constructors

Constructor and Description
RandomMessageBenchmark()

Method Summary

Modifier and Type	Method and Description
Set<BenchmarkOption>	getBenchmarkOptions() Get the options to use in this benchmark.
static void	main(String[] args) Execute the benchmark.
protected void	prepareConfiguration(GiraphConfiguration conf, org.apache.commons.cli.CommandLine cmd) Process options from CommandLine and prepare configuration for running the job.

Methods inherited from class org.apache.giraph.benchmark.GiraphBenchmark

getConf, run, setConf

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SUPERSTEP_COUNT

public static final String SUPERSTEP_COUNT

How many supersteps to run

See Also:

Constant Field Values

NUM_BYTES_PER_MESSAGE

public static final String NUM_BYTES_PER_MESSAGE

How many bytes per message

See Also:

Constant Field Values

DEFAULT_NUM_BYTES_PER_MESSAGE

public static final int DEFAULT_NUM_BYTES_PER_MESSAGE

Default bytes per message

See Also:

Constant Field Values

NUM_MESSAGES_PER_EDGE

public static final String NUM_MESSAGES_PER_EDGE

How many messages per edge

See Also:

Constant Field Values

DEFAULT_NUM_MESSAGES_PER_EDGE

public static final int DEFAULT_NUM_MESSAGES_PER_EDGE

Default messages per edge

See Also:

Constant Field Values

AGG_SUPERSTEP_TOTAL_BYTES

public static final String AGG_SUPERSTEP_TOTAL_BYTES

All bytes sent during this superstep

See Also:

Constant Field Values

AGG_TOTAL_BYTES

public static final String AGG_TOTAL_BYTES

All bytes sent during this application

See Also:

Constant Field Values

AGG_SUPERSTEP_TOTAL_MESSAGES

public static final String AGG_SUPERSTEP_TOTAL_MESSAGES

All messages during this superstep

See Also:

Constant Field Values

AGG_TOTAL_MESSAGES

public static final String AGG_TOTAL_MESSAGES

All messages during this application

See Also:

Constant Field Values

AGG_SUPERSTEP_TOTAL_MILLIS

public static final String AGG_SUPERSTEP_TOTAL_MILLIS

All millis during this superstep

See Also:

Constant Field Values

AGG_TOTAL_MILLIS

public static final String AGG_TOTAL_MILLIS

All millis during this application

See Also:

Constant Field Values

WORKERS_NUM

public static final String WORKERS_NUM

Workers for that superstep

See Also:

Constant Field Values

Constructor Detail

RandomMessageBenchmark

public RandomMessageBenchmark()

Method Detail

getBenchmarkOptions

public Set<BenchmarkOption> getBenchmarkOptions()

Description copied from class: GiraphBenchmark

Get the options to use in this benchmark. BenchmarkOption.VERBOSE, BenchmarkOption.HELP and BenchmarkOption.WORKERS will be added automatically, so you don't have to specify those.

Specified by:

getBenchmarkOptions in class GiraphBenchmark

Returns:

Options to use in this benchmark

prepareConfiguration

protected void prepareConfiguration(GiraphConfiguration conf,
                                    org.apache.commons.cli.CommandLine cmd)

Description copied from class: GiraphBenchmark

Process options from CommandLine and prepare configuration for running the job. BenchmarkOption.VERBOSE, BenchmarkOption.HELP and BenchmarkOption.WORKERS will be processed automatically so you don't have to process them.

Specified by:

prepareConfiguration in class GiraphBenchmark

Parameters:

conf - Configuration

cmd - Command line

main

public static void main(String[] args)
                 throws Exception

Execute the benchmark.

Parameters:

args - Typically, this is the command line arguments.

Throws:

Exception - Any exception thrown during computation.