public class SingleProcessStreamReceiver extends ProcessStreamReceiver
batchProcessingAllowed, lockWrapper, next, siddhiQueryContext, stateProcessors, stateProcessorsSize, 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() |
addStatefulProcessor, getStreamId, init, receive, receive, receive, receive, receive, setBatchProcessingAllowed, 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()
Copyright © 2019. All rights reserved.