com.espertech.esper.core.service
Class StreamJoinAnalysisResult

java.lang.Object
  com.espertech.esper.core.service.StreamJoinAnalysisResult

public class StreamJoinAnalysisResult
extends java.lang.Object

Analysis result for joins.

Constructor Summary

StreamJoinAnalysisResult(int numStreams)
Ctor.

Method Summary

void	addUniquenessInfo(ViewFactoryChain[] unmaterializedViewChain, java.lang.annotation.Annotation[] annotations)
boolean[]	getHasChildViews() Returns child view flags.
boolean[]	getNamedWindow() Return named window flags.
int	getNumStreams() Returns streams num.
TableMetadata[]	getTablesPerStream()
boolean[]	getUnidirectionalInd() Returns unidirection ind.
boolean[]	getUnidirectionalNonDriving() Returns non-driving unidirectional streams when partial self-joins.
int	getUnidirectionalStreamNumber() Returns unidirectional stream number.
java.lang.String[][][]	getUniqueKeys()
VirtualDWViewProviderForAgentInstance[]	getViewExternal()
boolean	isPureSelfJoin() True for self-join.
boolean	isUnidirectional() Returns unidirectional flag.
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.
void	setUnidirectionalStreamNumber(int unidirectionalStreamNumber) 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

isUnidirectional

public boolean isUnidirectional()

Returns unidirectional flag.

Returns:

unidirectional flag

getUnidirectionalStreamNumber

public int getUnidirectionalStreamNumber()

Returns unidirectional stream number.

Returns:

num

setUnidirectionalStreamNumber

public void setUnidirectionalStreamNumber(int unidirectionalStreamNumber)

Sets flag.

Parameters:

unidirectionalStreamNumber - index

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 java.lang.String[][][] getUniqueKeys()

setTablesForStream

public void setTablesForStream(int streamNum,
                               TableMetadata metadata)

getTablesPerStream

public TableMetadata[] getTablesPerStream()

addUniquenessInfo

public void addUniquenessInfo(ViewFactoryChain[] unmaterializedViewChain,
                              java.lang.annotation.Annotation[] annotations)