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

Class JoinSetComposerFAFImpl

java.lang.Object

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

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

All Implemented Interfaces:

JoinSetComposer

public class JoinSetComposerFAFImpl
extends JoinSetComposerImpl

Implements the function to determine a join result set using tables/indexes and query strategy instances for each stream.

Field Summary

Fields inherited from class com.espertech.esper.common.internal.epl.join.base.JoinSetComposerImpl

newResults, oldResults, queryStrategies, repositories

Constructor Summary

Constructors

Constructor	Description
JoinSetComposerFAFImpl(Map<TableLookupIndexReqKey,EventTable>[] repositories, QueryStrategy[] queryStrategies, boolean isPureSelfJoin, ExprEvaluatorContext exprEvaluatorContext, boolean joinRemoveStream, boolean outerJoins)

Method Summary

Modifier and Type	Method	Description
void	destroy()	Destroy stateful index tables, if any.
void	init(EventBean[][] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)	Provides initialization events per stream to composer to populate join indexes, if required
UniformPair<Set<MultiKeyArrayOfKeys<EventBean>>>	join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream, ExprEvaluatorContext exprEvaluatorContext)	Return join tuple result set from new data and old data for each stream.
Set<MultiKeyArrayOfKeys<EventBean>>	staticJoin()	For use in iteration over join statements, this must build a join tuple result set from all events in indexes, executing query strategies for each.

Methods inherited from class com.espertech.esper.common.internal.epl.join.base.JoinSetComposerImpl

accept, allowsInit, getQueryStrategies, getTables

Methods inherited from class java.lang.Object

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

Constructor Details

JoinSetComposerFAFImpl

public JoinSetComposerFAFImpl(Map<TableLookupIndexReqKey,EventTable>[] repositories,
 QueryStrategy[] queryStrategies,
 boolean isPureSelfJoin,
 ExprEvaluatorContext exprEvaluatorContext,
 boolean joinRemoveStream,
 boolean outerJoins)

Method Details

init

public void init(EventBean[][] eventsPerStream,
 ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: JoinSetComposer

Provides initialization events per stream to composer to populate join indexes, if required

Specified by:

init in interface JoinSetComposer

Overrides:

init in class JoinSetComposerImpl

Parameters:

eventsPerStream - is an array of events for each stream, with null elements to indicate no events for a stream

exprEvaluatorContext - evaluator context

destroy

public void destroy()

Description copied from interface: JoinSetComposer

Destroy stateful index tables, if any.

Specified by:

destroy in interface JoinSetComposer

Overrides:

destroy in class JoinSetComposerImpl

join

public UniformPair<Set<MultiKeyArrayOfKeys<EventBean>>> join(EventBean[][] newDataPerStream,
 EventBean[][] oldDataPerStream,
 ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: JoinSetComposer

Return join tuple result set from new data and old data for each stream.

Specified by:

join in interface JoinSetComposer

Overrides:

join in class JoinSetComposerImpl

Parameters:

newDataPerStream - - for each stream the event array (can be null).

oldDataPerStream - - for each stream the event array (can be null).

exprEvaluatorContext - expression evaluation context

Returns:

join tuples

staticJoin

public Set<MultiKeyArrayOfKeys<EventBean>> staticJoin()

Description copied from interface: JoinSetComposer

For use in iteration over join statements, this must build a join tuple result set from all events in indexes, executing query strategies for each.

Specified by:

staticJoin in interface JoinSetComposer

Overrides:

staticJoin in class JoinSetComposerImpl

Returns:

static join result