Package | Description |
---|---|
org.tikv.common | |
org.tikv.common.apiversion | |
org.tikv.common.codec | |
org.tikv.common.importer | |
org.tikv.common.key | |
org.tikv.common.region | |
org.tikv.common.util | |
org.tikv.raw | |
org.tikv.txn | |
org.tikv.txn.type |
Modifier and Type | Method and Description |
---|---|
Pair<Metapb.Region,Metapb.Peer> |
ReadOnlyPDClient.getRegionByID(BackOffer backOffer,
long id)
Get Region by Region Id
|
Pair<Metapb.Region,Metapb.Peer> |
PDClient.getRegionByID(BackOffer backOffer,
long id) |
Pair<Metapb.Region,Metapb.Peer> |
ReadOnlyPDClient.getRegionByKey(BackOffer backOffer,
com.google.protobuf.ByteString key)
Get Region from PD by key specified
|
Pair<Metapb.Region,Metapb.Peer> |
PDClient.getRegionByKey(BackOffer backOffer,
com.google.protobuf.ByteString key) |
Modifier and Type | Method and Description |
---|---|
Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString> |
RequestKeyV2Codec.encodePdQueryRange(com.google.protobuf.ByteString start,
com.google.protobuf.ByteString end) |
Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString> |
RequestKeyV1TxnCodec.encodePdQueryRange(com.google.protobuf.ByteString start,
com.google.protobuf.ByteString end) |
Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString> |
RequestKeyCodec.encodePdQueryRange(com.google.protobuf.ByteString start,
com.google.protobuf.ByteString end) |
Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString> |
RequestKeyV1Codec.encodePdQueryRange(com.google.protobuf.ByteString start,
com.google.protobuf.ByteString end) |
Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString> |
RequestKeyV2Codec.encodeRange(com.google.protobuf.ByteString start,
com.google.protobuf.ByteString end) |
Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString> |
RequestKeyCodec.encodeRange(com.google.protobuf.ByteString start,
com.google.protobuf.ByteString end) |
Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString> |
RequestKeyV1Codec.encodeRange(com.google.protobuf.ByteString start,
com.google.protobuf.ByteString end) |
Modifier and Type | Method and Description |
---|---|
static Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString> |
MetaCodec.decodeHashDataKey(com.google.protobuf.ByteString rawKey) |
Modifier and Type | Method and Description |
---|---|
static List<Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString>> |
MetaCodec.hashGetFields(com.google.protobuf.ByteString key,
Snapshot snapshot) |
Modifier and Type | Method and Description |
---|---|
void |
ImporterClient.write(Iterator<Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString>> iterator)
write KV pairs to RawKV/Txn using KVStream interface
|
Modifier and Type | Method and Description |
---|---|
Pair<Key,Key> |
StatisticsKeyRangeBuilder.compute() |
Modifier and Type | Method and Description |
---|---|
Pair<TiRegion,TiStore> |
RegionManager.getRegionStorePairByKey(com.google.protobuf.ByteString key) |
Pair<TiRegion,TiStore> |
RegionManager.getRegionStorePairByKey(com.google.protobuf.ByteString key,
BackOffer backOffer) |
Pair<TiRegion,TiStore> |
RegionManager.getRegionStorePairByKey(com.google.protobuf.ByteString key,
TiStoreType storeType) |
Pair<TiRegion,TiStore> |
RegionManager.getRegionStorePairByKey(com.google.protobuf.ByteString key,
TiStoreType storeType,
BackOffer backOffer) |
Modifier and Type | Method and Description |
---|---|
static <F,S> Pair<F,S> |
Pair.create(F f,
S s) |
Modifier and Type | Method and Description |
---|---|
Map<Pair<TiRegion,TiStore>,gnu.trove.list.array.TLongArrayList> |
RangeSplitter.groupByAndSortHandlesByRegionId(long tableId,
gnu.trove.list.array.TLongArrayList handles)
Group by a list of handles by the handles' region, handles will be sorted.
|
Modifier and Type | Method and Description |
---|---|
static <T,U> List<U> |
ClientUtils.getTasksWithOutput(ExecutorCompletionService<Pair<List<T>,List<U>>> completionService,
Queue<List<T>> taskQueue,
List<T> batches,
long backOff) |
Modifier and Type | Method and Description |
---|---|
List<List<com.google.protobuf.ByteString>> |
RawKVClient.batchScanKeys(List<Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString>> ranges,
int eachLimit) |
List<List<com.google.protobuf.ByteString>> |
SmartRawKVClient.batchScanKeys(List<Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString>> ranges,
int eachLimit) |
List<List<com.google.protobuf.ByteString>> |
RawKVClientBase.batchScanKeys(List<Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString>> ranges,
int eachLimit)
Create a new `batch scan` request with `keyOnly` option Once resolved this request will result
in a set of scanners over the given keys.
|
void |
RawKVClient.ingest(List<Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString>> list)
Ingest KV pairs to RawKV using StreamKV API.
|
void |
RawKVClient.ingest(List<Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString>> list,
Long ttl)
Ingest KV pairs to RawKV using StreamKV API.
|
Modifier and Type | Method and Description |
---|---|
void |
KVClient.ingest(List<Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString>> list) |
Modifier and Type | Method and Description |
---|---|
Map<Pair<TiRegion,TiStore>,List<com.google.protobuf.ByteString>> |
GroupKeyResult.getGroupsResult() |
Modifier and Type | Method and Description |
---|---|
void |
GroupKeyResult.setGroupsResult(Map<Pair<TiRegion,TiStore>,List<com.google.protobuf.ByteString>> groupsResult) |
Copyright © 2024 PingCAP. All rights reserved.