com.espertech.esper.epl.join.base

Class JoinPreloadMethodImpl

java.lang.Object

com.espertech.esper.epl.join.base.JoinPreloadMethodImpl

All Implemented Interfaces:

JoinPreloadMethod

public class JoinPreloadMethodImpl
extends Object
implements JoinPreloadMethod

Implements a method for pre-loading (initializing) join indexes from a filled buffer.

Constructor Summary

Constructors

Constructor and Description
JoinPreloadMethodImpl(int numStreams, JoinSetComposer joinSetComposer) Ctor.

Method Summary

Modifier and Type	Method and Description
boolean	isPreloading()
void	preloadAggregation(ResultSetProcessor resultSetProcessor) Initialize the result set process for the purpose of grouping and aggregation from the join result set.
void	preloadFromBuffer(int stream, ExprEvaluatorContext exprEvaluatorContext) Initialize a stream from the stream buffers data.
void	setBuffer(BufferView view, int stream) Sets the buffer for a stream to preload events from.

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinPreloadMethodImpl

public JoinPreloadMethodImpl(int numStreams,
                             JoinSetComposer joinSetComposer)

Ctor.

Parameters:

numStreams - number of streams

joinSetComposer - the composer holding stream indexes

Method Detail

setBuffer

public void setBuffer(BufferView view,
                      int stream)

Sets the buffer for a stream to preload events from.

Specified by:

setBuffer in interface JoinPreloadMethod

Parameters:

view - buffer

stream - the stream number for the buffer

preloadFromBuffer

public void preloadFromBuffer(int stream,
                              ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: JoinPreloadMethod

Initialize a stream from the stream buffers data.

Specified by:

preloadFromBuffer in interface JoinPreloadMethod

Parameters:

stream - to initialize and load indexes

exprEvaluatorContext - evaluator context

preloadAggregation

public void preloadAggregation(ResultSetProcessor resultSetProcessor)

Description copied from interface: JoinPreloadMethod

Initialize the result set process for the purpose of grouping and aggregation from the join result set.

Specified by:

preloadAggregation in interface JoinPreloadMethod

Parameters:

resultSetProcessor - is the grouping and aggregation result processing

isPreloading

public boolean isPreloading()

Specified by:

isPreloading in interface JoinPreloadMethod