io.picodata.driver.api.cursor

Class OffsetCursor<T extends Packable,R extends Collection<T>>

java.lang.Object

io.picodata.driver.api.cursor.TarantoolCursorBase<T,R>

io.picodata.driver.api.cursor.OffsetCursor<T,R>

All Implemented Interfaces:

TarantoolCursor<T>

public class OffsetCursor<T extends Packable,R extends Collection<T>>
extends TarantoolCursorBase<T,R>

Cursor implementation that uses server 'limit' and 'offset' methods under the hood.

Note: it is possible to use this class with standalone server only.

See TarantoolCursor for more details on cursors.

Constructor Summary

Constructors

Constructor and Description
OffsetCursor(TarantoolSpaceOperations<T,R> space, Conditions conditions, int batchSize)

Method Summary

Modifier and Type	Method and Description
protected boolean	advanceIterator()
protected void	fetchNextTuples() Perform a call o server for fetching the next batch.
protected T	getCurrentValue()

Methods inherited from class io.picodata.driver.api.cursor.TarantoolCursorBase

calcLimit, get, next

Methods inherited from class java.lang.Object

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

Constructor Detail

OffsetCursor

public OffsetCursor(TarantoolSpaceOperations<T,R> space,
                    Conditions conditions,
                    int batchSize)

Method Detail

fetchNextTuples

protected void fetchNextTuples()
                        throws TarantoolClientException

Perform a call o server for fetching the next batch.

Specified by:

fetchNextTuples in class TarantoolCursorBase<T extends Packable,R extends Collection<T>>

Throws:

TarantoolClientException - if select query was interrupted by client.

advanceIterator

protected boolean advanceIterator()

Specified by:

advanceIterator in class TarantoolCursorBase<T extends Packable,R extends Collection<T>>

getCurrentValue

protected T getCurrentValue()

Specified by:

getCurrentValue in class TarantoolCursorBase<T extends Packable,R extends Collection<T>>