public class MultiProcessStreamReceiver extends ProcessStreamReceiver
Modifier and Type | Class and Description |
---|---|
class |
MultiProcessStreamReceiver.ReturnEventHolder
Class to hold the events which are differed publishing
|
Modifier and Type | Field and Description |
---|---|
protected int[] |
eventSequence |
protected Processor[] |
nextProcessors |
protected OutputRateLimiter |
outputRateLimiter |
allStateProcessors, allStateProcessorsSize, lockWrapper, next, siddhiQueryContext, stateProcessorsForStream, stateProcessorsForStreamSize, streamId
Constructor and Description |
---|
MultiProcessStreamReceiver(String streamId,
int processCount,
Object patternSyncObject,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
static ThreadLocal<MultiProcessStreamReceiver.ReturnEventHolder> |
getMultiProcessReturn() |
void |
init() |
protected void |
processAndClear(int processIndex,
StreamEvent streamEvent) |
void |
receive(ComplexEvent complexEvent) |
void |
receive(Event event) |
void |
receive(Event[] events) |
void |
receive(List<Event> events) |
void |
receive(long timestamp,
Object[] data) |
void |
setMetaStreamEvent(MetaStreamEvent metaStreamEvent) |
void |
setNext(Processor nextProcessor) |
void |
setOutputRateLimiter(OutputRateLimiter outputRateLimiter) |
void |
setStreamEventFactory(StreamEventFactory streamEventFactory) |
protected void |
stabilizeStates(long timestamp) |
boolean |
toStream() |
addStatefulProcessorForStream, getStreamId, processAndClear, setAllStatefulProcessors, setLockWrapper, setSiddhiDebugger
protected Processor[] nextProcessors
protected int[] eventSequence
protected OutputRateLimiter outputRateLimiter
public MultiProcessStreamReceiver(String streamId, int processCount, Object patternSyncObject, SiddhiQueryContext siddhiQueryContext)
public static ThreadLocal<MultiProcessStreamReceiver.ReturnEventHolder> getMultiProcessReturn()
public void receive(ComplexEvent complexEvent)
receive
in interface StreamJunction.Receiver
receive
in class ProcessStreamReceiver
public void receive(Event event)
receive
in interface StreamJunction.Receiver
receive
in class ProcessStreamReceiver
public void receive(Event[] events)
receive
in interface StreamJunction.Receiver
receive
in class ProcessStreamReceiver
public void receive(List<Event> events)
receive
in interface StreamJunction.Receiver
receive
in class ProcessStreamReceiver
public void receive(long timestamp, Object[] data)
receive
in interface StreamJunction.Receiver
receive
in class ProcessStreamReceiver
protected void processAndClear(int processIndex, StreamEvent streamEvent)
protected void stabilizeStates(long timestamp)
public void setNext(Processor nextProcessor)
setNext
in class ProcessStreamReceiver
public void setMetaStreamEvent(MetaStreamEvent metaStreamEvent)
setMetaStreamEvent
in class ProcessStreamReceiver
public boolean toStream()
toStream
in class ProcessStreamReceiver
public void setStreamEventFactory(StreamEventFactory streamEventFactory)
setStreamEventFactory
in class ProcessStreamReceiver
public void init()
init
in class ProcessStreamReceiver
public void setOutputRateLimiter(OutputRateLimiter outputRateLimiter)
Copyright © 2019. All rights reserved.