Class ClientStreamerWithReceiverBatchSendRequest

java.lang.Object
org.apache.ignite.client.handler.requests.table.ClientStreamerWithReceiverBatchSendRequest

public class ClientStreamerWithReceiverBatchSendRequest extends Object
Client streamer batch request.
  • Constructor Details

    • ClientStreamerWithReceiverBatchSendRequest

      public ClientStreamerWithReceiverBatchSendRequest()
  • Method Details

    • process

      public static CompletableFuture<ResponseWriter> process(org.apache.ignite.internal.client.proto.ClientMessageUnpacker in, IgniteTables tables, boolean enableExecutionOptions, org.apache.ignite.internal.hlc.HybridTimestampTracker tsTracker)
      Processes the request.
      Parameters:
      in - Unpacker.
      tables - Ignite tables.
      enableExecutionOptions - Whether to read execution options.
      tsTracker - Hybrid timestamp tracker.
      Returns:
      Future.