com.datastax.driver.core

Class ThreadLocalMonotonicTimestampGenerator

java.lang.Object

com.datastax.driver.core.ThreadLocalMonotonicTimestampGenerator

All Implemented Interfaces:

TimestampGenerator

public class ThreadLocalMonotonicTimestampGenerator
extends Object

A timestamp generator based on System.currentTimeMillis(), with an incrementing thread-local counter to generate the sub-millisecond part.

This implementation guarantees incrementing timestamps for a given client thread, provided that no more than 1000 are requested for a given clock tick (the exact granularity of of System.currentTimeMillis() depends on the operating system).

If that rate is exceeded, a warning is logged and the timestamps don't increment anymore until the next clock tick.

Constructor Summary

Constructors

Constructor and Description
ThreadLocalMonotonicTimestampGenerator()

Method Summary

Modifier and Type	Method and Description
protected long	computeNext(long last)
long	next() Returns the next timestamp.

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadLocalMonotonicTimestampGenerator

public ThreadLocalMonotonicTimestampGenerator()

Method Detail

next

public long next()

Description copied from interface: TimestampGenerator

Returns the next timestamp.

Returns:

the next timestamp (in microseconds). If it equals Long.MIN_VALUE, it won't be sent by the driver, letting Cassandra generate a server-side timestamp.

computeNext

protected long computeNext(long last)