public class OrSequenceSingleStreamReceiver extends SequenceSingleStreamReceiver
complexEventSize, currentEvents, currentState, firstSimpleStreamProcessor, nextEvents, nextState, state
Constructor and Description |
---|
OrSequenceSingleStreamReceiver(OrSequenceState state,
StreamProcessor firstSimpleStreamProcessor,
int complexEventSize) |
Modifier and Type | Method and Description |
---|---|
protected void |
sendForProcess(StreamEvent streamEvent) |
addToNextEvents, getStreamId, getWindow, init, moveNextEventsToCurrentEvents, receive
public OrSequenceSingleStreamReceiver(OrSequenceState state, StreamProcessor firstSimpleStreamProcessor, int complexEventSize)
protected void sendForProcess(StreamEvent streamEvent)
sendForProcess
in class SequenceSingleStreamReceiver
Copyright © 2012. All Rights Reserved.