public class PatternSingleProcessStreamReceiver extends SingleProcessStreamReceiver
batchProcessingAllowed, lockWrapper, next, siddhiQueryContext, stateProcessors, stateProcessorsSize, streamId
Constructor and Description |
---|
PatternSingleProcessStreamReceiver(String streamId,
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 PatternSingleProcessStreamReceiver(String streamId, Object patternSyncObject, SiddhiQueryContext siddhiQueryContext)
protected void stabilizeStates()
stabilizeStates
in class SingleProcessStreamReceiver
Copyright © 2019. All rights reserved.