Package org.apache.ignite.compute.task

Class MapReduceJob.ComputeJobRunnerBuilder<T,R>

java.lang.Object

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

Enclosing class:

MapReduceJob<T,R>

public static class MapReduceJob.ComputeJobRunnerBuilder<T,R>
extends Object

Job submit parameters builder.

Constructor Summary

Constructors

Constructor	Description
ComputeJobRunnerBuilder()

Method Summary

Modifier and Type	Method	Description
MapReduceJob.ComputeJobRunnerBuilder<T,R>	args(T args)	Sets arguments of the job.
MapReduceJob<T,R>	build()	Constructs a compute job description object.
MapReduceJob.ComputeJobRunnerBuilder<T,R>	jobDescriptor(JobDescriptor<T,R> jobDescriptor)	Sets job descriptor.
MapReduceJob.ComputeJobRunnerBuilder<T,R>	node(ClusterNode node)	Adds a node to the set of candidate nodes.
MapReduceJob.ComputeJobRunnerBuilder<T,R>	nodes(Collection<ClusterNode> nodes)	Adds nodes to the set of candidate nodes.

Methods inherited from class java.lang.Object

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

Constructor Details

ComputeJobRunnerBuilder

public ComputeJobRunnerBuilder()

Method Details

nodes

public MapReduceJob.ComputeJobRunnerBuilder<T,R> nodes(Collection<ClusterNode> nodes)

Adds nodes to the set of candidate nodes.

Parameters:

nodes - A collection of candidate nodes.

Returns:

Builder instance.

node

public MapReduceJob.ComputeJobRunnerBuilder<T,R> node(ClusterNode node)

Adds a node to the set of candidate nodes.

Parameters:

node - Candidate node.

Returns:

Builder instance.

jobDescriptor

public MapReduceJob.ComputeJobRunnerBuilder<T,R> jobDescriptor(JobDescriptor<T,R> jobDescriptor)

Sets job descriptor.

Parameters:

jobDescriptor - A job descriptor.

Returns:

Builder instance.

args

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

Sets arguments of the job.

Parameters:

args - Arguments of the job.

Returns:

Builder instance.

build

public MapReduceJob<T,R> build()

Constructs a compute job description object.

Returns:

Description object.