com.netflix.astyanax.impl
Class AstyanaxCheckpointManager

java.lang.Object
  com.netflix.astyanax.impl.AstyanaxCheckpointManager

All Implemented Interfaces:

CheckpointManager

public class AstyanaxCheckpointManager
extends java.lang.Object
implements CheckpointManager

Track checkpoints in cassandra

Constructor Summary

AstyanaxCheckpointManager(Keyspace keyspace, java.lang.String columnFamily, java.nio.ByteBuffer bbKey)

AstyanaxCheckpointManager(Keyspace keyspace, java.lang.String columnFamily, java.lang.Long id)

AstyanaxCheckpointManager(Keyspace keyspace, java.lang.String columnFamily, java.lang.String id)

Method Summary

java.lang.String	getCheckpoint(java.lang.String startToken) Get the next checkpoint after the specified token.
java.util.SortedMap<java.lang.String,java.lang.String>	getCheckpoints() Return a sorted map of start tokens to their checkpoint
void	trackCheckpoint(java.lang.String startToken, java.lang.String checkpointToken) Track the checkpoint for a specific range

Methods inherited from class java.lang.Object

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

Constructor Detail

AstyanaxCheckpointManager

public AstyanaxCheckpointManager(Keyspace keyspace,
                                 java.lang.String columnFamily,
                                 java.lang.String id)

AstyanaxCheckpointManager

public AstyanaxCheckpointManager(Keyspace keyspace,
                                 java.lang.String columnFamily,
                                 java.lang.Long id)

AstyanaxCheckpointManager

public AstyanaxCheckpointManager(Keyspace keyspace,
                                 java.lang.String columnFamily,
                                 java.nio.ByteBuffer bbKey)

Method Detail

trackCheckpoint

public void trackCheckpoint(java.lang.String startToken,
                            java.lang.String checkpointToken)
                     throws com.netflix.astyanax.connectionpool.exceptions.ConnectionException

Description copied from interface: CheckpointManager

Track the checkpoint for a specific range

Specified by:

trackCheckpoint in interface CheckpointManager

Throws:

com.netflix.astyanax.connectionpool.exceptions.ConnectionException

getCheckpoint

public java.lang.String getCheckpoint(java.lang.String startToken)
                               throws com.netflix.astyanax.connectionpool.exceptions.ConnectionException

Description copied from interface: CheckpointManager

Get the next checkpoint after the specified token. Will return null if no checkpoint was set.

Specified by:

getCheckpoint in interface CheckpointManager

Throws:

com.netflix.astyanax.connectionpool.exceptions.ConnectionException

getCheckpoints

public java.util.SortedMap<java.lang.String,java.lang.String> getCheckpoints()
                                                                      throws com.netflix.astyanax.connectionpool.exceptions.ConnectionException

Description copied from interface: CheckpointManager

Return a sorted map of start tokens to their checkpoint

Specified by:

getCheckpoints in interface CheckpointManager

Throws:

com.netflix.astyanax.connectionpool.exceptions.ConnectionException