org.tikv.common.operation.iterator

Class CoprocessorIterator<T>

java.lang.Object

org.tikv.common.operation.iterator.CoprocessorIterator<T>

All Implemented Interfaces:

Iterator<T>

Direct Known Subclasses:

DAGIterator

public abstract class CoprocessorIterator<T>
extends Object
implements Iterator<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected int	chunkIndex
protected List<Chunk>	chunkList
protected DAGRequest	dagRequest
protected CodecDataInput	dataInput
protected boolean	eof
protected DataType[]	handleTypes
protected List<RangeSplitter.RegionTask>	regionTasks
protected RowReader	rowReader
protected SchemaInfer	schemaInfer
protected TiSession	session
protected int	taskIndex

Method Summary

Modifier and Type	Method and Description
static CoprocessorIterator<Long>	getHandleIterator(TiDAGRequest req, List<RangeSplitter.RegionTask> regionTasks, TiSession session) Build a DAGIterator from TiDAGRequest and region tasks to get handles
static CoprocessorIterator<Row>	getRowIterator(TiDAGRequest req, List<RangeSplitter.RegionTask> regionTasks, TiSession session) Build a DAGIterator from TiDAGRequest and region tasks to get rows
static CoprocessorIterator<TiChunk>	getTiChunkIterator(TiDAGRequest req, List<RangeSplitter.RegionTask> regionTasks, TiSession session, int numOfRows) Build a DAGIterator from TiDAGRequest and region tasks to get rows

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

session

protected final TiSession session

regionTasks

protected final List<RangeSplitter.RegionTask> regionTasks

dagRequest

protected final DAGRequest dagRequest

handleTypes

protected final DataType[] handleTypes

rowReader

protected RowReader rowReader

dataInput

protected CodecDataInput dataInput

eof

protected boolean eof

taskIndex

protected int taskIndex

chunkIndex

protected int chunkIndex

chunkList

protected List<Chunk> chunkList

schemaInfer

protected SchemaInfer schemaInfer

Method Detail

getRowIterator

public static CoprocessorIterator<Row> getRowIterator(TiDAGRequest req,
                                                      List<RangeSplitter.RegionTask> regionTasks,
                                                      TiSession session)

Build a DAGIterator from TiDAGRequest and region tasks to get rows

When we are preforming a scan request using coveringIndex, IndexScan should be used to read index rows. In other circumstances, TableScan is used to scan table rows.

Parameters:

req - TiDAGRequest built

regionTasks - a list or RegionTask each contains a task on a single region

session - TiSession

Returns:

a DAGIterator to be processed

getTiChunkIterator

public static CoprocessorIterator<TiChunk> getTiChunkIterator(TiDAGRequest req,
                                                              List<RangeSplitter.RegionTask> regionTasks,
                                                              TiSession session,
                                                              int numOfRows)

Build a DAGIterator from TiDAGRequest and region tasks to get rows

When we are preforming a scan request using coveringIndex, IndexScan should be used to read index rows. In other circumstances, TableScan is used to scan table rows.

Parameters:

req - TiDAGRequest built

regionTasks - a list or RegionTask each contains a task on a single region

session - TiSession

Returns:

a DAGIterator to be processed

getHandleIterator

public static CoprocessorIterator<Long> getHandleIterator(TiDAGRequest req,
                                                          List<RangeSplitter.RegionTask> regionTasks,
                                                          TiSession session)

Build a DAGIterator from TiDAGRequest and region tasks to get handles

When we use getHandleIterator, we must be preforming a IndexScan.

Parameters:

req - TiDAGRequest built

regionTasks - a list or RegionTask each contains a task on a single region

session - TiSession

Returns:

a DAGIterator to be processed