Package | Description |
---|---|
org.tikv.common | |
org.tikv.common.operation.iterator | |
org.tikv.common.region | |
org.tikv.common.util |
Modifier and Type | Method and Description |
---|---|
Iterator<Long> |
Snapshot.indexHandleRead(TiDAGRequest dagRequest,
List<RangeSplitter.RegionTask> tasks)
Below is lower level API for env like Spark which already did key range split Perform handle
scan
|
Iterator<TiChunk> |
Snapshot.tableReadChunk(TiDAGRequest dagRequest,
List<RangeSplitter.RegionTask> tasks,
int numOfRows) |
Modifier and Type | Field and Description |
---|---|
protected List<RangeSplitter.RegionTask> |
CoprocessorIterator.regionTasks |
Modifier and Type | Method and Description |
---|---|
static CoprocessorIterator<Long> |
CoprocessorIterator.getHandleIterator(TiDAGRequest req,
List<RangeSplitter.RegionTask> regionTasks,
TiSession session)
Build a DAGIterator from TiDAGRequest and region tasks to get handles
|
static CoprocessorIterator<Row> |
CoprocessorIterator.getRowIterator(TiDAGRequest req,
List<RangeSplitter.RegionTask> regionTasks,
TiSession session)
Build a DAGIterator from TiDAGRequest and region tasks to get rows
|
static CoprocessorIterator<TiChunk> |
CoprocessorIterator.getTiChunkIterator(TiDAGRequest req,
List<RangeSplitter.RegionTask> regionTasks,
TiSession session,
int numOfRows)
Build a DAGIterator from TiDAGRequest and region tasks to get rows
|
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.
|
Modifier and Type | Method and Description |
---|---|
static RangeSplitter.RegionTask |
RangeSplitter.RegionTask.newInstance(TiRegion region,
TiStore store,
List<Coprocessor.KeyRange> ranges) |
Modifier and Type | Method and Description |
---|---|
List<RangeSplitter.RegionTask> |
RangeSplitter.splitAndSortHandlesByRegion(List<Long> ids,
gnu.trove.list.array.TLongArrayList handles) |
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
|
Copyright © 2024 PingCAP. All rights reserved.