Java源码示例:org.apache.phoenix.iterate.LookAheadResultIterator

示例1
@Override
public ResultIterator iterator(ParallelScanGrouper scanGrouper, Scan scan) throws SQLException {
	StatementContext context = delegate.getContext();
	if (resultIterator == null) {
		context.getOverallQueryMetrics().startQuery();
		resultIterator = new CursorResultIterator(LookAheadResultIterator.wrap(delegate.iterator(scanGrouper, scan)),cursorName);
	}
    return resultIterator;
}