public class LogicalPreStateProcessor extends StreamPreStateProcessor
Modifier and Type | Field and Description |
---|---|
protected io.siddhi.query.api.execution.query.input.state.LogicalStateElement.Type |
logicalType |
protected LogicalPreStateProcessor |
partnerStatePreProcessor |
eventTimeComparator, isStartState, lock, nextProcessor, siddhiQueryContext, startStateIds, stateEventCloner, stateEventFactory, stateHolder, stateId, stateType, streamEventCloner, streamEventFactory, thisLastProcessor, thisStatePostProcessor, withinEveryPreStateProcessor, withinTime
Constructor and Description |
---|
LogicalPreStateProcessor(io.siddhi.query.api.execution.query.input.state.LogicalStateElement.Type type,
io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType) |
Modifier and Type | Method and Description |
---|---|
void |
addEventToNewAndEveryStateEventList(StateEvent event) |
void |
addEveryState(StateEvent stateEvent) |
protected void |
addState(StateEvent stateEvent,
io.siddhi.core.query.input.stream.state.StreamPreStateProcessor.StreamPreState state) |
boolean |
isNewAndEveryStateEventListEmpty() |
void |
moveAllNewAndEveryStateEventListEventsToPendingStateEventList() |
ComplexEventChunk<StateEvent> |
processAndReturn(ComplexEventChunk complexEventChunk) |
void |
resetState() |
void |
setPartnerStatePreProcessor(LogicalPreStateProcessor partnerStatePreProcessor) |
void |
updateState() |
addState, expireEvents, getNextProcessor, getPendingStateEventList, getStateId, getThisLastProcessor, getThisStatePostProcessor, init, init, isExpired, isStartState, process, process, process, removeOnNoStateChange, setNextProcessor, setStartState, setStartStateIds, setStateEventCloner, setStateEventFactory, setStateId, setStreamEventCloner, setStreamEventFactory, setThisLastProcessor, setThisStatePostProcessor, setToLast, setWithinEveryPreStateProcessor, setWithinTime, stateChanged
protected io.siddhi.query.api.execution.query.input.state.LogicalStateElement.Type logicalType
protected LogicalPreStateProcessor partnerStatePreProcessor
public LogicalPreStateProcessor(io.siddhi.query.api.execution.query.input.state.LogicalStateElement.Type type, io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType)
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 void resetState()
resetState
in interface PreStateProcessor
resetState
in class StreamPreStateProcessor
public void updateState()
updateState
in interface PreStateProcessor
updateState
in class StreamPreStateProcessor
public ComplexEventChunk<StateEvent> processAndReturn(ComplexEventChunk complexEventChunk)
processAndReturn
in interface PreStateProcessor
processAndReturn
in class StreamPreStateProcessor
public void setPartnerStatePreProcessor(LogicalPreStateProcessor partnerStatePreProcessor)
public void moveAllNewAndEveryStateEventListEventsToPendingStateEventList()
public boolean isNewAndEveryStateEventListEmpty()
public void addEventToNewAndEveryStateEventList(StateEvent event)
Copyright © 2021. All rights reserved.