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

Class SequenceSingleStreamReceiver

java.lang.Object

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

All Implemented Interfaces:

StreamReceiver, StreamElement

Direct Known Subclasses:

CountSequenceSingleStreamReceiver, OrSequenceSingleStreamReceiver

public class SequenceSingleStreamReceiver
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 SequenceState	nextState
protected SequenceState	state

Constructor Summary

Constructors

Constructor and Description
SequenceSingleStreamReceiver(SequenceState 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 streamEvent)
protected void	sendForProcess(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 SequenceState state

nextState

protected SequenceState nextState

firstSimpleStreamProcessor

protected StreamProcessor firstSimpleStreamProcessor

currentEvents

protected List<StateEvent> currentEvents

nextEvents

protected List<StateEvent> nextEvents

currentState

protected final int currentState

Constructor Detail

SequenceSingleStreamReceiver

public SequenceSingleStreamReceiver(SequenceState state,
                            StreamProcessor firstSimpleStreamProcessor,
                            int complexEventSize)

Method Detail

init

public void init()

receive

public void receive(StreamEvent streamEvent)

Specified by:

receive in interface StreamReceiver

sendForProcess

protected void sendForProcess(StreamEvent event)

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()