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

Class PatternSingleStreamReceiver

java.lang.Object

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

All Implemented Interfaces:

StreamReceiver, StreamElement

Direct Known Subclasses:

AndPatternSingleStreamReceiver, CountPatternSingleStreamReceiver, OrPatternSingleStreamReceiver

public class PatternSingleStreamReceiver
extends Object
implements StreamReceiver, StreamElement

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
PatternSingleStreamReceiver(PatternState state, StreamProcessor firstSimpleStreamProcessor, int complexEventSize)

Method Summary

Methods

Modifier and Type	Method and Description
void	addToNextEvents(StateEvent stateEvent)
String	getStreamId()
SchedulerQueue<StreamEvent>	getWindow()
void	init()
void	moveNextEventsToCurrentEvents()
void	receive(StreamEvent event)

Methods inherited from class java.lang.Object

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

Field Detail

complexEventSize

protected int complexEventSize

state

protected PatternState state

nextState

protected PatternState nextState

nextEveryState

protected PatternState nextEveryState

firstSimpleStreamProcessor

protected StreamProcessor firstSimpleStreamProcessor

currentEvents

protected List<StateEvent> currentEvents

nextEvents

protected List<StateEvent> nextEvents

currentState

protected final int currentState

Constructor Detail

PatternSingleStreamReceiver

public PatternSingleStreamReceiver(PatternState state,
                           StreamProcessor firstSimpleStreamProcessor,
                           int complexEventSize)

Method Detail

init

public void init()

receive

public void receive(StreamEvent event)

Specified by:

receive in interface StreamReceiver

getStreamId

public String getStreamId()

Specified by:

getStreamId in interface StreamReceiver

Specified by:

getStreamId in interface StreamElement

getWindow

public SchedulerQueue<StreamEvent> getWindow()

Specified by:

getWindow in interface StreamElement

addToNextEvents

public void addToNextEvents(StateEvent stateEvent)

moveNextEventsToCurrentEvents

public void moveNextEventsToCurrentEvents()