public class Scheduler extends Object implements ExternalReferencedHolder
Constructor and Description |
---|
Scheduler(Schedulable singleThreadEntryValve,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
void |
init(LockWrapper lockWrapper,
String queryName) |
void |
notifyAt(long time) |
void |
schedule(long time,
io.siddhi.core.util.Scheduler.SchedulerState state) |
protected void |
sendTimerEvents(io.siddhi.core.util.Scheduler.SchedulerState state)
Go through the timestamps stored in the toNotifyQueue and send the TIMER events for the expired events.
|
void |
setLatencyTracker(LatencyTracker latencyTracker) |
void |
setStreamEventFactory(StreamEventFactory streamEventFactory) |
void |
start()
This will be called only once and this can be used to acquire
required resources for the processing element.
|
void |
stop()
This will be called only once and this can be used to release
the acquired resources for processing.
|
void |
switchToLiveMode()
Schedule events which are not scheduled in the queue when switching back from event time to system current time
|
void |
switchToPlayBackMode()
this can be used to release
the acquired resources for processing.
|
protected String queryName
public Scheduler(Schedulable singleThreadEntryValve, SiddhiQueryContext siddhiQueryContext)
public void init(LockWrapper lockWrapper, String queryName)
public void notifyAt(long time)
public void schedule(long time, io.siddhi.core.util.Scheduler.SchedulerState state)
public void setStreamEventFactory(StreamEventFactory streamEventFactory)
public void setLatencyTracker(LatencyTracker latencyTracker)
protected void sendTimerEvents(io.siddhi.core.util.Scheduler.SchedulerState state)
state
- current statepublic void switchToLiveMode()
public void switchToPlayBackMode()
public void stop()
ExternalReferencedHolder
stop
in interface ExternalReferencedHolder
public void start()
ExternalReferencedHolder
start
in interface ExternalReferencedHolder
Copyright © 2019. All rights reserved.