public class ProcessStreamReceiver extends Object implements StreamJunction.Receiver
Modifier and Type | Field and Description |
---|---|
protected List<PreStateProcessor> |
allStateProcessors |
protected int |
allStateProcessorsSize |
protected LockWrapper |
lockWrapper |
protected Processor |
next |
protected SiddhiQueryContext |
siddhiQueryContext |
protected List<PreStateProcessor> |
stateProcessorsForStream |
protected int |
stateProcessorsForStreamSize |
protected String |
streamId |
Constructor and Description |
---|
ProcessStreamReceiver(String streamId,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
void |
addStatefulProcessorForStream(PreStateProcessor stateProcessor) |
String |
getStreamId() |
void |
init() |
protected void |
processAndClear(ComplexEventChunk<StreamEvent> streamEventChunk) |
void |
receive(ComplexEvent complexEvents) |
void |
receive(Event event) |
void |
receive(Event[] events) |
void |
receive(List<Event> events) |
void |
receive(long timestamp,
Object[] data) |
void |
setAllStatefulProcessors(List<PreStateProcessor> allStateProcessors) |
void |
setLockWrapper(LockWrapper lockWrapper) |
void |
setMetaStreamEvent(MetaStreamEvent metaStreamEvent) |
void |
setNext(Processor next) |
void |
setSiddhiDebugger(SiddhiDebugger siddhiDebugger) |
void |
setStreamEventFactory(StreamEventFactory streamEventFactory) |
boolean |
toStream() |
protected final SiddhiQueryContext siddhiQueryContext
protected String streamId
protected Processor next
protected List<PreStateProcessor> stateProcessorsForStream
protected int stateProcessorsForStreamSize
protected LockWrapper lockWrapper
protected List<PreStateProcessor> allStateProcessors
protected int allStateProcessorsSize
public ProcessStreamReceiver(String streamId, SiddhiQueryContext siddhiQueryContext)
public String getStreamId()
getStreamId
in interface StreamJunction.Receiver
public void setSiddhiDebugger(SiddhiDebugger siddhiDebugger)
public void receive(ComplexEvent complexEvents)
receive
in interface StreamJunction.Receiver
public void receive(Event event)
receive
in interface StreamJunction.Receiver
public void receive(Event[] events)
receive
in interface StreamJunction.Receiver
public void receive(List<Event> events)
receive
in interface StreamJunction.Receiver
public void receive(long timestamp, Object[] data)
receive
in interface StreamJunction.Receiver
protected void processAndClear(ComplexEventChunk<StreamEvent> streamEventChunk)
public void setMetaStreamEvent(MetaStreamEvent metaStreamEvent)
public boolean toStream()
public void setNext(Processor next)
public void setStreamEventFactory(StreamEventFactory streamEventFactory)
public void setLockWrapper(LockWrapper lockWrapper)
public void init()
public void addStatefulProcessorForStream(PreStateProcessor stateProcessor)
public void setAllStatefulProcessors(List<PreStateProcessor> allStateProcessors)
Copyright © 2021. All rights reserved.