Package org.apache.beam.sdk.io.redis

Class RedisCursor

java.lang.Object

org.apache.beam.sdk.io.redis.RedisCursor

All Implemented Interfaces:

Serializable, Comparable<RedisCursor>

public class RedisCursor
extends Object
implements Comparable<RedisCursor>, Serializable

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final RedisCursor	END_CURSOR
static final RedisCursor	ZERO_CURSOR
static final ByteKey	ZERO_KEY

Method Summary

Modifier and Type	Method	Description
int	compareTo(RedisCursor other)	RedisCursor implements Comparable<RedisCursor> by transforming the cursors to an index of the Redis table.
boolean	equals(@Nullable Object o)
String	getCursor()
long	getDbSize()
int	hashCode()
boolean	isStart()
static RedisCursor	of(String cursor, long dbSize, boolean isStart)

Methods inherited from class java.lang.Object

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

Field Details

ZERO_KEY

public static final ByteKey ZERO_KEY

ZERO_CURSOR

public static final RedisCursor ZERO_CURSOR

END_CURSOR

public static final RedisCursor END_CURSOR

Method Details

of

public static RedisCursor of(String cursor,
 long dbSize,
 boolean isStart)

compareTo

public int compareTo(@Nonnull
 RedisCursor other)

RedisCursor implements Comparable<RedisCursor> by transforming the cursors to an index of the Redis table.

Specified by:

compareTo in interface Comparable<RedisCursor>

equals

public boolean equals(@Nullable Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getCursor

public String getCursor()

getDbSize

public long getDbSize()

isStart

public boolean isStart()