Class ClientStreamerWithReceiverBatchSendRequest
java.lang.Object
org.apache.ignite.client.handler.requests.table.ClientStreamerWithReceiverBatchSendRequest
Client streamer batch request.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic 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.
-
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.
-