public class ProcessStreamReceiver extends Object implements StreamJunction.Receiver
Modifier and Type | Field and Description |
---|---|
protected boolean |
batchProcessingAllowed |
protected LockWrapper |
lockWrapper |
protected Processor |
next |
protected SiddhiQueryContext |
siddhiQueryContext |
protected List<PreStateProcessor> |
stateProcessors |
protected int |
stateProcessorsSize |
protected String |
streamId |
Constructor and Description |
---|
ProcessStreamReceiver(String streamId,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
void |
addStatefulProcessor(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 |
setBatchProcessingAllowed(boolean batchProcessingAllowed) |
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> stateProcessors
protected int stateProcessorsSize
protected LockWrapper lockWrapper
protected boolean batchProcessingAllowed
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 setBatchProcessingAllowed(boolean batchProcessingAllowed)
public void setNext(Processor next)
public void setStreamEventFactory(StreamEventFactory streamEventFactory)
public void setLockWrapper(LockWrapper lockWrapper)
public void init()
public void addStatefulProcessor(PreStateProcessor stateProcessor)
Copyright © 2019. All rights reserved.