com.netflix.astyanax.shallows
Class EmptyCheckpointManager

java.lang.Object
  com.netflix.astyanax.shallows.EmptyCheckpointManager

All Implemented Interfaces:

CheckpointManager

public class EmptyCheckpointManager
extends java.lang.Object
implements CheckpointManager

Constructor Summary

EmptyCheckpointManager()

Method Summary

java.lang.String	getCheckpoint(java.lang.String startToken) Since no checkpoint management is done here simply use the startToken as the start checkpoint for the range
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) Do nothing since checkpoints aren't being persisted.

Methods inherited from class java.lang.Object

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

Constructor Detail

EmptyCheckpointManager

public EmptyCheckpointManager()

Method Detail

trackCheckpoint

public void trackCheckpoint(java.lang.String startToken,
                            java.lang.String checkpointToken)

Do nothing since checkpoints aren't being persisted.

Specified by:

trackCheckpoint in interface CheckpointManager

getCheckpoint

public java.lang.String getCheckpoint(java.lang.String startToken)

Since no checkpoint management is done here simply use the startToken as the start checkpoint for the range

Specified by:

getCheckpoint in interface CheckpointManager

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