Class ClientComputeExecuteMapReduceRequest

java.lang.Object
org.apache.ignite.client.handler.requests.compute.ClientComputeExecuteMapReduceRequest

public class ClientComputeExecuteMapReduceRequest extends Object
Compute MapReduce request.
  • Constructor Details

    • ClientComputeExecuteMapReduceRequest

      public ClientComputeExecuteMapReduceRequest()
  • Method Details

    • process

      public static CompletableFuture<ResponseWriter> process(org.apache.ignite.internal.client.proto.ClientMessageUnpacker in, org.apache.ignite.internal.compute.IgniteComputeInternal compute, NotificationSender notificationSender, ClientContext clientContext)
      Processes the request.
      Parameters:
      in - Unpacker.
      compute - Compute.
      notificationSender - Notification sender.
      clientContext - Client context.
      Returns:
      Future.