public class SinkTime
extends java.lang.Object
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 and Description |
---|
SinkTime() |
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.
|
public static final java.lang.String SYNC_DISABLE_KEY
protected static final boolean disableSync
protected java.util.HashMap<java.lang.String,java.lang.Long> times
protected boolean setTimeFor(java.lang.String sourceId, long timeId)
sourceId
- timeId
- public boolean isNewEvent(java.lang.String sourceId, long timeId)
sourceId
- timeId
-