com.espertech.esper.epl.join.assemble

Class RootRequiredAssemblyNode

java.lang.Object

com.espertech.esper.epl.join.assemble.BaseAssemblyNode

com.espertech.esper.epl.join.assemble.RootRequiredAssemblyNode

All Implemented Interfaces:

ResultAssembler

public class RootRequiredAssemblyNode
extends BaseAssemblyNode

Assembly node for an event stream that is a root with a one required child node below it.

Field Summary

Fields inherited from class com.espertech.esper.epl.join.assemble.BaseAssemblyNode

childNodes, numStreams, parentNode, streamNum

Constructor Summary

Constructors

Constructor and Description
RootRequiredAssemblyNode(int streamNum, int numStreams) Ctor.

Method Summary

Modifier and Type	Method and Description
void	init(List<Node>[] result) Provides results to assembly nodes for initialization.
void	print(IndentWriter indentWriter) Output this node using writer, not outputting child nodes.
void	process(List<Node>[] result, Collection<EventBean[]> resultFinalRows, EventBean resultRootEvent) Process results.
void	result(EventBean[] row, int fromStreamNum, EventBean myEvent, Node myNode, Collection<EventBean[]> resultFinalRows, EventBean resultRootEvent) Publish a result row.

Methods inherited from class com.espertech.esper.epl.join.assemble.BaseAssemblyNode

addChild, getChildNodes, getStreamNum, getSubstreams, setParentAssembler

Methods inherited from class java.lang.Object

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

Constructor Detail

RootRequiredAssemblyNode

public RootRequiredAssemblyNode(int streamNum,
                                int numStreams)

Ctor.

Parameters:

streamNum - - is the stream number

numStreams - - is the number of streams

Method Detail

init

public void init(List<Node>[] result)

Description copied from class: BaseAssemblyNode

Provides results to assembly nodes for initialization.

Specified by:

init in class BaseAssemblyNode

Parameters:

result - is a list of result nodes per stream

process

public void process(List<Node>[] result,
                    Collection<EventBean[]> resultFinalRows,
                    EventBean resultRootEvent)

Description copied from class: BaseAssemblyNode

Process results.

Specified by:

process in class BaseAssemblyNode

Parameters:

result - is a list of result nodes per stream

resultFinalRows - final row collection

resultRootEvent - root event

result

public void result(EventBean[] row,
                   int fromStreamNum,
                   EventBean myEvent,
                   Node myNode,
                   Collection<EventBean[]> resultFinalRows,
                   EventBean resultRootEvent)

Description copied from interface: ResultAssembler

Publish a result row.

Parameters:

row - is the result to publish

fromStreamNum - is the originitor that publishes the row

myEvent - is optional and is the event that led to the row result

myNode - is optional and is the result node of the event that led to the row result

resultFinalRows - is the final result rows

resultRootEvent - root event

print

public void print(IndentWriter indentWriter)

Description copied from class: BaseAssemblyNode

Output this node using writer, not outputting child nodes.

Specified by:

print in class BaseAssemblyNode

Parameters:

indentWriter - to use for output