public class StreamPreStateProcessor extends Object implements PreStateProcessor
Modifier and Type | Field and Description |
---|---|
protected Comparator |
eventTimeComparator |
protected boolean |
isStartState |
protected ReentrantLock |
lock |
protected Processor |
nextProcessor |
protected SiddhiQueryContext |
siddhiQueryContext |
protected int[] |
startStateIds |
protected StateEventCloner |
stateEventCloner |
protected StateEventFactory |
stateEventFactory |
protected StateHolder<io.siddhi.core.query.input.stream.state.StreamPreStateProcessor.StreamPreState> |
stateHolder |
protected int |
stateId |
protected io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type |
stateType |
protected StreamEventCloner |
streamEventCloner |
protected StreamEventFactory |
streamEventFactory |
protected StreamPostStateProcessor |
thisLastProcessor |
protected StreamPostStateProcessor |
thisStatePostProcessor |
protected PreStateProcessor |
withinEveryPreStateProcessor |
protected long |
withinTime |
Constructor and Description |
---|
StreamPreStateProcessor(io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType) |
Modifier and Type | Method and Description |
---|---|
void |
addEveryState(StateEvent stateEvent) |
void |
addState(StateEvent stateEvent) |
protected void |
addState(StateEvent stateEvent,
io.siddhi.core.query.input.stream.state.StreamPreStateProcessor.StreamPreState state) |
void |
expireEvents(long timestamp) |
Processor |
getNextProcessor()
Get next processor element in the processor chain.
|
List<StateEvent> |
getPendingStateEventList() |
int |
getStateId() |
StreamPostStateProcessor |
getThisLastProcessor() |
StreamPostStateProcessor |
getThisStatePostProcessor() |
void |
init() |
void |
init(SiddhiQueryContext siddhiQueryContext) |
protected boolean |
isExpired(StateEvent pendingStateEvent,
long currentTimestamp) |
boolean |
isStartState() |
void |
process(ComplexEventChunk complexEventChunk)
Process the handed StreamEvent
|
void |
process(List<ComplexEventChunk> complexEventChunks)
Process the handed StreamEvent
|
protected void |
process(StateEvent stateEvent) |
ComplexEventChunk<StateEvent> |
processAndReturn(ComplexEventChunk complexEventChunk) |
protected boolean |
removeOnNoStateChange(io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType) |
void |
resetState() |
void |
setNextProcessor(Processor processor)
Set next processor element in processor chain
|
void |
setStartState(boolean isStartState) |
void |
setStartStateIds(int[] stateIds) |
void |
setStateEventCloner(StateEventCloner stateEventCloner) |
void |
setStateEventFactory(StateEventFactory stateEventFactory) |
void |
setStateId(int stateId) |
void |
setStreamEventCloner(StreamEventCloner streamEventCloner) |
void |
setStreamEventFactory(StreamEventFactory streamEventFactory) |
void |
setThisLastProcessor(StreamPostStateProcessor thisLastProcessor) |
void |
setThisStatePostProcessor(StreamPostStateProcessor thisStatePostProcessor) |
void |
setToLast(Processor processor)
Set as the last element of the processor chain
|
void |
setWithinEveryPreStateProcessor(PreStateProcessor withinEveryPreStateProcessor) |
void |
setWithinTime(long withinTime) |
void |
stateChanged() |
void |
updateState() |
protected int stateId
protected boolean isStartState
protected io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType
protected long withinTime
protected int[] startStateIds
protected PreStateProcessor withinEveryPreStateProcessor
protected StreamPostStateProcessor thisStatePostProcessor
protected StreamPostStateProcessor thisLastProcessor
protected Processor nextProcessor
protected ReentrantLock lock
protected StateEventFactory stateEventFactory
protected StreamEventCloner streamEventCloner
protected StateEventCloner stateEventCloner
protected StreamEventFactory streamEventFactory
protected SiddhiQueryContext siddhiQueryContext
protected StateHolder<io.siddhi.core.query.input.stream.state.StreamPreStateProcessor.StreamPreState> stateHolder
protected Comparator eventTimeComparator
public StreamPreStateProcessor(io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType)
public void init(SiddhiQueryContext siddhiQueryContext)
public StreamPostStateProcessor getThisStatePostProcessor()
getThisStatePostProcessor
in interface PreStateProcessor
public void setThisStatePostProcessor(StreamPostStateProcessor thisStatePostProcessor)
public void process(ComplexEventChunk complexEventChunk)
public void process(List<ComplexEventChunk> complexEventChunks)
Processor
protected boolean isExpired(StateEvent pendingStateEvent, long currentTimestamp)
protected void process(StateEvent stateEvent)
public Processor getNextProcessor()
getNextProcessor
in interface Processor
public void setNextProcessor(Processor processor)
setNextProcessor
in interface Processor
processor
- Processor to be set as next element of processor chainpublic void setToLast(Processor processor)
public void init()
init
in interface PreStateProcessor
public StreamPostStateProcessor getThisLastProcessor()
public void setThisLastProcessor(StreamPostStateProcessor thisLastProcessor)
public void addState(StateEvent stateEvent)
addState
in interface PreStateProcessor
protected void addState(StateEvent stateEvent, io.siddhi.core.query.input.stream.state.StreamPreStateProcessor.StreamPreState state)
public void addEveryState(StateEvent stateEvent)
addEveryState
in interface PreStateProcessor
public void setWithinEveryPreStateProcessor(PreStateProcessor withinEveryPreStateProcessor)
setWithinEveryPreStateProcessor
in interface PreStateProcessor
public void stateChanged()
public boolean isStartState()
isStartState
in interface PreStateProcessor
public void setStartState(boolean isStartState)
setStartState
in interface PreStateProcessor
public void setStateEventFactory(StateEventFactory stateEventFactory)
public void setStreamEventFactory(StreamEventFactory streamEventFactory)
public void setStreamEventCloner(StreamEventCloner streamEventCloner)
public void setStateEventCloner(StateEventCloner stateEventCloner)
public void resetState()
resetState
in interface PreStateProcessor
public void updateState()
updateState
in interface PreStateProcessor
public void expireEvents(long timestamp)
expireEvents
in interface PreStateProcessor
public ComplexEventChunk<StateEvent> processAndReturn(ComplexEventChunk complexEventChunk)
processAndReturn
in interface PreStateProcessor
protected boolean removeOnNoStateChange(io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType)
public int getStateId()
getStateId
in interface PreStateProcessor
public void setStateId(int stateId)
setStateId
in interface PreStateProcessor
public void setWithinTime(long withinTime)
setWithinTime
in interface PreStateProcessor
public void setStartStateIds(int[] stateIds)
setStartStateIds
in interface PreStateProcessor
public List<StateEvent> getPendingStateEventList()
Copyright © 2019. All rights reserved.