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