com.espertech.esper.core.service

Class StreamJoinAnalysisResult

java.lang.Object

com.espertech.esper.core.service.StreamJoinAnalysisResult

public class StreamJoinAnalysisResult
extends Object

Analysis result for joins.

Constructor Summary

Constructors

Constructor and Description
StreamJoinAnalysisResult(int numStreams) Ctor.

Method Summary

Modifier and Type	Method and Description
void	addUniquenessInfo(ViewFactoryChain[] unmaterializedViewChain, Annotation[] annotations)
boolean[]	getHasChildViews() Returns child view flags.
boolean[]	getNamedWindow() Return named window flags.
int	getNumStreams() Returns streams num.
TableMetadata[]	getTablesPerStream()
int	getUnidirectionalCount()
boolean[]	getUnidirectionalInd() Returns unidirection ind.
boolean[]	getUnidirectionalNonDriving() Returns non-driving unidirectional streams when partial self-joins.
int	getUnidirectionalStreamNumberFirst()
String[][][]	getUniqueKeys()
VirtualDWViewProviderForAgentInstance[]	getViewExternal()
boolean	isPureSelfJoin() True for self-join.
boolean	isUnidirectional()
boolean	isUnidirectionalAll()
void	setHasChildViews(int index) Sets child view flags.
void	setNamedWindow(int index) Sets named window flag
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

StreamJoinAnalysisResult

public StreamJoinAnalysisResult(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

getUnidirectionalNonDriving

public boolean[] getUnidirectionalNonDriving()

Returns non-driving unidirectional streams when partial self-joins.

Returns:

indicators

isPureSelfJoin

public boolean isPureSelfJoin()

True for self-join.

Returns:

self-join

getHasChildViews

public boolean[] getHasChildViews()

Returns child view flags.

Returns:

flags

getNamedWindow

public boolean[] getNamedWindow()

Return named window flags.

Returns:

flags

setNamedWindow

public void setNamedWindow(int index)

Sets named window flag

Parameters:

index - to set

getNumStreams

public int getNumStreams()

Returns streams num.

Returns:

num

getViewExternal

public VirtualDWViewProviderForAgentInstance[] getViewExternal()

getUniqueKeys

public String[][][] getUniqueKeys()

setTablesForStream

public void setTablesForStream(int streamNum,
                               TableMetadata metadata)

getTablesPerStream

public TableMetadata[] getTablesPerStream()

addUniquenessInfo

public void addUniquenessInfo(ViewFactoryChain[] unmaterializedViewChain,
                              Annotation[] annotations)

isUnidirectional

public boolean isUnidirectional()

getUnidirectionalStreamNumberFirst

public int getUnidirectionalStreamNumberFirst()

isUnidirectionalAll

public boolean isUnidirectionalAll()

getUnidirectionalCount

public int getUnidirectionalCount()