io.picodata.driver.api.cursor

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

java.lang.Object

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

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

All Implemented Interfaces:

TarantoolCursor<T>

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

Cursor implementation that uses 'cluster' select method under the hood. Designed to work with cluster client.

See TarantoolCursor for more details on cursors.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected boolean	advanceIterator()
protected void	fetchNextTuples()
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

StartAfterCursor

public StartAfterCursor(TarantoolSpaceOperations<T,R> space,
                        Conditions conditions,
                        int batchSize,
                        MessagePackMapper mapper)

Method Detail

fetchNextTuples

protected void fetchNextTuples()
                        throws TarantoolClientException

Specified by:

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

Throws:

TarantoolClientException

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>>