Package org.apache.ignite.compute

Class TaskDescriptor<T,R>

java.lang.Object

org.apache.ignite.compute.TaskDescriptor<T,R>

public class TaskDescriptor<T,R>
extends Object

Compute task descriptor.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TaskDescriptor.Builder<T,R>	Builder.

Method Summary

Modifier and Type	Method	Description
static <I, M, T, R> TaskDescriptor.Builder<I,R>	builder(Class<? extends MapReduceTask<I,M,T,R>> taskClass)	Create a new builder.
static <T, R> TaskDescriptor.Builder<T,R>	builder(String taskClassName)	Create a new builder.
Class<R>	reduceJobResultClass()	Reduce job result class.
Marshaller<R,byte[]>	reduceJobResultMarshaller()	Marshaller for reduce job result.
Marshaller<T,byte[]>	splitJobArgumentMarshaller()	Marshaller for split job argument.
String	taskClassName()	Task class name.
List<DeploymentUnit>	units()	Deployment units.

Methods inherited from class java.lang.Object

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

Method Details

taskClassName

public String taskClassName()

Task class name.

Returns:

Task class name.

units

public List<DeploymentUnit> units()

Deployment units.

Returns:

Deployment units.

splitJobArgumentMarshaller

public Marshaller<T,byte[]> splitJobArgumentMarshaller()

Marshaller for split job argument.

Returns:

Marshaller for split job argument.

reduceJobResultMarshaller

public Marshaller<R,byte[]> reduceJobResultMarshaller()

Marshaller for reduce job result.

Returns:

Marshaller for reduce job result.

reduceJobResultClass

public Class<R> reduceJobResultClass()

Reduce job result class.

Returns:

Reduce job result class.

builder

public static <T,
R> TaskDescriptor.Builder<T,R> builder(String taskClassName)

Create a new builder.

Returns:

Task descriptor builder.

builder

public static <I,
M,
T,
R> TaskDescriptor.Builder<I,R> builder(Class<? extends MapReduceTask<I,M,T,R>> taskClass)

Create a new builder.

Returns:

Task descriptor builder.