Package org.apache.ignite.compute.task

Class MapReduceJob<T,R>

java.lang.Object

org.apache.ignite.compute.task.MapReduceJob<T,R>

public class MapReduceJob<T,R>
extends Object

A description of the job to be submitted as a result of the split step of the MapReduceTask. Reflects the parameters of the IgniteCompute.submitAsync(JobTarget, JobDescriptor, Object) method.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MapReduceJob.ComputeJobRunnerBuilder<T,R>	Job submit parameters builder.

Method Summary

Modifier and Type	Method	Description
T	arg()	Arguments of the job.
static <T, R> MapReduceJob.ComputeJobRunnerBuilder<T,R>	builder()	Returns new builder.
JobDescriptor<T,R>	jobDescriptor()	Job descriptor.
Set<ClusterNode>	nodes()	Candidate nodes; the job will be executed on one of them.
MapReduceJob.ComputeJobRunnerBuilder<T,R>	toBuilder()	Returns new builder using this definition.

Methods inherited from class java.lang.Object

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

Method Details

nodes

public Set<ClusterNode> nodes()

Candidate nodes; the job will be executed on one of them.

Returns:

A set of candidate nodes.

jobDescriptor

public JobDescriptor<T,R> jobDescriptor()

Job descriptor.

Returns:

Job descriptor.

arg

public T arg()

Arguments of the job.

Returns:

Arguments of the job.

toBuilder

public MapReduceJob.ComputeJobRunnerBuilder<T,R> toBuilder()

Returns new builder using this definition.

Returns:

New builder.

builder

public static <T,
R>
MapReduceJob.ComputeJobRunnerBuilder<T,R> builder()

Returns new builder.

Returns:

New builder.