public class AbsentLogicalPreStateProcessor extends LogicalPreStateProcessor implements AbsentPreStateProcessor
logicalType, partnerStatePreProcessor
isStartState, lock, nextProcessor, siddhiQueryContext, startStateIds, stateEventCloner, stateEventFactory, stateHolder, stateId, stateType, streamEventCloner, streamEventFactory, thisLastProcessor, thisStatePostProcessor, withinEveryPreStateProcessor, withinTime
Constructor and Description |
---|
AbsentLogicalPreStateProcessor(io.siddhi.query.api.execution.query.input.state.LogicalStateElement.Type type,
io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType,
io.siddhi.query.api.expression.constant.TimeConstant waitingTime) |
Modifier and Type | Method and Description |
---|---|
void |
addEveryState(StateEvent stateEvent) |
protected void |
addState(StateEvent stateEvent,
io.siddhi.core.query.input.stream.state.StreamPreStateProcessor.StreamPreState state) |
Scheduler |
getScheduler() |
void |
init(SiddhiQueryContext siddhiQueryContext) |
void |
partitionCreated()
Get called when partition is created
|
boolean |
partnerCanProceed(StateEvent stateEvent) |
void |
process(ComplexEventChunk complexEventChunk)
Process the handed StreamEvent
|
ComplexEventChunk<StateEvent> |
processAndReturn(ComplexEventChunk complexEventChunk) |
void |
setScheduler(Scheduler scheduler) |
void |
updateLastArrivalTime(long timestamp)
Update the timestamp of the event arrived to this processor and met the filter conditions.
|
addEventToNewAndEveryStateEventList, isNewAndEveryStateEventListEmpty, moveAllNewAndEveryStateEventListEventsToPendingStateEventList, resetState, setPartnerStatePreProcessor, updateState
addState, getNextProcessor, getPendingStateEventList, getStateId, getThisLastProcessor, getThisStatePostProcessor, init, isExpired, isStartState, process, removeOnNoStateChange, setNextProcessor, setStartState, setStartStateIds, setStateEventCloner, setStateEventFactory, setStateId, setStreamEventCloner, setStreamEventFactory, setThisLastProcessor, setThisStatePostProcessor, setToLast, setWithinEveryPreStateProcessor, setWithinTime, stateChanged
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getNextProcessor, setNextProcessor, setToLast
public AbsentLogicalPreStateProcessor(io.siddhi.query.api.execution.query.input.state.LogicalStateElement.Type type, io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType, io.siddhi.query.api.expression.constant.TimeConstant waitingTime)
public 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 state)
addState
in class LogicalPreStateProcessor
public void addEveryState(StateEvent stateEvent)
addEveryState
in interface PreStateProcessor
addEveryState
in class LogicalPreStateProcessor
public void process(ComplexEventChunk complexEventChunk)
StreamPreStateProcessor
process
in interface Processor
process
in class StreamPreStateProcessor
complexEventChunk
- event chunk to be processedpublic ComplexEventChunk<StateEvent> processAndReturn(ComplexEventChunk complexEventChunk)
processAndReturn
in interface PreStateProcessor
processAndReturn
in class LogicalPreStateProcessor
public Scheduler getScheduler()
getScheduler
in interface SchedulingProcessor
public void setScheduler(Scheduler scheduler)
setScheduler
in interface SchedulingProcessor
public void partitionCreated()
PartitionCreationListener
partitionCreated
in interface PartitionCreationListener
public boolean partnerCanProceed(StateEvent stateEvent)
Copyright © 2019. All rights reserved.