org.wso2.siddhi.core.stream.packer.join

Class JoinStreamPacker

java.lang.Object

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

org.wso2.siddhi.core.stream.packer.join.JoinStreamPacker

All Implemented Interfaces:

StreamPacker, StreamProcessor

Direct Known Subclasses:

LeftJoinStreamPacker, RightJoinStreamPacker

public abstract class JoinStreamPacker
extends SingleStreamPacker

Field Summary

Fields

Modifier and Type	Field and Description
protected ConditionExecutor	onConditionExecutor
protected boolean	triggerEvent
protected SchedulerQueue<StreamEvent>	window

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

prevStreamElement, queryProjector

Constructor Summary

Constructors

Constructor and Description
JoinStreamPacker(ConditionExecutor onConditionExecutor, boolean triggerEvent)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract StateEvent	createNewEvent(ComplexEvent complexEvent, ComplexEvent complexEvent1)
SchedulerQueue<StreamEvent>	getWindow()
void	process(ComplexEvent complexEvent)
protected void	sendEventList(List<AtomicEvent> list)
void	setNext(QueryProjector queryProjector)
void	setOppositeWindow(SchedulerQueue<StreamEvent> window)

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

setPrevious

Methods inherited from class java.lang.Object

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

Field Detail

window

protected SchedulerQueue<StreamEvent> window

onConditionExecutor

protected ConditionExecutor onConditionExecutor

triggerEvent

protected boolean triggerEvent

Constructor Detail

JoinStreamPacker

public JoinStreamPacker(ConditionExecutor onConditionExecutor,
                boolean triggerEvent)

Method Detail

getWindow

public SchedulerQueue<StreamEvent> getWindow()

setNext

public void setNext(QueryProjector queryProjector)

Specified by:

setNext in interface StreamPacker

Overrides:

setNext in class SingleStreamPacker

process

public void process(ComplexEvent complexEvent)

Specified by:

process in interface StreamProcessor

Overrides:

process in class SingleStreamPacker

createNewEvent

protected abstract StateEvent createNewEvent(ComplexEvent complexEvent,
                        ComplexEvent complexEvent1)

sendEventList

protected void sendEventList(List<AtomicEvent> list)

setOppositeWindow

public void setOppositeWindow(SchedulerQueue<StreamEvent> window)