org.apache.omid.tso

Class WorldClockOracleImpl

java.lang.Object

org.apache.omid.tso.WorldClockOracleImpl

All Implemented Interfaces:

TimestampOracle

@Singleton
public class WorldClockOracleImpl
extends Object
implements TimestampOracle

The Timestamp Oracle that gives monotonically increasing timestamps based on world time

Constructor Summary

Constructors

Constructor and Description
WorldClockOracleImpl(MetricsRegistry metrics, TimestampStorage tsStorage, Panicker panicker)

Method Summary

Methods

Modifier and Type	Method and Description
long	getLast() Returns the last timestamp assigned.
void	initialize() Allows the initialization of the Timestamp Oracle service.
long	next() Returns the next timestamp if available.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

WorldClockOracleImpl

@Inject
public WorldClockOracleImpl(MetricsRegistry metrics,
                           TimestampStorage tsStorage,
                           Panicker panicker)
                     throws IOException

Throws:

IOException

Method Detail

initialize

public void initialize()
                throws IOException

Description copied from interface: TimestampOracle

Allows the initialization of the Timestamp Oracle service.

Specified by:

initialize in interface TimestampOracle

Throws:

IOException - raised if a problem during initialization is shown.

next

public long next()

Returns the next timestamp if available. Otherwise spins till the ts-persist thread allocates a new timestamp.

Specified by:

next in interface TimestampOracle

getLast

public long getLast()

Description copied from interface: TimestampOracle

Returns the last timestamp assigned.

Specified by:

getLast in interface TimestampOracle

toString

public String toString()

Overrides:

toString in class Object