Package com.espertech.esper.common.internal.context.aifactory.select

Class StreamJoinAnalysisResultCompileTime

java.lang.Object
com.espertech.esper.common.internal.context.aifactory.select.StreamJoinAnalysisResultCompileTime
public class StreamJoinAnalysisResultCompileTime extends Object
Analysis result for joins.

  • Constructor Details

    • StreamJoinAnalysisResultCompileTime

      public StreamJoinAnalysisResultCompileTime(int numStreams)
      Ctor.
      Parameters:
      numStreams - number of streams

  • Method Details

    • setUnidirectionalInd

      public void setUnidirectionalInd(int index)
      Sets flag.
      Parameters:
      index - index

    • setUnidirectionalNonDriving

      public void setUnidirectionalNonDriving(int index)
      Sets flag.
      Parameters:
      index - index

    • setPureSelfJoin

      public void setPureSelfJoin(boolean pureSelfJoin)
      Sets self-join.
      Parameters:
      pureSelfJoin - if a self join

    • setHasChildViews

      public void setHasChildViews(int index)
      Sets child view flags.
      Parameters:
      index - to set

    • getUnidirectionalInd

      public boolean[] getUnidirectionalInd()
      Returns unidirection ind.
      Returns:
      unidirectional flags

    • getHasChildViews

      public boolean[] getHasChildViews()
      Returns child view flags.
      Returns:
      flags

    • getNamedWindowsPerStream

      public NamedWindowMetaData[] getNamedWindowsPerStream()

    • setNamedWindowsPerStream

      public void setNamedWindowsPerStream(int streamNum, NamedWindowMetaData metadata)

    • getNumStreams

      public int getNumStreams()
      Returns streams num.
      Returns:
      num

    • getUniqueKeys

      public String[][][] getUniqueKeys()

    • setTablesForStream

      public void setTablesForStream(int streamNum, TableMetaData metadata)

    • getTablesPerStream

      public TableMetaData[] getTablesPerStream()

    • hasTables

      public boolean hasTables()

    • addUniquenessInfo

      public void addUniquenessInfo(List<ViewFactoryForge>[] unmaterializedViewChain, Annotation[] annotations)

    • isUnidirectional

      public boolean isUnidirectional()

    • isUnidirectionalAll

      public boolean isUnidirectionalAll()

    • isPureSelfJoin

      public boolean isPureSelfJoin()

    • getUnidirectionalCount

      public int getUnidirectionalCount()

    • make

      public CodegenExpression make(CodegenMethodScope parent, SAIFFInitializeSymbol symbols, CodegenClassScope classScope)

    • isVirtualDW

      public boolean isVirtualDW(int stream)

    • getUniqueCandidateProperties

      public static Set<String> getUniqueCandidateProperties(List<ViewFactoryForge> forges, Annotation[] annotations)