com.datastax.driver.core

Class AtomicMonotonicTimestampGenerator

java.lang.Object

com.datastax.driver.core.AtomicMonotonicTimestampGenerator

All Implemented Interfaces:

TimestampGenerator

public class AtomicMonotonicTimestampGenerator
extends Object

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

This implementation guarantees incrementing timestamps among all client threads, 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. If you consistently exceed that rate, consider using ThreadLocalMonotonicTimestampGenerator.

Constructor Summary

Constructors

Constructor and Description
AtomicMonotonicTimestampGenerator()

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

AtomicMonotonicTimestampGenerator

public AtomicMonotonicTimestampGenerator()

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)