public class CountSequenceSingleStreamReceiver extends SequenceSingleStreamReceiver
complexEventSize, currentEvents, currentState, firstSimpleStreamProcessor, nextEvents, nextState, state
Constructor and Description |
---|
CountSequenceSingleStreamReceiver(CountSequenceState state,
StreamProcessor firstSimpleStreamProcessor,
int complexEventSize) |
Modifier and Type | Method and Description |
---|---|
void |
addOnlyToNextEvents(StateEvent stateEvent) |
void |
addToNextEvents(StateEvent stateEvent) |
boolean |
isPassed() |
protected void |
sendForProcess(StreamEvent streamEvent) |
void |
setPassed(boolean passed) |
getStreamId, getWindow, init, moveNextEventsToCurrentEvents, receive
public CountSequenceSingleStreamReceiver(CountSequenceState state, StreamProcessor firstSimpleStreamProcessor, int complexEventSize)
protected void sendForProcess(StreamEvent streamEvent)
sendForProcess
in class SequenceSingleStreamReceiver
public void addToNextEvents(StateEvent stateEvent)
addToNextEvents
in class SequenceSingleStreamReceiver
public void setPassed(boolean passed)
public boolean isPassed()
public void addOnlyToNextEvents(StateEvent stateEvent)
Copyright © 2012. All Rights Reserved.