org.apache.reef.examples.data.output

Class OutputServiceTask

java.lang.Object

org.apache.reef.examples.data.output.OutputServiceTask

All Implemented Interfaces:

Task

public final class OutputServiceTask
extends Object
implements Task

The Task code for the output service demo app. This task receives an output stream from the output service and writes "Hello REEF!" on it.

Constructor Summary

Constructors

Constructor and Description
OutputServiceTask(OutputStreamProvider outputStreamProvider) Task constructor - instantiated via TANG.

Method Summary

Modifier and Type	Method and Description
byte[]	call(byte[] memento) Receives an output stream from the output service and writes "Hello REEF!" on it.

Methods inherited from class java.lang.Object

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

Constructor Detail

OutputServiceTask

@Inject
public OutputServiceTask(OutputStreamProvider outputStreamProvider)

Task constructor - instantiated via TANG.

Parameters:

outputStreamProvider - Output stream provider object through which tasks create output streams.

Method Detail

call

public byte[] call(byte[] memento)
            throws IOException

Receives an output stream from the output service and writes "Hello REEF!" on it.

Specified by:

call in interface Task

Parameters:

memento - the memento objected passed down by the driver.

Returns:

null

Throws:

IOException