Package org.apache.ignite.compute

Class TaskDescriptor.Builder<T,R>

java.lang.Object
org.apache.ignite.compute.TaskDescriptor.Builder<T,R>
Enclosing class:
TaskDescriptor<T,R>
public static class TaskDescriptor.Builder<T,R> extends Object
Builder.

  • Method Details

    • units

      public TaskDescriptor.Builder<T,R> units(List<DeploymentUnit> units)
      Sets the deployment units.
      Parameters:
      units - Deployment units.
      Returns:
      This builder.

    • units

      public TaskDescriptor.Builder<T,R> units(DeploymentUnit... units)
      Sets the deployment units.
      Parameters:
      units - Deployment units.
      Returns:
      This builder.

    • splitJobArgumentMarshaller

      public TaskDescriptor.Builder<T,R> splitJobArgumentMarshaller(Marshaller<T,byte[]> splitJobArgumentMarshaller)
      Sets the marshaller for split job argument.
      Parameters:
      splitJobArgumentMarshaller - Marshaller for split job argument.
      Returns:
      This builder.

    • reduceJobResultMarshaller

      public TaskDescriptor.Builder<T,R> reduceJobResultMarshaller(Marshaller<R,byte[]> reduceJobResultMarshaller)
      Sets the marshaller for reduce job result.
      Parameters:
      reduceJobResultMarshaller - Marshaller for reduce job result.
      Returns:
      This builder.

    • reduceJobResultClass

      public TaskDescriptor.Builder<T,R> reduceJobResultClass(Class<R> reduceJobResultClass)
      Sets the reduce job result class.
      Parameters:
      reduceJobResultClass - Reduce job result class.
      Returns:
      This builder.

    • build

      public TaskDescriptor<T,R> build()
      Builds the task descriptor.
      Returns:
      Task descriptor.