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

Class JoinPreloadMethodImpl

java.lang.Object
com.espertech.esper.common.internal.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 Details

    • JoinPreloadMethodImpl

      public JoinPreloadMethodImpl(int numStreams, JoinSetComposer joinSetComposer)
      Ctor.
      Parameters:
      numStreams - number of streams
      joinSetComposer - the composer holding stream indexes

  • Method Details

    • 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