Package org.apache.ignite.client.handler.requests.sql

Class ClientSqlExecuteRequest

java.lang.Object

org.apache.ignite.client.handler.requests.sql.ClientSqlExecuteRequest

public class ClientSqlExecuteRequest
extends Object

Client SQL execute request.

Constructor Summary

Constructors

Constructor	Description
ClientSqlExecuteRequest()

Method Summary

Modifier and Type	Method	Description
static CompletableFuture<ResponseWriter>	process(Executor operationExecutor, org.apache.ignite.internal.client.proto.ClientMessageUnpacker in, long requestId, Map<Long,CancelHandle> cancelHandles, org.apache.ignite.internal.sql.engine.QueryProcessor sql, ClientResourceRegistry resources, ClientHandlerMetricSource metrics, org.apache.ignite.internal.hlc.HybridTimestampTracker timestampTracker, boolean sqlPartitionAwarenessSupported, boolean sqlDirectTxMappingSupported, org.apache.ignite.internal.tx.TxManager txManager, org.apache.ignite.internal.hlc.ClockService clockService, NotificationSender notificationSender, @Nullable String username)	Processes the request.

Methods inherited from class java.lang.Object

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

Constructor Details

ClientSqlExecuteRequest

public ClientSqlExecuteRequest()

Method Details

process

public static CompletableFuture<ResponseWriter> process(Executor operationExecutor,
 org.apache.ignite.internal.client.proto.ClientMessageUnpacker in,
 long requestId,
 Map<Long,CancelHandle> cancelHandles,
 org.apache.ignite.internal.sql.engine.QueryProcessor sql,
 ClientResourceRegistry resources,
 ClientHandlerMetricSource metrics,
 org.apache.ignite.internal.hlc.HybridTimestampTracker timestampTracker,
 boolean sqlPartitionAwarenessSupported,
 boolean sqlDirectTxMappingSupported,
 org.apache.ignite.internal.tx.TxManager txManager,
 org.apache.ignite.internal.hlc.ClockService clockService,
 NotificationSender notificationSender,
 @Nullable
 @Nullable String username)

Processes the request.

Parameters:

operationExecutor - Executor to submit execution of operation.

in - Unpacker.

requestId - Id of the request.

cancelHandles - Registry of handlers. Request must register itself in this registry before switching to another thread.

sql - SQL API.

resources - Resources.

metrics - Metrics.

timestampTracker - Server's view of latest seen by client time.

sqlPartitionAwarenessSupported - Denotes whether client supports partition awareness for SQL or not.

sqlDirectTxMappingSupported - Denotes whether client supports direct mapping of implicit transaction for SQL operations for SQL or not.

txManager - Tx manager is used to start explicit transaction in case of transaction piggybacking, or to start remote transaction in case of direct mapping.

clockService - Clock service is required to update observable time after execution of operation within a remote transaction.

notificationSender - Notification sender is required to send acknowledge for underlying write operation within a remote transaction.

username - Authenticated user name or null for unknown user.

Returns:

Future representing result of operation.