org.wso2.siddhi.core.stream.recevier.sequence

Class CountSequenceSingleStreamReceiver

java.lang.Object

org.wso2.siddhi.core.stream.recevier.sequence.SequenceSingleStreamReceiver

org.wso2.siddhi.core.stream.recevier.sequence.CountSequenceSingleStreamReceiver

All Implemented Interfaces:

StreamReceiver, StreamElement

public class CountSequenceSingleStreamReceiver
extends SequenceSingleStreamReceiver

Field Summary

Fields inherited from class org.wso2.siddhi.core.stream.recevier.sequence.SequenceSingleStreamReceiver

complexEventSize, currentEvents, currentState, firstSimpleStreamProcessor, nextEvents, nextState, state

Constructor Summary

Constructors

Constructor and Description
CountSequenceSingleStreamReceiver(CountSequenceState state, StreamProcessor firstSimpleStreamProcessor, int complexEventSize)

Method Summary

Methods

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)

Methods inherited from class org.wso2.siddhi.core.stream.recevier.sequence.SequenceSingleStreamReceiver

getStreamId, getWindow, init, moveNextEventsToCurrentEvents, receive

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CountSequenceSingleStreamReceiver

public CountSequenceSingleStreamReceiver(CountSequenceState state,
                                 StreamProcessor firstSimpleStreamProcessor,
                                 int complexEventSize)

Method Detail

sendForProcess

protected void sendForProcess(StreamEvent streamEvent)

Overrides:

sendForProcess in class SequenceSingleStreamReceiver

addToNextEvents

public void addToNextEvents(StateEvent stateEvent)

Overrides:

addToNextEvents in class SequenceSingleStreamReceiver

setPassed

public void setPassed(boolean passed)

isPassed

public boolean isPassed()

addOnlyToNextEvents

public void addOnlyToNextEvents(StateEvent stateEvent)