public class PatternSingleStreamReceiver extends Object implements StreamReceiver, StreamElement
Modifier and Type | Field and Description |
---|---|
protected int |
complexEventSize |
protected List<StateEvent> |
currentEvents |
protected int |
currentState |
protected StreamProcessor |
firstSimpleStreamProcessor |
protected List<StateEvent> |
nextEvents |
protected PatternState |
nextEveryState |
protected PatternState |
nextState |
protected PatternState |
state |
Constructor and Description |
---|
PatternSingleStreamReceiver(PatternState state,
StreamProcessor firstSimpleStreamProcessor,
int complexEventSize) |
Modifier and Type | Method and Description |
---|---|
void |
addToNextEvents(StateEvent stateEvent) |
String |
getStreamId() |
SchedulerQueue<StreamEvent> |
getWindow() |
void |
init() |
void |
moveNextEventsToCurrentEvents() |
void |
receive(StreamEvent event) |
protected int complexEventSize
protected PatternState state
protected PatternState nextState
protected PatternState nextEveryState
protected StreamProcessor firstSimpleStreamProcessor
protected List<StateEvent> currentEvents
protected List<StateEvent> nextEvents
protected final int currentState
public PatternSingleStreamReceiver(PatternState state, StreamProcessor firstSimpleStreamProcessor, int complexEventSize)
public void init()
public void receive(StreamEvent event)
receive
in interface StreamReceiver
public String getStreamId()
getStreamId
in interface StreamReceiver
getStreamId
in interface StreamElement
public SchedulerQueue<StreamEvent> getWindow()
getWindow
in interface StreamElement
public void addToNextEvents(StateEvent stateEvent)
public void moveNextEventsToCurrentEvents()
Copyright © 2012. All Rights Reserved.