Package org.apache.cassandra.service.pager

Class PagingState

java.lang.Object

org.apache.cassandra.service.pager.PagingState

public class PagingState
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PagingState.RowMark	Marks the last row returned by paging, the one from which paging should continue.

Field Summary

Fields

Modifier and Type	Field	Description
final ByteBuffer	partitionKey
final int	remaining
final int	remainingInPartition
final PagingState.RowMark	rowMark

Constructor Summary

Constructors

Constructor	Description
PagingState(ByteBuffer partitionKey, PagingState.RowMark rowMark, int remaining, int remainingInPartition)

Method Summary

Modifier and Type	Method	Description
static PagingState	deserialize(ByteBuffer bytes, ProtocolVersion protocolVersion)	It's possible to receive a V3 paging state on a V4 client session, and vice versa - so we cannot blindly rely on the protocol version provided.
final boolean	equals(Object o)
final int	hashCode()
ByteBuffer	serialize(ProtocolVersion protocolVersion)
int	serializedSize(ProtocolVersion protocolVersion)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

partitionKey

public final ByteBuffer partitionKey

rowMark

public final PagingState.RowMark rowMark

remaining

public final int remaining

remainingInPartition

public final int remainingInPartition

Constructor Details

PagingState

public PagingState(ByteBuffer partitionKey,
 PagingState.RowMark rowMark,
 int remaining,
 int remainingInPartition)

Method Details

serialize

public ByteBuffer serialize(ProtocolVersion protocolVersion)

serializedSize

public int serializedSize(ProtocolVersion protocolVersion)

deserialize

public static PagingState deserialize(ByteBuffer bytes,
 ProtocolVersion protocolVersion)

It's possible to receive a V3 paging state on a V4 client session, and vice versa - so we cannot blindly rely on the protocol version provided. We must verify first that the buffer indeed contains a paging state that adheres to the protocol version provided, or, if not - see if it is in a different version, in which case we try the other format.

hashCode

public final int hashCode()

Overrides:

hashCode in class Object

equals

public final boolean equals(Object o)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object