com.espertech.esper.view.internal

Class IntersectViewFactory

java.lang.Object

com.espertech.esper.view.internal.IntersectViewFactory

All Implemented Interfaces:

DataWindowViewFactory, DataWindowViewFactoryUniqueCandidate, ViewFactoryContainer, ViewFactory

public class IntersectViewFactory
extends Object
implements ViewFactory, DataWindowViewFactory, DataWindowViewFactoryUniqueCandidate, ViewFactoryContainer

Factory for union-views.

Field Summary

Fields

Modifier and Type	Field and Description
protected ThreadLocal<IntersectAsymetricViewLocalState>	asymetricViewLocalState
protected int	batchViewIndex
protected ThreadLocal<IntersectBatchViewLocalState>	batchViewLocalState
protected ThreadLocal<IntersectDefaultViewLocalState>	defaultViewLocalState
protected boolean	hasAsymetric
protected EventType	parentEventType
protected List<ViewFactory>	viewFactories

Constructor Summary

Constructors

Constructor and Description
IntersectViewFactory() Ctor.

Method Summary

Modifier and Type	Method and Description
void	attach(EventType parentEventType, StatementContext statementContext, ViewFactory optionalParentFactory, List<ViewFactory> parentViewFactories) Attaches the factory to a parent event type such that the factory can validate attach requirements and determine an event type for resulting views.
boolean	canReuse(View view, AgentInstanceContext agentInstanceContext) Determines if the given view could be used instead of creating a new view, requires the view factory to compare view type, parameters and other capabilities provided.
IntersectAsymetricViewLocalState	getAsymetricViewLocalStatePerThread()
int	getBatchViewIndex()
IntersectBatchViewLocalState	getBatchViewLocalStatePerThread()
IntersectDefaultViewLocalState	getDefaultViewLocalStatePerThread()
EventType	getEventType() Returns the event type that the view that is created by the view factory would create for events posted by the view.
EventType	getParentEventType()
Set<String>	getUniquenessCandidatePropertyNames()
Collection<ViewFactory>	getViewFactoriesContained()
String	getViewName() Returns the name of the view, not namespace+name but readable name.
protected static String	getViewNameUnionIntersect(boolean intersect, Collection<ViewFactory> factories)
boolean	isHasAsymetric()
View	makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) Create a new view.
void	setParentEventType(EventType parentEventType) Sets the parent event type.
void	setViewFactories(List<ViewFactory> viewFactories) Sets the view factories.
void	setViewParameters(ViewFactoryContext viewFactoryContext, List<ExprNode> viewParameters) Indicates user EPL query view parameters to the view factory.

Methods inherited from class java.lang.Object

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

Field Detail

parentEventType

protected EventType parentEventType

viewFactories

protected List<ViewFactory> viewFactories

batchViewIndex

protected int batchViewIndex

hasAsymetric

protected boolean hasAsymetric

batchViewLocalState

protected ThreadLocal<IntersectBatchViewLocalState> batchViewLocalState

defaultViewLocalState

protected ThreadLocal<IntersectDefaultViewLocalState> defaultViewLocalState

asymetricViewLocalState

protected ThreadLocal<IntersectAsymetricViewLocalState> asymetricViewLocalState

Constructor Detail

IntersectViewFactory

public IntersectViewFactory()

Ctor.

Method Detail

setParentEventType

public void setParentEventType(EventType parentEventType)

Sets the parent event type.

Parameters:

parentEventType - type

setViewFactories

public void setViewFactories(List<ViewFactory> viewFactories)

Sets the view factories.

Parameters:

viewFactories - factories

setViewParameters

public void setViewParameters(ViewFactoryContext viewFactoryContext,
                              List<ExprNode> viewParameters)
                       throws ViewParameterException

Description copied from interface: ViewFactory

Indicates user EPL query view parameters to the view factory.

Specified by:

setViewParameters in interface ViewFactory

Parameters:

viewFactoryContext - supplied context information for the view factory

viewParameters - is the objects representing the view parameters

Throws:

ViewParameterException - if the parameters don't match view parameter needs

attach

public void attach(EventType parentEventType,
                   StatementContext statementContext,
                   ViewFactory optionalParentFactory,
                   List<ViewFactory> parentViewFactories)
            throws ViewParameterException

Description copied from interface: ViewFactory

Attaches the factory to a parent event type such that the factory can validate attach requirements and determine an event type for resulting views.

Specified by:

attach in interface ViewFactory

Parameters:

parentEventType - is the parent event stream's or view factory's event type

statementContext - contains the services needed for creating a new event type

optionalParentFactory - is null when there is no parent view factory, or contains the parent view factory

parentViewFactories - is a list of all the parent view factories or empty list if there are none

Throws:

ViewParameterException - is thrown to indicate that this view factories's view would not play with the parent view factories view

makeView

public View makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext)

Description copied from interface: ViewFactory

Create a new view.

Specified by:

makeView in interface ViewFactory

Parameters:

agentInstanceViewFactoryContext - context

Returns:

view

getEventType

public EventType getEventType()

Description copied from interface: ViewFactory

Returns the event type that the view that is created by the view factory would create for events posted by the view.

Specified by:

getEventType in interface ViewFactory

Returns:

event type of view's created by the view factory

canReuse

public boolean canReuse(View view,
                        AgentInstanceContext agentInstanceContext)

Description copied from interface: ViewFactory

Determines if the given view could be used instead of creating a new view, requires the view factory to compare view type, parameters and other capabilities provided.

Specified by:

canReuse in interface ViewFactory

Parameters:

view - is the candidate view to compare to

agentInstanceContext - agent instance context

Returns:

true if the given view can be reused instead of creating a new view, or false to indicate the view is not right for reuse

getUniquenessCandidatePropertyNames

public Set<String> getUniquenessCandidatePropertyNames()

Specified by:

getUniquenessCandidatePropertyNames in interface DataWindowViewFactoryUniqueCandidate

getViewName

public String getViewName()

Description copied from interface: ViewFactory

Returns the name of the view, not namespace+name but readable name.

Specified by:

getViewName in interface ViewFactory

Returns:

readable name

getViewFactoriesContained

public Collection<ViewFactory> getViewFactoriesContained()

Specified by:

getViewFactoriesContained in interface ViewFactoryContainer

getViewNameUnionIntersect

protected static String getViewNameUnionIntersect(boolean intersect,
                                                  Collection<ViewFactory> factories)

getParentEventType

public EventType getParentEventType()

getBatchViewIndex

public int getBatchViewIndex()

isHasAsymetric

public boolean isHasAsymetric()

getBatchViewLocalStatePerThread

public IntersectBatchViewLocalState getBatchViewLocalStatePerThread()

getDefaultViewLocalStatePerThread

public IntersectDefaultViewLocalState getDefaultViewLocalStatePerThread()

getAsymetricViewLocalStatePerThread

public IntersectAsymetricViewLocalState getAsymetricViewLocalStatePerThread()