com.espertech.esper.epl.join.base
Class JoinExecutionStrategyImpl

java.lang.Object
  com.espertech.esper.epl.join.base.JoinExecutionStrategyImpl

All Implemented Interfaces:

JoinExecutionStrategy

public class JoinExecutionStrategyImpl
extends java.lang.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

JoinExecutionStrategyImpl(JoinSetComposer composer, JoinSetProcessor filter, JoinSetProcessor indicator, ExprEvaluatorContext staticExprEvaluatorContext)
Ctor.

Method Summary

void	join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream) Execute join.
java.util.Set<MultiKey<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 Detail

JoinExecutionStrategyImpl

public JoinExecutionStrategyImpl(JoinSetComposer composer,
                                 JoinSetProcessor filter,
                                 JoinSetProcessor indicator,
                                 ExprEvaluatorContext staticExprEvaluatorContext)

Ctor.

Parameters:

composer - - determines join tuple set

filter - - for filtering among tuples

indicator - - for presenting the info to a view

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

Method Detail

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 java.util.Set<MultiKey<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