public class CountPreStateProcessor extends StreamPreStateProcessor
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 |
---|---|
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() |
addEveryState, addState, getNextProcessor, getPendingStateEventList, getStateId, getThisLastProcessor, getThisStatePostProcessor, init, isExpired, isStartState, 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 CountPostStateProcessor getCountPostStateProcessor()
public void setCountPostStateProcessor(CountPostStateProcessor countPostStateProcessor)
public void startStateReset()
public void updateState()
updateState
in interface PreStateProcessor
updateState
in class StreamPreStateProcessor
Copyright © 2019. All rights reserved.