org.springframework.data.redis.core

Class ScanCursor<T>

java.lang.Object

org.springframework.data.redis.core.ScanCursor<T>

Type Parameters:

T -

All Implemented Interfaces:

Closeable, AutoCloseable, Iterator<T>, Cursor<T>

Direct Known Subclasses:

KeyBoundCursor

public abstract class ScanCursor<T>
extends Object
implements Cursor<T>

Redis client agnostic Cursor implementation continuously loading additional results from Redis server until reaching its starting point zero.
Note: Please note that the ScanCursor has to be initialized (open() prior to usage.

Since:

1.4

Constructor Summary

Constructors

Constructor and Description
ScanCursor() Crates new ScanCursor with id=0 and ScanOptions.NONE
ScanCursor(long cursorId) Crates new ScanCursor with ScanOptions.NONE
ScanCursor(long cursorId, ScanOptions options) Crates new ScanCursor
ScanCursor(ScanOptions options) Crates new ScanCursor with id=0.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
protected void	doClose() Customization hook for cleaning up resources on when calling close().
protected void	doOpen(long cursorId) Customization hook when calling open().
protected abstract ScanIteration<T>	doScan(long cursorId, ScanOptions options) Performs the actual scan command using the native client implementation.
long	getCursorId() Get the reference cursor.
long	getPosition()
boolean	hasNext()
boolean	isClosed()
protected boolean	isOpen()
protected boolean	isReady()
protected T	moveNext(Iterator<T> source) Fetch the next item from the underlying Iterable.
T	next()
ScanCursor<T>	open() Initialize the Cursor prior to usage.
void	remove()

Methods inherited from class java.lang.Object

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

Constructor Detail

ScanCursor

public ScanCursor()

Crates new ScanCursor with id=0 and ScanOptions.NONE

ScanCursor

public ScanCursor(ScanOptions options)

Crates new ScanCursor with id=0.

Parameters:

options -

ScanCursor

public ScanCursor(long cursorId)

Crates new ScanCursor with ScanOptions.NONE

Parameters:

cursorId -

ScanCursor

public ScanCursor(long cursorId,
          ScanOptions options)

Crates new ScanCursor

Parameters:

cursorId -

options - Defaulted to ScanOptions.NONE if nulled.

Method Detail

doScan

protected abstract ScanIteration<T> doScan(long cursorId,
                      ScanOptions options)

Performs the actual scan command using the native client implementation. The given options are never null.

Parameters:

cursorId -

options -

Returns:

open

public final ScanCursor<T> open()

Initialize the Cursor prior to usage.

Specified by:

open in interface Cursor<T>

Returns:

doOpen

protected void doOpen(long cursorId)

Customization hook when calling open().

Parameters:

cursorId -

getCursorId

public long getCursorId()

Description copied from interface: Cursor

Get the reference cursor.
NOTE: the id might change while iterating items.

Specified by:

getCursorId in interface Cursor<T>

Returns:

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<T>

next

public T next()

Specified by:

next in interface Iterator<T>

moveNext

protected T moveNext(Iterator<T> source)

Fetch the next item from the underlying Iterable.

Parameters:

source -

Returns:

remove

public void remove()

Specified by:

remove in interface Iterator<T>

close

public final void close()
                 throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

doClose

protected void doClose()

Customization hook for cleaning up resources on when calling close().

isClosed

public boolean isClosed()

Specified by:

isClosed in interface Cursor<T>

Returns:

Returns true if cursor closed.

isReady

protected final boolean isReady()

isOpen

protected final boolean isOpen()

getPosition

public long getPosition()

Specified by:

getPosition in interface Cursor<T>

Returns:

Returns the current position of the cursor.