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

Class JoinExecutionStrategyImpl

java.lang.Object

com.espertech.esper.common.internal.epl.join.base.JoinExecutionStrategyImpl

All Implemented Interfaces:

JoinExecutionStrategy

public class JoinExecutionStrategyImpl
extends Object
implements JoinExecutionStrategy

Join execution strategy based on a 3-step getSelectListEvents of composing a join set, filtering the join set and indicating.

Constructor Summary

Constructors

Constructor	Description
JoinExecutionStrategyImpl(JoinSetComposer composer, ExprEvaluator optionalFilter, JoinSetProcessor indicator, ExprEvaluatorContext staticExprEvaluatorContext)	Ctor.

Method Summary

Modifier and Type	Method	Description
void	join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream)	Execute join.
Set<MultiKeyArrayOfKeys<EventBean>>	staticJoin()	A static join is for use with iterating over join statements.

Methods inherited from class java.lang.Object

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

Constructor Details

JoinExecutionStrategyImpl

public JoinExecutionStrategyImpl(JoinSetComposer composer,
 ExprEvaluator optionalFilter,
 JoinSetProcessor indicator,
 ExprEvaluatorContext staticExprEvaluatorContext)

Ctor.

Parameters:

composer - - determines join tuple set

optionalFilter - - for filtering among tuples

indicator - - for presenting the info to a view

staticExprEvaluatorContext - expression evaluation context for static evaluation (not for runtime eval)

Method Details

join

public void join(EventBean[][] newDataPerStream,
 EventBean[][] oldDataPerStream)

Description copied from interface: JoinExecutionStrategy

Execute join. The first dimension in the 2-dim arrays is the stream that generated the events, and the second dimension is the actual events generated.

Specified by:

join in interface JoinExecutionStrategy

Parameters:

newDataPerStream - - new events for each stream

oldDataPerStream - - old events for each stream

staticJoin

public Set<MultiKeyArrayOfKeys<EventBean>> staticJoin()

Description copied from interface: JoinExecutionStrategy

A static join is for use with iterating over join statements.

Specified by:

staticJoin in interface JoinExecutionStrategy

Returns:

set of rows, each row with two or more events, one for each stream