org.apache.ignite.internal.processors.hadoop.proto

Class HadoopProtocolTaskAdapter<R>

java.lang.Object

org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolTaskAdapter<R>

All Implemented Interfaces:

Serializable, ComputeTask<HadoopProtocolTaskArguments,R>

Direct Known Subclasses:

HadoopProtocolJobCountersTask, HadoopProtocolJobStatusTask, HadoopProtocolKillJobTask, HadoopProtocolNextTaskIdTask, HadoopProtocolSubmitJobTask

public abstract class HadoopProtocolTaskAdapter<R>
extends Object
implements ComputeTask<HadoopProtocolTaskArguments,R>

Hadoop protocol task adapter.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HadoopProtocolTaskAdapter()

Method Summary

Modifier and Type	Method and Description
Map<? extends ComputeJob,ClusterNode>	map(List<ClusterNode> subgrid, HadoopProtocolTaskArguments arg)
R	reduce(List<ComputeJobResult> results)
ComputeJobResultPolicy	result(ComputeJobResult res, List<ComputeJobResult> rcvd)
abstract R	run(ComputeJobContext jobCtx, Hadoop hadoop, HadoopProtocolTaskArguments args) Run the task.

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopProtocolTaskAdapter

public HadoopProtocolTaskAdapter()

Method Detail

map

@Nullable
public Map<? extends ComputeJob,ClusterNode> map(List<ClusterNode> subgrid,
                                                           @Nullable
                                                           HadoopProtocolTaskArguments arg)

Specified by:

map in interface ComputeTask<HadoopProtocolTaskArguments,R>

result

public ComputeJobResultPolicy result(ComputeJobResult res,
                                     List<ComputeJobResult> rcvd)

Specified by:

result in interface ComputeTask<HadoopProtocolTaskArguments,R>

reduce

@Nullable
public R reduce(List<ComputeJobResult> results)

Specified by:

reduce in interface ComputeTask<HadoopProtocolTaskArguments,R>

run

public abstract R run(ComputeJobContext jobCtx,
                      Hadoop hadoop,
                      HadoopProtocolTaskArguments args)
               throws IgniteCheckedException

Run the task.

Parameters:

jobCtx - Job context.

hadoop - Hadoop facade.

args - Arguments.

Returns:

Job result.

Throws:

IgniteCheckedException - If failed.