public class PatternMultiProcessStreamReceiver extends StateMultiProcessStreamReceiver
MultiProcessStreamReceiver.ReturnEventHolder
eventSequence, nextProcessors, outputRateLimiter
batchProcessingAllowed, lockWrapper, next, siddhiQueryContext, stateProcessors, stateProcessorsSize, streamId
Constructor and Description |
---|
PatternMultiProcessStreamReceiver(String streamId,
int processCount,
Object patternSyncObject,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
protected void |
stabilizeStates() |
processAndClear, setNext
getMultiProcessReturn, init, receive, receive, receive, receive, receive, setMetaStreamEvent, setOutputRateLimiter, setStreamEventFactory, toStream
addStatefulProcessor, getStreamId, processAndClear, setBatchProcessingAllowed, setLockWrapper, setSiddhiDebugger
public PatternMultiProcessStreamReceiver(String streamId, int processCount, Object patternSyncObject, SiddhiQueryContext siddhiQueryContext)
protected void stabilizeStates()
stabilizeStates
in class MultiProcessStreamReceiver
Copyright © 2019. All rights reserved.