Package org.tikv.common.operation.iterator

Class ScanIterator

java.lang.Object

org.tikv.common.operation.iterator.ScanIterator

All Implemented Interfaces:

Iterator<org.tikv.kvproto.Kvrpcpb.KvPair>

public abstract class ScanIterator
extends Object
implements Iterator<org.tikv.kvproto.Kvrpcpb.KvPair>

Copied from https://github.com/tikv/client-java project to fix https://github.com/tikv/client-java/issues/600 for 3.2.0 version.

Line 107 : Use `currentCache.size() > scanLimit` instead of `currentCache.size() > limit`.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.tikv.common.region.RegionStoreClient.RegionStoreClientBuilder	builder
protected org.tikv.common.TiConfiguration	conf
protected List<org.tikv.kvproto.Kvrpcpb.KvPair>	currentCache
protected org.tikv.common.key.Key	endKey
protected boolean	endOfScan
protected boolean	hasEndKey
protected int	index
protected boolean	keyOnly
protected int	limit
protected boolean	processingLastBatch
protected org.tikv.shade.com.google.protobuf.ByteString	startKey

Method Summary

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, hasNext, next, remove

Field Detail

conf

protected final org.tikv.common.TiConfiguration conf

builder

protected final org.tikv.common.region.RegionStoreClient.RegionStoreClientBuilder builder

currentCache

protected List<org.tikv.kvproto.Kvrpcpb.KvPair> currentCache

startKey

protected org.tikv.shade.com.google.protobuf.ByteString startKey

index

protected int index

limit

protected int limit

keyOnly

protected boolean keyOnly

endOfScan

protected boolean endOfScan

endKey

protected org.tikv.common.key.Key endKey

hasEndKey

protected boolean hasEndKey

processingLastBatch

protected boolean processingLastBatch