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 Summary

Constructors

Constructor and Description
StreamJoinAnalysisResultCompileTime(int numStreams) Ctor.

Method Summary

Modifier and Type	Method and Description
void	addUniquenessInfo(List<ViewFactoryForge>[] unmaterializedViewChain, Annotation[] annotations)
boolean[]	getHasChildViews() Returns child view flags.
NamedWindowMetaData[]	getNamedWindowsPerStream()
int	getNumStreams() Returns streams num.
TableMetaData[]	getTablesPerStream()
int	getUnidirectionalCount()
boolean[]	getUnidirectionalInd() Returns unidirection ind.
static Set<String>	getUniqueCandidateProperties(List<ViewFactoryForge> forges, Annotation[] annotations)
String[][][]	getUniqueKeys()
boolean	isPureSelfJoin()
boolean	isUnidirectional()
boolean	isUnidirectionalAll()
boolean	isVirtualDW(int stream)
CodegenExpression	make(CodegenMethodScope parent, SAIFFInitializeSymbol symbols, CodegenClassScope classScope)
void	setHasChildViews(int index) Sets child view flags.
void	setNamedWindowsPerStream(int streamNum, NamedWindowMetaData metadata)
void	setPureSelfJoin(boolean pureSelfJoin) Sets self-join.
void	setTablesForStream(int streamNum, TableMetaData metadata)
void	setUnidirectionalInd(int index) Sets flag.
void	setUnidirectionalNonDriving(int index) Sets flag.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamJoinAnalysisResultCompileTime

public StreamJoinAnalysisResultCompileTime(int numStreams)

Ctor.

Parameters:

numStreams - number of streams

Method Detail

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()

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)