Package | Description |
---|---|
org.tikv.common | |
org.tikv.common.importer | |
org.tikv.common.operation | |
org.tikv.common.region | |
org.tikv.common.util | |
org.tikv.txn | |
org.tikv.txn.type |
Modifier and Type | Method and Description |
---|---|
static List<TiRegion> |
TiBatchWriteUtils.getIndexRegions(TiSession session,
TiTableInfo table) |
static List<TiRegion> |
TiBatchWriteUtils.getRecordRegions(TiSession session,
TiTableInfo table) |
static List<TiRegion> |
TiBatchWriteUtils.getRegionByIndex(TiSession session,
TiTableInfo table,
TiIndexInfo index) |
static List<TiRegion> |
TiBatchWriteUtils.getRegionsByTable(TiSession session,
TiTableInfo table) |
Constructor and Description |
---|
ImporterClient(TiSession tiSession,
com.google.protobuf.ByteString uuid,
Key minKey,
Key maxKey,
TiRegion region,
Long ttl) |
Modifier and Type | Method and Description |
---|---|
TiRegion |
RegionErrorHandler.getRegion() |
Modifier and Type | Field and Description |
---|---|
protected TiRegion |
AbstractRegionStoreClient.region |
Modifier and Type | Method and Description |
---|---|
TiRegion |
RegionManager.createRegion(Metapb.Region region,
BackOffer backOffer) |
TiRegion |
AbstractRegionStoreClient.getRegion() |
TiRegion |
RegionErrorReceiver.getRegion() |
TiRegion |
RegionManager.getRegionById(long regionId)
Deprecated.
|
TiRegion |
RegionCache.getRegionById(long regionId)
Deprecated.
|
TiRegion |
RegionManager.getRegionByKey(com.google.protobuf.ByteString key) |
TiRegion |
RegionManager.getRegionByKey(com.google.protobuf.ByteString key,
BackOffer backOffer) |
TiRegion |
RegionCache.getRegionByKey(com.google.protobuf.ByteString key,
BackOffer backOffer) |
TiRegion |
RegionCache.putRegion(TiRegion region) |
TiRegion |
TiRegion.switchPeer(long leaderStoreID)
switches current peer to the one on specific store.
|
TiRegion |
RegionManager.updateLeader(TiRegion region,
long storeId) |
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 |
---|---|
RegionStoreClient |
RegionStoreClient.RegionStoreClientBuilder.build(TiRegion region) |
RegionStoreClient |
RegionStoreClient.RegionStoreClientBuilder.build(TiRegion region,
BackOffer backOffer) |
RegionStoreClient |
RegionStoreClient.RegionStoreClientBuilder.build(TiRegion region,
TiStore store) |
RegionStoreClient |
RegionStoreClient.RegionStoreClientBuilder.build(TiRegion region,
TiStore store,
TiStoreType storeType) |
void |
RegionManager.insertRegionToCache(TiRegion region) |
void |
RegionCache.insertRegionToCache(TiRegion region) |
void |
RegionManager.invalidateRegion(TiRegion region) |
void |
RegionCache.invalidateRegion(TiRegion region)
Removes region associated with regionId from regionCache.
|
boolean |
AbstractRegionStoreClient.onNotLeader(TiRegion newRegion,
BackOffer backOffer)
onNotLeader deals with NotLeaderError and returns whether re-splitting key range is needed
|
boolean |
RegionErrorReceiver.onNotLeader(TiRegion region,
BackOffer backOffer) |
void |
RegionManager.onRegionStale(TiRegion region) |
void |
RegionManager.onRequestFail(TiRegion region)
Clears all cache when a TiKV server does not respond
|
TiRegion |
RegionCache.putRegion(TiRegion region) |
TiRegion |
RegionManager.updateLeader(TiRegion region,
long storeId) |
boolean |
RegionCache.updateRegion(TiRegion expected,
TiRegion region) |
Constructor and Description |
---|
AbstractRegionStoreClient(TiConfiguration conf,
TiRegion region,
TiStore store,
ChannelFactory channelFactory,
TikvGrpc.TikvBlockingStub blockingStub,
TikvGrpc.TikvFutureStub asyncStub,
RegionManager regionManager) |
Modifier and Type | Method and Description |
---|---|
TiRegion |
DeleteRange.getRegion() |
TiRegion |
Batch.getRegion() |
TiRegion |
RangeSplitter.RegionTask.getRegion() |
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.
|
static Map<TiRegion,List<com.google.protobuf.ByteString>> |
ClientUtils.groupKeysByRegion(RegionManager regionManager,
List<com.google.protobuf.ByteString> keys,
BackOffer backoffer) |
static Map<TiRegion,List<com.google.protobuf.ByteString>> |
ClientUtils.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>> |
ClientUtils.groupKeysByRegion(RegionManager regionManager,
Set<com.google.protobuf.ByteString> keys,
BackOffer backoffer) |
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 RangeSplitter.RegionTask |
RangeSplitter.RegionTask.newInstance(TiRegion region,
TiStore store,
List<Coprocessor.KeyRange> ranges) |
Constructor and Description |
---|
Batch(BackOffer backOffer,
TiRegion region,
List<com.google.protobuf.ByteString> keys) |
Batch(BackOffer backOffer,
TiRegion region,
List<com.google.protobuf.ByteString> keys,
List<com.google.protobuf.ByteString> values) |
DeleteRange(BackOffer backOffer,
TiRegion region,
com.google.protobuf.ByteString startKey,
com.google.protobuf.ByteString endKey) |
Modifier and Type | Method and Description |
---|---|
ClientRPCResult |
TxnKVClient.commit(BackOffer backOffer,
com.google.protobuf.ByteString[] keys,
long startTs,
long commitTs,
TiRegion tiRegion,
TiStore store)
Commit request of 2pc, add backoff logic when encountered region error, ErrBodyMissing, and
other errors
|
static AbstractLockResolverClient |
AbstractLockResolverClient.getInstance(TiConfiguration conf,
TiRegion region,
TiStore store,
TikvGrpc.TikvBlockingStub blockingStub,
TikvGrpc.TikvFutureStub asyncStub,
ChannelFactory channelFactory,
RegionManager regionManager,
PDClient pdClient,
RegionStoreClient.RegionStoreClientBuilder clientBuilder) |
ClientRPCResult |
TxnKVClient.prewrite(BackOffer backOffer,
List<Kvrpcpb.Mutation> mutations,
com.google.protobuf.ByteString primary,
long lockTTL,
long startTs,
TiRegion tiRegion,
TiStore store)
when encountered region error,ErrBodyMissing, and other errors
|
ClientRPCResult |
TxnKVClient.txnHeartBeat(BackOffer backOffer,
com.google.protobuf.ByteString primaryLock,
long startTs,
long ttl,
TiRegion tiRegion,
TiStore store)
TXN Heart Beat: update primary key ttl
|
Constructor and Description |
---|
LockResolverClientV2(TiConfiguration conf,
TiRegion region,
TiStore store,
TikvGrpc.TikvBlockingStub blockingStub,
TikvGrpc.TikvFutureStub asyncStub,
ChannelFactory channelFactory,
RegionManager regionManager) |
LockResolverClientV3(TiConfiguration conf,
TiRegion region,
TiStore store,
TikvGrpc.TikvBlockingStub blockingStub,
TikvGrpc.TikvFutureStub asyncStub,
ChannelFactory channelFactory,
RegionManager regionManager,
PDClient pdClient,
RegionStoreClient.RegionStoreClientBuilder clientBuilder) |
LockResolverClientV4(TiConfiguration conf,
TiRegion region,
TiStore store,
TikvGrpc.TikvBlockingStub blockingStub,
TikvGrpc.TikvFutureStub asyncStub,
ChannelFactory channelFactory,
RegionManager regionManager,
PDClient pdClient,
RegionStoreClient.RegionStoreClientBuilder clientBuilder) |
Modifier and Type | Method and Description |
---|---|
TiRegion |
BatchKeys.getRegion() |
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) |
Constructor and Description |
---|
BatchKeys(TiRegion region,
TiStore store,
List<com.google.protobuf.ByteString> keysInput,
int sizeInBytes) |
Copyright © 2024 PingCAP. All rights reserved.