org.wso2.siddhi.core.stream.packer.pattern

Class PatternStreamPacker

java.lang.Object

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

org.wso2.siddhi.core.stream.packer.pattern.PatternStreamPacker

All Implemented Interfaces:

StreamPacker, StreamProcessor

Direct Known Subclasses:

AndPatternStreamPacker, CountPatternStreamPacker, OrPatternStreamPacker

public class PatternStreamPacker
extends SingleStreamPacker

Field Summary

Fields

Modifier and Type	Field and Description
protected PatternState	nextEveryState
protected PatternState	nextState
protected PatternState	state
protected PatternSingleStreamReceiver	streamReceiver

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

prevStreamElement, queryProjector

Constructor Summary

Constructors

Constructor and Description
PatternStreamPacker(PatternState 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(PatternSingleStreamReceiver 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 PatternSingleStreamReceiver streamReceiver

state

protected PatternState state

nextState

protected PatternState nextState

nextEveryState

protected PatternState nextEveryState

Constructor Detail

PatternStreamPacker

public PatternStreamPacker(PatternState state)

Method Detail

setStreamReceiver

public void setStreamReceiver(PatternSingleStreamReceiver 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)