org.wso2.siddhi.core.stream.recevier.pattern

Class CountPatternSingleStreamReceiver

java.lang.Object

org.wso2.siddhi.core.stream.recevier.pattern.PatternSingleStreamReceiver

org.wso2.siddhi.core.stream.recevier.pattern.CountPatternSingleStreamReceiver

All Implemented Interfaces:

StreamReceiver, StreamElement

public class CountPatternSingleStreamReceiver
extends PatternSingleStreamReceiver

Field Summary

Fields inherited from class org.wso2.siddhi.core.stream.recevier.pattern.PatternSingleStreamReceiver

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

Constructor Summary

Constructors

Constructor and Description
CountPatternSingleStreamReceiver(CountPatternState state, StreamProcessor firstSimpleStreamProcessor, int complexEventSize)

Method Summary

Methods

Modifier and Type	Method and Description
void	addOnlyToNextEvents(StateEvent stateEvent)
void	addToNextEvents(StateEvent stateEvent)
boolean	isPassed()
void	receive(StreamEvent event)
void	setPassed(boolean passed)

Methods inherited from class org.wso2.siddhi.core.stream.recevier.pattern.PatternSingleStreamReceiver

getStreamId, getWindow, init, moveNextEventsToCurrentEvents

Methods inherited from class java.lang.Object

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

Constructor Detail

CountPatternSingleStreamReceiver

public CountPatternSingleStreamReceiver(CountPatternState state,
                                StreamProcessor firstSimpleStreamProcessor,
                                int complexEventSize)

Method Detail

receive

public void receive(StreamEvent event)

Specified by:

receive in interface StreamReceiver

Overrides:

receive in class PatternSingleStreamReceiver

addToNextEvents

public void addToNextEvents(StateEvent stateEvent)

Overrides:

addToNextEvents in class PatternSingleStreamReceiver

setPassed

public void setPassed(boolean passed)

isPassed

public boolean isPassed()

addOnlyToNextEvents

public void addOnlyToNextEvents(StateEvent stateEvent)