public class CountPreStateProcessor extends StreamPreStateProcessor
eventTimeComparator, isStartState, lock, nextProcessor, siddhiQueryContext, startStateIds, stateEventCloner, stateEventFactory, stateHolder, stateId, stateType, streamEventCloner, streamEventFactory, thisLastProcessor, thisStatePostProcessor, withinEveryPreStateProcessor, withinTime
Constructor and Description |
---|
CountPreStateProcessor(int minCount,
int maxCount,
io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType) |
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) |
CountPostStateProcessor |
getCountPostStateProcessor() |
void |
init(SiddhiQueryContext siddhiQueryContext) |
ComplexEventChunk<StateEvent> |
processAndReturn(ComplexEventChunk complexEventChunk) |
void |
setCountPostStateProcessor(CountPostStateProcessor countPostStateProcessor) |
void |
startStateReset() |
void |
successCondition() |
void |
updateState() |
addState, expireEvents, getNextProcessor, getPendingStateEventList, getStateId, getThisLastProcessor, getThisStatePostProcessor, init, isExpired, isStartState, process, process, process, removeOnNoStateChange, resetState, setNextProcessor, setStartState, setStartStateIds, setStateEventCloner, setStateEventFactory, setStateId, setStreamEventCloner, setStreamEventFactory, setThisLastProcessor, setThisStatePostProcessor, setToLast, setWithinEveryPreStateProcessor, setWithinTime, stateChanged
public CountPreStateProcessor(int minCount, int maxCount, io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType)
public void init(SiddhiQueryContext siddhiQueryContext)
init
in class StreamPreStateProcessor
public ComplexEventChunk<StateEvent> processAndReturn(ComplexEventChunk complexEventChunk)
processAndReturn
in interface PreStateProcessor
processAndReturn
in class StreamPreStateProcessor
public void successCondition()
protected void addState(StateEvent stateEvent, io.siddhi.core.query.input.stream.state.StreamPreStateProcessor.StreamPreState state)
addState
in class StreamPreStateProcessor
public void addEveryState(StateEvent stateEvent)
addEveryState
in interface PreStateProcessor
addEveryState
in class StreamPreStateProcessor
public CountPostStateProcessor getCountPostStateProcessor()
public void setCountPostStateProcessor(CountPostStateProcessor countPostStateProcessor)
public void startStateReset()
public void updateState()
updateState
in interface PreStateProcessor
updateState
in class StreamPreStateProcessor
Copyright © 2021. All rights reserved.