public class AbsentStreamPreStateProcessor extends StreamPreStateProcessor implements AbsentPreStateProcessor
eventTimeComparator, isStartState, lock, nextProcessor, siddhiQueryContext, startStateIds, stateEventCloner, stateEventFactory, stateHolder, stateId, stateType, streamEventCloner, streamEventFactory, thisLastProcessor, thisStatePostProcessor, withinEveryPreStateProcessor, withinTime
Constructor and Description |
---|
AbsentStreamPreStateProcessor(io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType,
long waitingTime)
Construct an AbsentStreamPreStateProcessor object.
|
Modifier and Type | Method and Description |
---|---|
void |
addEveryState(StateEvent stateEvent) |
protected void |
addState(StateEvent stateEvent,
io.siddhi.core.query.input.stream.state.StreamPreStateProcessor.StreamPreState preState) |
Scheduler |
getScheduler() |
void |
init(SiddhiQueryContext siddhiQueryContext) |
void |
partitionCreated()
Get called when partition is created
|
void |
process(ComplexEventChunk complexEventChunk)
Process the handed StreamEvent
|
void |
process(List<ComplexEventChunk> complexEventChunks)
Process the handed StreamEvent
|
ComplexEventChunk<StateEvent> |
processAndReturn(ComplexEventChunk complexEventChunk) |
protected boolean |
removeOnNoStateChange(io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType) |
void |
resetState() |
void |
setScheduler(Scheduler scheduler) |
void |
updateLastArrivalTime(long timestamp)
Update the timestamp of the event arrived to this processor and met the filter conditions.
|
addState, expireEvents, getNextProcessor, getPendingStateEventList, getStateId, getThisLastProcessor, getThisStatePostProcessor, init, isExpired, isStartState, process, setNextProcessor, setStartState, setStartStateIds, setStateEventCloner, setStateEventFactory, setStateId, setStreamEventCloner, setStreamEventFactory, setThisLastProcessor, setThisStatePostProcessor, setToLast, setWithinEveryPreStateProcessor, setWithinTime, stateChanged, updateState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getNextProcessor, setNextProcessor, setToLast
public AbsentStreamPreStateProcessor(io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType, long waitingTime)
stateType
- PATTERN or SEQUENCEwaitingTime
- the waiting time defined by 'for' keywordpublic void init(SiddhiQueryContext siddhiQueryContext)
init
in class StreamPreStateProcessor
public void updateLastArrivalTime(long timestamp)
AbsentPreStateProcessor
updateLastArrivalTime
in interface AbsentPreStateProcessor
timestamp
- the timestamp if the eventprotected void addState(StateEvent stateEvent, io.siddhi.core.query.input.stream.state.StreamPreStateProcessor.StreamPreState preState)
addState
in class StreamPreStateProcessor
public void addEveryState(StateEvent stateEvent)
addEveryState
in interface PreStateProcessor
addEveryState
in class StreamPreStateProcessor
public void resetState()
resetState
in interface PreStateProcessor
resetState
in class StreamPreStateProcessor
public void process(ComplexEventChunk complexEventChunk)
StreamPreStateProcessor
process
in interface Processor
process
in class StreamPreStateProcessor
complexEventChunk
- event chunk to be processedpublic void process(List<ComplexEventChunk> complexEventChunks)
Processor
process
in interface Processor
process
in class StreamPreStateProcessor
complexEventChunks
- event chunks to be processedpublic ComplexEventChunk<StateEvent> processAndReturn(ComplexEventChunk complexEventChunk)
processAndReturn
in interface PreStateProcessor
processAndReturn
in class StreamPreStateProcessor
protected boolean removeOnNoStateChange(io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType)
removeOnNoStateChange
in class StreamPreStateProcessor
public Scheduler getScheduler()
getScheduler
in interface SchedulingProcessor
public void setScheduler(Scheduler scheduler)
setScheduler
in interface SchedulingProcessor
public void partitionCreated()
PartitionCreationListener
partitionCreated
in interface PartitionCreationListener
Copyright © 2021. All rights reserved.