| Package | Description |
|---|---|
| org.tikv.common.region | |
| org.tikv.common.util |
| Modifier and Type | Method and Description |
|---|---|
void |
RegionStoreClient.rawBatchPut(BackOffer backOffer,
Batch batch,
long ttl,
boolean atomicForCAS) |
| Modifier and Type | Method and Description |
|---|---|
static List<Batch> |
ClientUtils.getBatches(BackOffer backOffer,
List<com.google.protobuf.ByteString> keys,
int batchSize,
int batchLimit,
RegionStoreClient.RegionStoreClientBuilder clientBuilder) |
| Modifier and Type | Method and Description |
|---|---|
static void |
ClientUtils.appendBatches(BackOffer backOffer,
List<Batch> batches,
TiRegion region,
List<com.google.protobuf.ByteString> keys,
int batchMaxSizeInBytes,
int batchLimit)
Append batch to list and split them according to batch limit
|
static void |
ClientUtils.appendBatches(BackOffer backOffer,
List<Batch> batches,
TiRegion region,
List<com.google.protobuf.ByteString> keys,
List<com.google.protobuf.ByteString> values,
int batchMaxSizeInBytes,
int batchLimit)
Append batch to list and split them according to batch limit
|
static List<Kvrpcpb.KvPair> |
ClientUtils.getKvPairs(ExecutorCompletionService<List<Kvrpcpb.KvPair>> completionService,
List<Batch> batches,
int backOff) |
Copyright © 2025 PingCAP. All rights reserved.