public class SingleProcessStreamReceiver extends ProcessStreamReceiver
allStateProcessors, allStateProcessorsSize, lockWrapper, next, siddhiQueryContext, stateProcessorsForStream, stateProcessorsForStreamSize, streamId
Constructor and Description |
---|
SingleProcessStreamReceiver(String streamId,
Object patternSyncObject,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
protected void |
processAndClear(ComplexEventChunk<StreamEvent> streamEventChunk) |
void |
setNext(Processor next) |
protected void |
stabilizeStates(long timestamp) |
addStatefulProcessorForStream, getStreamId, init, receive, receive, receive, receive, receive, setAllStatefulProcessors, setLockWrapper, setMetaStreamEvent, setSiddhiDebugger, setStreamEventFactory, toStream
public SingleProcessStreamReceiver(String streamId, Object patternSyncObject, SiddhiQueryContext siddhiQueryContext)
public void setNext(Processor next)
setNext
in class ProcessStreamReceiver
protected void processAndClear(ComplexEventChunk<StreamEvent> streamEventChunk)
processAndClear
in class ProcessStreamReceiver
protected void stabilizeStates(long timestamp)
Copyright © 2021. All rights reserved.