org.graphstream.stream.sync

Class SinkTime

java.lang.Object

org.graphstream.stream.sync.SinkTime

public class SinkTime
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static boolean	disableSync Flag used to disable sync.
static java.lang.String	SYNC_DISABLE_KEY Key used to disable synchro.
protected java.util.HashMap<java.lang.String,java.lang.Long>	times Map storing times of sources.

Constructor Summary

Constructors

Constructor and Description
SinkTime()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isNewEvent(java.lang.String sourceId, long timeId) Allow to know if event is new for this source.
protected boolean	setTimeFor(java.lang.String sourceId, long timeId) Update timeId for a source.

Methods inherited from class java.lang.Object

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

Field Detail

SYNC_DISABLE_KEY

public static final java.lang.String SYNC_DISABLE_KEY

Key used to disable synchro. Just run : java -DSYNC_DISABLE_KEY ...

See Also:

Constant Field Values

disableSync

protected static final boolean disableSync

Flag used to disable sync.

times

protected java.util.HashMap<java.lang.String,java.lang.Long> times

Map storing times of sources.

Constructor Detail

SinkTime

public SinkTime()

Method Detail

setTimeFor

protected boolean setTimeFor(java.lang.String sourceId,
                 long timeId)

Update timeId for a source.

Parameters:

sourceId -

timeId -

Returns:

true if time has been updated

isNewEvent

public boolean isNewEvent(java.lang.String sourceId,
                 long timeId)

Allow to know if event is new for this source. This updates the timeId mapped to the source.

Parameters:

sourceId -

timeId -

Returns:

true if event is new for the source