org.wso2.siddhi.core.stream.packer

Class SingleStreamPacker

java.lang.Object

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

All Implemented Interfaces:

StreamPacker, StreamProcessor

Direct Known Subclasses:

JoinStreamPacker, PatternStreamPacker, SequenceStreamPacker

public class SingleStreamPacker
extends Object
implements StreamPacker, StreamProcessor

Field Summary

Fields

Modifier and Type	Field and Description
protected StreamElement	prevStreamElement
protected QueryProjector	queryProjector

Constructor Summary

Constructors

Constructor and Description
SingleStreamPacker()

Method Summary

Methods

Modifier and Type	Method and Description
void	process(ComplexEvent complexEvent)
void	setNext(QueryProjector queryProjector)
void	setPrevious(StreamElement streamElement)

Methods inherited from class java.lang.Object

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

Field Detail

queryProjector

protected QueryProjector queryProjector

prevStreamElement

protected StreamElement prevStreamElement

Constructor Detail

SingleStreamPacker

public SingleStreamPacker()

Method Detail

process

public void process(ComplexEvent complexEvent)

Specified by:

process in interface StreamProcessor

setPrevious

public void setPrevious(StreamElement streamElement)

Specified by:

setPrevious in interface StreamProcessor

setNext

public void setNext(QueryProjector queryProjector)

Specified by:

setNext in interface StreamPacker