org.apache.ignite.internal.processors.hadoop

Class GridHadoopTaskContext

java.lang.Object

org.apache.ignite.internal.processors.hadoop.GridHadoopTaskContext

public abstract class GridHadoopTaskContext
extends Object

Task context.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GridHadoopTaskContext(GridHadoopTaskInfo taskInfo, GridHadoopJob job)

Method Summary

Methods

Modifier and Type	Method and Description
abstract void	cancel() Cancel current task execution.
abstract void	cleanupTaskEnvironment() Cleans up local environment of the task.
abstract <T extends GridHadoopCounter> T	counter(String grp, String name, Class<T> cls) Gets counter for the given name.
abstract GridHadoopCounters	counters() Gets all known counters.
abstract Comparator<Object>	groupComparator() Gets comparator for grouping on combine or reduce operation.
GridHadoopTaskInput	input() Gets task input.
void	input(GridHadoopTaskInput in) Sets input of the task.
GridHadoopJob	job()
abstract GridHadoopSerialization	keySerialization() Gets serializer for values.
GridHadoopTaskOutput	output() Gets task output.
void	output(GridHadoopTaskOutput out) Sets output of the task.
abstract GridHadoopPartitioner	partitioner() Gets partitioner.
abstract void	prepareTaskEnvironment() Prepare local environment for the task.
abstract void	run() Execute current task.
abstract Comparator<Object>	sortComparator() Gets sorting comparator.
GridHadoopTaskInfo	taskInfo() Gets task info.
void	taskInfo(GridHadoopTaskInfo info) Set a new task info.
abstract GridHadoopSerialization	valueSerialization() Gets serializer for values.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridHadoopTaskContext

protected GridHadoopTaskContext(GridHadoopTaskInfo taskInfo,
                     GridHadoopJob job)

Parameters:

taskInfo - Task info.

job - Job.

Method Detail

taskInfo

public GridHadoopTaskInfo taskInfo()

Gets task info.

Returns:

Task info.

taskInfo

public void taskInfo(GridHadoopTaskInfo info)

Set a new task info.

Parameters:

info - Task info.

output

public GridHadoopTaskOutput output()

Gets task output.

Returns:

Task output.

input

public GridHadoopTaskInput input()

Gets task input.

Returns:

Task input.

job

public GridHadoopJob job()

Returns:

Job.

counter

public abstract <T extends GridHadoopCounter> T counter(String grp,
                                      String name,
                                      Class<T> cls)

Gets counter for the given name.

Parameters:

grp - Counter group's name.

name - Counter name.

Returns:

Counter.

counters

public abstract GridHadoopCounters counters()

Gets all known counters.

Returns:

Unmodifiable collection of counters.

input

public void input(GridHadoopTaskInput in)

Sets input of the task.

Parameters:

in - Input.

output

public void output(GridHadoopTaskOutput out)

Sets output of the task.

Parameters:

out - Output.

partitioner

public abstract GridHadoopPartitioner partitioner()
                                           throws IgniteCheckedException

Gets partitioner.

Returns:

Partitioner.

Throws:

IgniteCheckedException - If failed.

keySerialization

public abstract GridHadoopSerialization keySerialization()
                                                  throws IgniteCheckedException

Gets serializer for values.

Returns:

Serializer for keys.

Throws:

IgniteCheckedException - If failed.

valueSerialization

public abstract GridHadoopSerialization valueSerialization()
                                                    throws IgniteCheckedException

Gets serializer for values.

Returns:

Serializer for values.

Throws:

IgniteCheckedException - If failed.

sortComparator

public abstract Comparator<Object> sortComparator()

Gets sorting comparator.

Returns:

Comparator for sorting.

groupComparator

public abstract Comparator<Object> groupComparator()

Gets comparator for grouping on combine or reduce operation.

Returns:

Comparator.

run

public abstract void run()
                  throws IgniteCheckedException

Execute current task.

Throws:

IgniteCheckedException - If failed.

cancel

public abstract void cancel()

Cancel current task execution.

prepareTaskEnvironment

public abstract void prepareTaskEnvironment()
                                     throws IgniteCheckedException

Prepare local environment for the task.

Throws:

IgniteCheckedException - If failed.

cleanupTaskEnvironment

public abstract void cleanupTaskEnvironment()
                                     throws IgniteCheckedException

Cleans up local environment of the task.

Throws:

IgniteCheckedException - If failed.