Class ClientPrepareForUpdateRequest
java.lang.Object
org.apache.ignite.client.handler.requests.table.ClientPrepareForUpdateRequest
Client request: for each tuple of a batch, take the locks an update of that row needs, without writing anything to the storage.
The locks are held until the transaction finishes.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic CompletableFuture<ResponseWriter>process(org.apache.ignite.internal.client.proto.ClientMessageUnpacker in, org.apache.ignite.internal.table.IgniteTablesInternal tables, org.apache.ignite.internal.catalog.CatalogService catalogService, org.apache.ignite.internal.schema.SchemaSyncService schemaSyncService, ClientResourceRegistry resources, ClientHandlerMetricSource metrics, org.apache.ignite.internal.tx.TxManager txManager, org.apache.ignite.internal.hlc.ClockService clockService, org.gridgain.internal.license.LicenseFeatureChecker licenseFeatureChecker, NotificationSender notificationSender, org.apache.ignite.internal.hlc.HybridTimestampTracker tsTracker, long requestId, Map<Long, Long> reqToTxMap) Processes the request.
-
Constructor Details
-
ClientPrepareForUpdateRequest
public ClientPrepareForUpdateRequest()
-
-
Method Details
-
process
public static CompletableFuture<ResponseWriter> process(org.apache.ignite.internal.client.proto.ClientMessageUnpacker in, org.apache.ignite.internal.table.IgniteTablesInternal tables, org.apache.ignite.internal.catalog.CatalogService catalogService, org.apache.ignite.internal.schema.SchemaSyncService schemaSyncService, ClientResourceRegistry resources, ClientHandlerMetricSource metrics, org.apache.ignite.internal.tx.TxManager txManager, org.apache.ignite.internal.hlc.ClockService clockService, org.gridgain.internal.license.LicenseFeatureChecker licenseFeatureChecker, NotificationSender notificationSender, org.apache.ignite.internal.hlc.HybridTimestampTracker tsTracker, long requestId, Map<Long, Long> reqToTxMap) Processes the request.- Parameters:
in- Unpacker.tables- Ignite tables.catalogService- Catalog service.schemaSyncService- Schema sync service.resources- Resource registry.metrics- Metrics.txManager- Ignite transactions.clockService- Clock service.licenseFeatureChecker- License feature checker.notificationSender- Notification sender.tsTracker- Timestamp tracker.requestId- Id of the request.reqToTxMap- Tracker for first request of direct transactions.- Returns:
- Future.
-