org.tikv.common.util

Class ClientUtils

java.lang.Object

org.tikv.common.util.ClientUtils

public class ClientUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
ClientUtils()

Method Summary

Modifier and Type	Method and Description
static void	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	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 byte[]	genUUID()
static List<Batch>	getBatches(BackOffer backOffer, List<com.google.protobuf.ByteString> keys, int batchSize, int batchLimit, RegionStoreClient.RegionStoreClientBuilder clientBuilder)
static List<Kvrpcpb.KvPair>	getKvPairs(ExecutorCompletionService<List<Kvrpcpb.KvPair>> completionService, List<Batch> batches, int backOff)
static <T> void	getTasks(ExecutorCompletionService<List<T>> completionService, Queue<List<T>> taskQueue, List<T> batches, long backOff)
static <T,U> List<U>	getTasksWithOutput(ExecutorCompletionService<Pair<List<T>,List<U>>> completionService, Queue<List<T>> taskQueue, List<T> batches, long backOff)
static Map<TiRegion,List<com.google.protobuf.ByteString>>	groupKeysByRegion(RegionManager regionManager, List<com.google.protobuf.ByteString> keys, BackOffer backoffer)
static Map<TiRegion,List<com.google.protobuf.ByteString>>	groupKeysByRegion(RegionManager regionManager, List<com.google.protobuf.ByteString> keys, BackOffer backoffer, boolean sorted) Group by list of keys according to its region
static Map<TiRegion,List<com.google.protobuf.ByteString>>	groupKeysByRegion(RegionManager regionManager, Set<com.google.protobuf.ByteString> keys, BackOffer backoffer)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientUtils

public ClientUtils()

Method Detail

appendBatches

public static void 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

Parameters:

backOffer - backOffer

batches - a grouped batch

region - region

keys - keys

batchMaxSizeInBytes - batch max limit

appendBatches

public static void 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

Parameters:

backOffer - backOffer

batches - a grouped batch

region - region

keys - keys

values - values

batchMaxSizeInBytes - batch max limit

getBatches

public static List<Batch> getBatches(BackOffer backOffer,
                                     List<com.google.protobuf.ByteString> keys,
                                     int batchSize,
                                     int batchLimit,
                                     RegionStoreClient.RegionStoreClientBuilder clientBuilder)

groupKeysByRegion

public static Map<TiRegion,List<com.google.protobuf.ByteString>> groupKeysByRegion(RegionManager regionManager,
                                                                                   Set<com.google.protobuf.ByteString> keys,
                                                                                   BackOffer backoffer)

groupKeysByRegion

public static Map<TiRegion,List<com.google.protobuf.ByteString>> groupKeysByRegion(RegionManager regionManager,
                                                                                   List<com.google.protobuf.ByteString> keys,
                                                                                   BackOffer backoffer)

groupKeysByRegion

public static Map<TiRegion,List<com.google.protobuf.ByteString>> groupKeysByRegion(RegionManager regionManager,
                                                                                   List<com.google.protobuf.ByteString> keys,
                                                                                   BackOffer backoffer,
                                                                                   boolean sorted)

Group by list of keys according to its region

Parameters:

keys - keys

Returns:

a mapping of keys and their region

getKvPairs

public static List<Kvrpcpb.KvPair> getKvPairs(ExecutorCompletionService<List<Kvrpcpb.KvPair>> completionService,
                                              List<Batch> batches,
                                              int backOff)

getTasks

public static <T> void getTasks(ExecutorCompletionService<List<T>> completionService,
                                Queue<List<T>> taskQueue,
                                List<T> batches,
                                long backOff)

getTasksWithOutput

public static <T,U> List<U> getTasksWithOutput(ExecutorCompletionService<Pair<List<T>,List<U>>> completionService,
                                               Queue<List<T>> taskQueue,
                                               List<T> batches,
                                               long backOff)

genUUID

public static byte[] genUUID()