Package | Description |
---|---|
org.tikv.common | |
org.tikv.common.importer | |
org.tikv.common.operation | |
org.tikv.common.region | |
org.tikv.common.util | |
org.tikv.txn |
Modifier and Type | Method and Description |
---|---|
RegionManager |
TiSession.getRegionManager() |
Constructor and Description |
---|
ImporterStoreClientBuilder(TiConfiguration conf,
ChannelFactory channelFactory,
RegionManager regionManager,
PDClient pdClient) |
Constructor and Description |
---|
KVErrorHandler(RegionManager regionManager,
RegionErrorReceiver recv,
AbstractLockResolverClient lockResolverClient,
Function<RespT,Errorpb.Error> getRegionError,
Function<RespT,Kvrpcpb.KeyError> getKeyError,
Function<ResolveLockResult,Object> resolveLockResultCallback,
long callerStartTS,
boolean forWrite) |
RegionErrorHandler(RegionManager regionManager,
RegionErrorReceiver recv,
Function<RespT,Errorpb.Error> getRegionError) |
Modifier and Type | Field and Description |
---|---|
protected RegionManager |
AbstractRegionStoreClient.regionManager |
Modifier and Type | Method and Description |
---|---|
RegionManager |
RegionStoreClient.RegionStoreClientBuilder.getRegionManager() |
Constructor and Description |
---|
AbstractRegionStoreClient(TiConfiguration conf,
TiRegion region,
TiStore store,
ChannelFactory channelFactory,
TikvGrpc.TikvBlockingStub blockingStub,
TikvGrpc.TikvFutureStub asyncStub,
RegionManager regionManager) |
RegionStoreClientBuilder(TiConfiguration conf,
ChannelFactory channelFactory,
RegionManager regionManager,
PDClient pdClient) |
Modifier and Type | Method and Description |
---|---|
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) |
static RangeSplitter |
RangeSplitter.newSplitter(RegionManager mgr) |
Modifier and Type | Method and Description |
---|---|
RegionManager |
TxnKVClient.getRegionManager() |
Modifier and Type | Method and Description |
---|---|
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) |
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) |
Copyright © 2024 PingCAP. All rights reserved.