public class SequenceSingleProcessStreamReceiver extends SingleProcessStreamReceiver
allStateProcessors, allStateProcessorsSize, lockWrapper, next, siddhiQueryContext, stateProcessorsForStream, stateProcessorsForStreamSize, streamId
Constructor and Description |
---|
SequenceSingleProcessStreamReceiver(String streamId,
StateStreamRuntime stateStreamRuntime,
Object patternSyncObject,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
protected void |
stabilizeStates(long timestamp) |
processAndClear, setNext
addStatefulProcessorForStream, getStreamId, init, receive, receive, receive, receive, receive, setAllStatefulProcessors, setLockWrapper, setMetaStreamEvent, setSiddhiDebugger, setStreamEventFactory, toStream
public SequenceSingleProcessStreamReceiver(String streamId, StateStreamRuntime stateStreamRuntime, Object patternSyncObject, SiddhiQueryContext siddhiQueryContext)
protected void stabilizeStates(long timestamp)
stabilizeStates
in class SingleProcessStreamReceiver
Copyright © 2019. All rights reserved.