org.tikv.common

Class Snapshot

java.lang.Object

org.tikv.common.Snapshot

public class Snapshot
extends Object

Constructor Summary

Constructors

Constructor and Description
Snapshot(TiTimestamp timestamp, TiSession session)

Method Summary

Modifier and Type	Method and Description
List<BytePairWrapper>	batchGet(int backOffer, List<byte[]> keys)
byte[]	get(byte[] key)
com.google.protobuf.ByteString	get(com.google.protobuf.ByteString key)
TiConfiguration	getConf()
TiSession	getSession()
TiTimestamp	getTimestamp()
long	getVersion()
Iterator<Long>	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<Kvrpcpb.KvPair>	scan(com.google.protobuf.ByteString startKey) scan all keys after startKey, inclusive
Iterator<Kvrpcpb.KvPair>	scanPrefix(com.google.protobuf.ByteString prefix) scan all keys with prefix
Iterator<TiChunk>	tableReadChunk(TiDAGRequest dagRequest, List<RangeSplitter.RegionTask> tasks, int numOfRows)
Iterator<Row>	tableReadRow(TiDAGRequest dagRequest, long physicalId) Issue a table read request

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Snapshot

public Snapshot(@Nonnull
                TiTimestamp timestamp,
                TiSession session)

Method Detail

getSession

public TiSession getSession()

getVersion

public long getVersion()

getTimestamp

public TiTimestamp getTimestamp()

get

public byte[] get(byte[] key)

get

public com.google.protobuf.ByteString get(com.google.protobuf.ByteString key)

batchGet

public List<BytePairWrapper> batchGet(int backOffer,
                                      List<byte[]> keys)

tableReadChunk

public Iterator<TiChunk> tableReadChunk(TiDAGRequest dagRequest,
                                        List<RangeSplitter.RegionTask> tasks,
                                        int numOfRows)

tableReadRow

public Iterator<Row> tableReadRow(TiDAGRequest dagRequest,
                                  long physicalId)

Issue a table read request

Parameters:

dagRequest - DAG request for coprocessor

Returns:

a Iterator that contains all result from this select request.

indexHandleRead

public Iterator<Long> 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

Parameters:

dagRequest - DAGRequest for coprocessor

tasks - RegionTask of the coprocessor request to send

Returns:

Row iterator to iterate over resulting rows

scan

public Iterator<Kvrpcpb.KvPair> scan(com.google.protobuf.ByteString startKey)

scan all keys after startKey, inclusive

Parameters:

startKey - start of keys

Returns:

iterator of kvPair

scanPrefix

public Iterator<Kvrpcpb.KvPair> scanPrefix(com.google.protobuf.ByteString prefix)

scan all keys with prefix

Parameters:

prefix - prefix of keys

Returns:

iterator of kvPair

getConf

public TiConfiguration getConf()