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