public class SequenceSingleProcessStreamReceiver extends SingleProcessStreamReceiver
batchProcessingAllowed, lockWrapper, next, siddhiQueryContext, stateProcessors, stateProcessorsSize, streamId
Constructor and Description |
---|
SequenceSingleProcessStreamReceiver(String streamId,
StateStreamRuntime stateStreamRuntime,
Object patternSyncObject,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
protected void |
stabilizeStates() |
processAndClear, setNext
addStatefulProcessor, getStreamId, init, receive, receive, receive, receive, receive, setBatchProcessingAllowed, setLockWrapper, setMetaStreamEvent, setSiddhiDebugger, setStreamEventFactory, toStream
public SequenceSingleProcessStreamReceiver(String streamId, StateStreamRuntime stateStreamRuntime, Object patternSyncObject, SiddhiQueryContext siddhiQueryContext)
protected void stabilizeStates()
stabilizeStates
in class SingleProcessStreamReceiver
Copyright © 2019. All rights reserved.