org.apache.reef.examples.data.loading

Class LineCountingTask

java.lang.Object

org.apache.reef.examples.data.loading.LineCountingTask

All Implemented Interfaces:

Task

public class LineCountingTask
extends Object
implements Task

The task that iterates over the data set to count the number of records. Assumes TextInputFormat and that records represent lines.

Constructor Summary

Constructors

Constructor and Description
LineCountingTask(DataSet<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text> dataSet)

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	call(byte[] memento) Called by the resourcemanager harness to execute the task.

Methods inherited from class java.lang.Object

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

Constructor Detail

LineCountingTask

@Inject
public LineCountingTask(DataSet<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text> dataSet)

Method Detail

call

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

Description copied from interface: Task

Called by the resourcemanager harness to execute the task.

Specified by:

call in interface Task

Parameters:

memento - the memento objected passed down by the driver.

Returns:

the user defined return value

Throws:

Exception - whenever the Task encounters an unsolved issue. This Exception will be thrown at the Driver's event handler.