Package | Description |
---|---|
org.tikv.common.codec | |
org.tikv.common.key | |
org.tikv.common.meta | |
org.tikv.common.predicates | |
org.tikv.common.region | |
org.tikv.common.util | |
org.tikv.kvproto |
Modifier and Type | Method and Description |
---|---|
static String |
KeyUtils.formatBytes(Coprocessor.KeyRange keyRange) |
static String |
KeyUtils.formatBytesUTF8(Coprocessor.KeyRange keyRange) |
Modifier and Type | Method and Description |
---|---|
Coprocessor.KeyRange |
IndexScanKeyRangeBuilder.compute() |
Modifier and Type | Method and Description |
---|---|
List<Coprocessor.KeyRange> |
TiDAGRequest.getRangesByPhysicalId(long physicalId) |
Map<Long,List<Coprocessor.KeyRange>> |
TiDAGRequest.getRangesMaps() |
Modifier and Type | Method and Description |
---|---|
TiDAGRequest |
TiDAGRequest.addRanges(Map<Long,List<Coprocessor.KeyRange>> ranges)
set key range of scan
|
Modifier and Type | Method and Description |
---|---|
Map<Long,List<Coprocessor.KeyRange>> |
TiKVScanAnalyzer.TiKVScanPlan.getKeyRanges() |
Modifier and Type | Method and Description |
---|---|
TiKVScanAnalyzer.TiKVScanPlan.Builder |
TiKVScanAnalyzer.TiKVScanPlan.Builder.setKeyRanges(Map<Long,List<Coprocessor.KeyRange>> keyRanges) |
Modifier and Type | Method and Description |
---|---|
List<RangeSplitter.RegionTask> |
RegionStoreClient.coprocess(BackOffer backOffer,
DAGRequest req,
List<Coprocessor.KeyRange> ranges,
Queue<SelectResponse> responseQueue,
long startTs)
Execute and retrieve the response from TiKV server.
|
Iterator<SelectResponse> |
RegionStoreClient.coprocessStreaming(DAGRequest req,
List<Coprocessor.KeyRange> ranges,
long startTs) |
Modifier and Type | Method and Description |
---|---|
static Coprocessor.KeyRange |
KeyRangeUtils.makeCoprocRange(com.google.protobuf.ByteString startKey,
com.google.protobuf.ByteString endKey)
Build a Coprocessor Range with CLOSED_OPEN endpoints
|
static Coprocessor.KeyRange |
KeyRangeUtils.makeCoprocRange(com.google.common.collect.Range<Key> range)
Build a Coprocessor Range
|
Modifier and Type | Method and Description |
---|---|
List<Coprocessor.KeyRange> |
RangeSplitter.RegionTask.getRanges() |
static List<Coprocessor.KeyRange> |
KeyRangeUtils.mergeRanges(List<Coprocessor.KeyRange> ranges)
Merge potential discrete ranges into one large range.
|
static List<Coprocessor.KeyRange> |
KeyRangeUtils.mergeSortedRanges(List<Coprocessor.KeyRange> ranges)
Merge SORTED potential discrete ranges into one large range.
|
static List<Coprocessor.KeyRange> |
KeyRangeUtils.mergeSortedRanges(List<Coprocessor.KeyRange> ranges,
int splitNum)
Merge SORTED potential discrete ranges into no more than
splitNum large range. |
Modifier and Type | Method and Description |
---|---|
static List<Coprocessor.KeyRange> |
KeyRangeUtils.mergeRanges(List<Coprocessor.KeyRange> ranges)
Merge potential discrete ranges into one large range.
|
static List<Coprocessor.KeyRange> |
KeyRangeUtils.mergeSortedRanges(List<Coprocessor.KeyRange> ranges)
Merge SORTED potential discrete ranges into one large range.
|
static List<Coprocessor.KeyRange> |
KeyRangeUtils.mergeSortedRanges(List<Coprocessor.KeyRange> ranges,
int splitNum)
Merge SORTED potential discrete ranges into no more than
splitNum large range. |
static RangeSplitter.RegionTask |
RangeSplitter.RegionTask.newInstance(TiRegion region,
TiStore store,
List<Coprocessor.KeyRange> ranges) |
List<RangeSplitter.RegionTask> |
RangeSplitter.splitRangeByRegion(List<Coprocessor.KeyRange> keyRanges)
Split key ranges into corresponding region tasks and group by their region id
|
List<RangeSplitter.RegionTask> |
RangeSplitter.splitRangeByRegion(List<Coprocessor.KeyRange> keyRanges,
TiStoreType storeType)
Split key ranges into corresponding region tasks and group by their region id
|
Modifier and Type | Method and Description |
---|---|
Coprocessor.KeyRange |
Coprocessor.KeyRange.Builder.build() |
Coprocessor.KeyRange |
Coprocessor.KeyRange.Builder.buildPartial() |
static Coprocessor.KeyRange |
Coprocessor.KeyRange.getDefaultInstance() |
Coprocessor.KeyRange |
Coprocessor.KeyRange.getDefaultInstanceForType() |
Coprocessor.KeyRange |
Coprocessor.KeyRange.Builder.getDefaultInstanceForType() |
Coprocessor.KeyRange |
Coprocessor.ResponseOrBuilder.getRange()
.coprocessor.KeyRange range = 5; |
Coprocessor.KeyRange |
Coprocessor.Response.getRange()
.coprocessor.KeyRange range = 5; |
Coprocessor.KeyRange |
Coprocessor.Response.Builder.getRange()
.coprocessor.KeyRange range = 5; |
Coprocessor.KeyRange |
Coprocessor.RequestOrBuilder.getRanges(int index)
repeated .coprocessor.KeyRange ranges = 4; |
Coprocessor.KeyRange |
Coprocessor.Request.getRanges(int index)
repeated .coprocessor.KeyRange ranges = 4; |
Coprocessor.KeyRange |
Coprocessor.Request.Builder.getRanges(int index)
repeated .coprocessor.KeyRange ranges = 4; |
Coprocessor.KeyRange |
Coprocessor.RegionInfoOrBuilder.getRanges(int index)
repeated .coprocessor.KeyRange ranges = 3; |
Coprocessor.KeyRange |
Coprocessor.RegionInfo.getRanges(int index)
repeated .coprocessor.KeyRange ranges = 3; |
Coprocessor.KeyRange |
Coprocessor.RegionInfo.Builder.getRanges(int index)
repeated .coprocessor.KeyRange ranges = 3; |
static Coprocessor.KeyRange |
Coprocessor.KeyRange.parseDelimitedFrom(InputStream input) |
static Coprocessor.KeyRange |
Coprocessor.KeyRange.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Coprocessor.KeyRange |
Coprocessor.KeyRange.parseFrom(byte[] data) |
static Coprocessor.KeyRange |
Coprocessor.KeyRange.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Coprocessor.KeyRange |
Coprocessor.KeyRange.parseFrom(ByteBuffer data) |
static Coprocessor.KeyRange |
Coprocessor.KeyRange.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Coprocessor.KeyRange |
Coprocessor.KeyRange.parseFrom(com.google.protobuf.ByteString data) |
static Coprocessor.KeyRange |
Coprocessor.KeyRange.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Coprocessor.KeyRange |
Coprocessor.KeyRange.parseFrom(com.google.protobuf.CodedInputStream input) |
static Coprocessor.KeyRange |
Coprocessor.KeyRange.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Coprocessor.KeyRange |
Coprocessor.KeyRange.parseFrom(InputStream input) |
static Coprocessor.KeyRange |
Coprocessor.KeyRange.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<Coprocessor.KeyRange> |
Coprocessor.KeyRange.getParserForType() |
List<Coprocessor.KeyRange> |
Coprocessor.RequestOrBuilder.getRangesList()
repeated .coprocessor.KeyRange ranges = 4; |
List<Coprocessor.KeyRange> |
Coprocessor.Request.getRangesList()
repeated .coprocessor.KeyRange ranges = 4; |
List<Coprocessor.KeyRange> |
Coprocessor.Request.Builder.getRangesList()
repeated .coprocessor.KeyRange ranges = 4; |
List<Coprocessor.KeyRange> |
Coprocessor.RegionInfoOrBuilder.getRangesList()
repeated .coprocessor.KeyRange ranges = 3; |
List<Coprocessor.KeyRange> |
Coprocessor.RegionInfo.getRangesList()
repeated .coprocessor.KeyRange ranges = 3; |
List<Coprocessor.KeyRange> |
Coprocessor.RegionInfo.Builder.getRangesList()
repeated .coprocessor.KeyRange ranges = 3; |
static com.google.protobuf.Parser<Coprocessor.KeyRange> |
Coprocessor.KeyRange.parser() |
Modifier and Type | Method and Description |
---|---|
Coprocessor.Request.Builder |
Coprocessor.Request.Builder.addRanges(Coprocessor.KeyRange value)
repeated .coprocessor.KeyRange ranges = 4; |
Coprocessor.RegionInfo.Builder |
Coprocessor.RegionInfo.Builder.addRanges(Coprocessor.KeyRange value)
repeated .coprocessor.KeyRange ranges = 3; |
Coprocessor.Request.Builder |
Coprocessor.Request.Builder.addRanges(int index,
Coprocessor.KeyRange value)
repeated .coprocessor.KeyRange ranges = 4; |
Coprocessor.RegionInfo.Builder |
Coprocessor.RegionInfo.Builder.addRanges(int index,
Coprocessor.KeyRange value)
repeated .coprocessor.KeyRange ranges = 3; |
Coprocessor.KeyRange.Builder |
Coprocessor.KeyRange.Builder.mergeFrom(Coprocessor.KeyRange other) |
Coprocessor.Response.Builder |
Coprocessor.Response.Builder.mergeRange(Coprocessor.KeyRange value)
.coprocessor.KeyRange range = 5; |
static Coprocessor.KeyRange.Builder |
Coprocessor.KeyRange.newBuilder(Coprocessor.KeyRange prototype) |
Coprocessor.Response.Builder |
Coprocessor.Response.Builder.setRange(Coprocessor.KeyRange value)
.coprocessor.KeyRange range = 5; |
Coprocessor.Request.Builder |
Coprocessor.Request.Builder.setRanges(int index,
Coprocessor.KeyRange value)
repeated .coprocessor.KeyRange ranges = 4; |
Coprocessor.RegionInfo.Builder |
Coprocessor.RegionInfo.Builder.setRanges(int index,
Coprocessor.KeyRange value)
repeated .coprocessor.KeyRange ranges = 3; |
Modifier and Type | Method and Description |
---|---|
Coprocessor.Request.Builder |
Coprocessor.Request.Builder.addAllRanges(Iterable<? extends Coprocessor.KeyRange> values)
repeated .coprocessor.KeyRange ranges = 4; |
Coprocessor.RegionInfo.Builder |
Coprocessor.RegionInfo.Builder.addAllRanges(Iterable<? extends Coprocessor.KeyRange> values)
repeated .coprocessor.KeyRange ranges = 3; |
Copyright © 2024 PingCAP. All rights reserved.