Package com.espertech.esper.common.internal.epl.join.rep

Class RepositoryImpl

java.lang.Object

com.espertech.esper.common.internal.epl.join.rep.RepositoryImpl

All Implemented Interfaces:

Repository

public class RepositoryImpl
extends Object
implements Repository

Implements a repository for join events and lookup results.

Constructor Summary

Constructors

Constructor	Description
RepositoryImpl(int rootStream, EventBean rootEvent, int numStreams)	Ctor.

Method Summary

Modifier and Type	Method	Description
void	addResult(Cursor cursor, Set<EventBean> lookupResults, int resultStream)	Add a lookup result.
Iterator<Cursor>	getCursors(int lookupFromStream)	Supply events for performing look ups for a given stream.
List<Node>[]	getNodesPerStream()	Returns a list of nodes that are the lookup results per stream.

Methods inherited from class java.lang.Object

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

Constructor Details

RepositoryImpl

public RepositoryImpl(int rootStream,
 EventBean rootEvent,
 int numStreams)

Ctor.

Parameters:

rootStream - is the stream supplying the root event

rootEvent - is the root event

numStreams - is the number of streams

Method Details

getCursors

public Iterator<Cursor> getCursors(int lookupFromStream)

Description copied from interface: Repository

Supply events for performing look ups for a given stream.

Specified by:

getCursors in interface Repository

Parameters:

lookupFromStream - is the stream to perform lookup for

Returns:

an iterator over events with additional positioning information

addResult

public void addResult(Cursor cursor,
 Set<EventBean> lookupResults,
 int resultStream)

Description copied from interface: Repository

Add a lookup result.

Specified by:

addResult in interface Repository

Parameters:

cursor - provides result position and parent event and node information

lookupResults - is the events found

resultStream - is the stream number of the stream providing the results

getNodesPerStream

public List<Node>[] getNodesPerStream()

Returns a list of nodes that are the lookup results per stream.

Returns:

result nodes per stream