org.gridgain.grid.ggfs.mapreduce

Class GridGgfsTaskNoReduceAdapter<T,R>

java.lang.Object

org.gridgain.grid.compute.GridComputeTaskAdapter<GridGgfsTaskArgs<T>,R>

org.gridgain.grid.ggfs.mapreduce.GridGgfsTask<T,R>

org.gridgain.grid.ggfs.mapreduce.GridGgfsTaskNoReduceAdapter<T,R>

All Implemented Interfaces:

Serializable, GridComputeTask<GridGgfsTaskArgs<T>,R>

public abstract class GridGgfsTaskNoReduceAdapter<T,R>
extends GridGgfsTask<T,R>

Convenient GridGgfsTask adapter with empty reduce step. Use this adapter in case you are not interested in results returned by jobs.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GridGgfsTaskNoReduceAdapter()

Method Summary

Methods

Modifier and Type	Method and Description
R	reduce(List<GridComputeJobResult> results) Default implementation which will ignore all results sent from execution nodes.

Methods inherited from class org.gridgain.grid.ggfs.mapreduce.GridGgfsTask

createJob, map

Methods inherited from class org.gridgain.grid.compute.GridComputeTaskAdapter

result

Methods inherited from class java.lang.Object

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

Constructor Detail

GridGgfsTaskNoReduceAdapter

public GridGgfsTaskNoReduceAdapter()

Method Detail

reduce

public R reduce(List<GridComputeJobResult> results)

Default implementation which will ignore all results sent from execution nodes.

Parameters:

results - Received results of broadcasted remote executions. Note that if task class has GridComputeTaskNoResultCache annotation, then this list will be empty.

Returns:

Will always return null.