org.wso2.siddhi.core.stream.packer.sequence

Class SequenceStreamPacker

java.lang.Object

org.wso2.siddhi.core.stream.packer.SingleStreamPacker

org.wso2.siddhi.core.stream.packer.sequence.SequenceStreamPacker

All Implemented Interfaces:

StreamPacker, StreamProcessor

Direct Known Subclasses:

CountSequenceStreamPacker, OrSequenceStreamPacker

public class SequenceStreamPacker
extends SingleStreamPacker

Field Summary

Fields

Modifier and Type	Field and Description
protected SequenceState	nextState
protected SequenceState	state
protected SequenceSingleStreamReceiver	streamReceiver

Fields inherited from class org.wso2.siddhi.core.stream.packer.SingleStreamPacker

prevStreamElement, queryProjector

Constructor Summary

Constructors

Constructor and Description
SequenceStreamPacker(SequenceState state)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	passToStreamReceivers(StateEvent eventBundle)
void	process(ComplexEvent complexEvent)
protected void	sendEvent(AtomicEvent atomicEvent)
protected void	setEventState(StateEvent eventBundle)
void	setStreamReceiver(SequenceSingleStreamReceiver streamReceiver)

Methods inherited from class org.wso2.siddhi.core.stream.packer.SingleStreamPacker

setNext, setPrevious

Methods inherited from class java.lang.Object

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

Field Detail

streamReceiver

protected SequenceSingleStreamReceiver streamReceiver

state

protected SequenceState state

nextState

protected SequenceState nextState

Constructor Detail

SequenceStreamPacker

public SequenceStreamPacker(SequenceState state)

Method Detail

setStreamReceiver

public void setStreamReceiver(SequenceSingleStreamReceiver streamReceiver)

process

public void process(ComplexEvent complexEvent)

Specified by:

process in interface StreamProcessor

Overrides:

process in class SingleStreamPacker

setEventState

protected void setEventState(StateEvent eventBundle)

sendEvent

protected void sendEvent(AtomicEvent atomicEvent)

passToStreamReceivers

protected void passToStreamReceivers(StateEvent eventBundle)