org.apache.reef.examples.data.output

Class OutputServiceDriver

java.lang.Object

org.apache.reef.examples.data.output.OutputServiceDriver

public final class OutputServiceDriver
extends Object

The Driver code for the output service demo app.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	OutputServiceDriver.ActiveContextHandler Handles ActiveContext: Submit the output service demo task.
class	OutputServiceDriver.EvaluatorAllocatedHandler Handles AllocatedEvaluator: Submit the output service and a context for it.
class	OutputServiceDriver.StartHandler Handles the StartTime event: Request three Evaluators.

Constructor Summary

Constructors

Constructor and Description
OutputServiceDriver(EvaluatorRequestor requestor, OutputService outputService) Job driver constructor - instantiated via TANG.

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

OutputServiceDriver

@Inject
public OutputServiceDriver(EvaluatorRequestor requestor,
                          OutputService outputService)

Job driver constructor - instantiated via TANG.

Parameters:

requestor - evaluator requestor object used to create new evaluator containers.

outputService - output service object.