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 © 2024 PingCAP. All rights reserved.