org.apache.reef.examples.group.bgd

Class BGDClient

java.lang.Object

org.apache.reef.examples.group.bgd.BGDClient

public class BGDClient
extends Object

A client to submit BGD Jobs.

Constructor Summary

Constructors

Constructor and Description
BGDClient(String input, int numSplits, int memory, int fanOut, BGDControlParameters bgdControlParameters)

Method Summary

Methods

Modifier and Type	Method and Description
static BGDClient	fromCommandLine(String[] args)
LauncherStatus	run(Configuration runtimeConfiguration, String jobName, int timeout) Runs BGD on the given runtime - with timeout.
void	submit(Configuration runtimeConfiguration, String jobName) Runs BGD on the given runtime.

Methods inherited from class java.lang.Object

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

Constructor Detail

BGDClient

@Inject
public BGDClient(String input,
                int numSplits,
                int memory,
                int fanOut,
                BGDControlParameters bgdControlParameters)

Method Detail

submit

public void submit(Configuration runtimeConfiguration,
          String jobName)
            throws Exception

Runs BGD on the given runtime.

Parameters:

runtimeConfiguration - the runtime to run on.

jobName - the name of the job on the runtime.

Throws:

Exception

run

public LauncherStatus run(Configuration runtimeConfiguration,
                 String jobName,
                 int timeout)
                   throws Exception

Runs BGD on the given runtime - with timeout.

Parameters:

runtimeConfiguration - the runtime to run on.

jobName - the name of the job on the runtime.

timeout - the time after which the job will be killed if not completed, in ms

Returns:

job completion status

Throws:

Exception

fromCommandLine

public static final BGDClient fromCommandLine(String[] args)
                                       throws Exception

Throws:

Exception