com.espertech.esper.rowregex

Class EventRowRegexNFAViewFactory

java.lang.Object

com.espertech.esper.view.ViewFactorySupport

com.espertech.esper.rowregex.EventRowRegexNFAViewFactory

All Implemented Interfaces:

ViewFactory

public class EventRowRegexNFAViewFactory
extends ViewFactorySupport

View factory for match-recognize view.

Field Summary

Fields

Modifier and Type	Field and Description
protected List<AggregationServiceAggExpressionDesc>	aggregationExpressions
protected AggregationServiceMatchRecognize	aggregationService
protected RegexNFAState[]	allStates
protected TreeMap<Integer,List<ExprPreviousMatchRecognizeNode>>	callbacksPerIndex
protected ExprEvaluator[]	columnEvaluators
protected String[]	columnNames
protected ObjectArrayEventType	compositeEventType
protected ObjectArrayBackedEventBean	defineMultimatchEventBean
protected RowRegexExprNode	expandedPatternNode
protected boolean	isCollectMultimatches
protected boolean	isDefineAsksMultimatches
protected boolean[]	isExprRequiresMultimatchState
protected boolean	isIterateOnly
protected boolean	isOrTerminated
protected boolean	isTrackMaxStates
protected boolean	isUnbound
protected ConfigurationEngineDefaults.MatchRecognize	matchRecognizeConfig
protected MatchRecognizeSpec	matchRecognizeSpec
protected int[]	multimatchStreamNumToVariable
protected String[]	multimatchVariablesArray
protected int[]	multimatchVariableToStreamNum
protected int	numEventsEventsPerStreamDefine
protected ExprEvaluator[]	partitionByEvals
protected EventType	rowEventType
protected RegexNFAState[]	startStates
protected Map<Integer,String>	streamVariables
protected HashMap<String,Pair<ExprNode,ExprEvaluator>>	variableDefinitions
protected Set<String>	variablesSingle
protected LinkedHashMap<String,Pair<Integer,Boolean>>	variableStreams

Constructor Summary

Constructors

Constructor and Description
EventRowRegexNFAViewFactory(ViewFactoryChain viewChain, MatchRecognizeSpec matchRecognizeSpec, AgentInstanceContext agentInstanceContext, boolean isUnbound, Annotation[] annotations, ConfigurationEngineDefaults.MatchRecognize matchRecognizeConfig) 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.
List<AggregationServiceAggExpressionDesc>	getAggregationExpressions()
AggregationServiceMatchRecognize	getAggregationService()
RegexNFAState[]	getAllStates()
EventType	getEventType() Returns the event type that the view that is created by the view factory would create for events posted by the view.
int	getNumEventsEventsPerStreamDefine()
Set<ExprPreviousMatchRecognizeNode>	getPreviousExprNodes()
String	getViewName() Returns the name of the view, not namespace+name but readable name.
View	makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) Create a new view.
void	setViewParameters(ViewFactoryContext viewFactoryContext, List<ExprNode> viewParameters) Indicates user EPL query view parameters to the view factory.

Methods inherited from class com.espertech.esper.view.ViewFactorySupport

assertReturnsNonConstant, canReuse, evaluate, evaluateAssertNoProperties, evaluateSizeParam, validate, validate, validateAndEvaluate, validateAndEvaluateExpr, validateExpr, validateNoParameters, validateNoProperties, validateSizeParam, validateSizeSingleParam

Methods inherited from class java.lang.Object

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

Field Detail

matchRecognizeSpec

protected final MatchRecognizeSpec matchRecognizeSpec

variableStreams

protected final LinkedHashMap<String,Pair<Integer,Boolean>> variableStreams

variableDefinitions

protected final HashMap<String,Pair<ExprNode,ExprEvaluator>> variableDefinitions

streamVariables

protected final Map<Integer,String> streamVariables

variablesSingle

protected final Set<String> variablesSingle

compositeEventType

protected final ObjectArrayEventType compositeEventType

rowEventType

protected final EventType rowEventType

aggregationService

protected final AggregationServiceMatchRecognize aggregationService

aggregationExpressions

protected final List<AggregationServiceAggExpressionDesc> aggregationExpressions

callbacksPerIndex

protected final TreeMap<Integer,List<ExprPreviousMatchRecognizeNode>> callbacksPerIndex

isUnbound

protected final boolean isUnbound

isIterateOnly

protected final boolean isIterateOnly

isCollectMultimatches

protected final boolean isCollectMultimatches

isDefineAsksMultimatches

protected final boolean isDefineAsksMultimatches

defineMultimatchEventBean

protected final ObjectArrayBackedEventBean defineMultimatchEventBean

isExprRequiresMultimatchState

protected final boolean[] isExprRequiresMultimatchState

expandedPatternNode

protected final RowRegexExprNode expandedPatternNode

matchRecognizeConfig

protected final ConfigurationEngineDefaults.MatchRecognize matchRecognizeConfig

columnEvaluators

protected final ExprEvaluator[] columnEvaluators

columnNames

protected final String[] columnNames

partitionByEvals

protected final ExprEvaluator[] partitionByEvals

startStates

protected final RegexNFAState[] startStates

allStates

protected final RegexNFAState[] allStates

multimatchVariablesArray

protected final String[] multimatchVariablesArray

multimatchStreamNumToVariable

protected final int[] multimatchStreamNumToVariable

multimatchVariableToStreamNum

protected final int[] multimatchVariableToStreamNum

numEventsEventsPerStreamDefine

protected final int numEventsEventsPerStreamDefine

isOrTerminated

protected final boolean isOrTerminated

isTrackMaxStates

protected final boolean isTrackMaxStates

Constructor Detail

EventRowRegexNFAViewFactory

public EventRowRegexNFAViewFactory(ViewFactoryChain viewChain,
                                   MatchRecognizeSpec matchRecognizeSpec,
                                   AgentInstanceContext agentInstanceContext,
                                   boolean isUnbound,
                                   Annotation[] annotations,
                                   ConfigurationEngineDefaults.MatchRecognize matchRecognizeConfig)
                            throws ExprValidationException

Ctor.

Parameters:

viewChain - views

matchRecognizeSpec - specification

isUnbound - true for unbound stream

annotations - annotations

matchRecognizeConfig - config

agentInstanceContext - context

Throws:

ExprValidationException - if validation fails

Method Detail

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.

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.

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.

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.

Returns:

event type of view's created by the view factory

getAggregationExpressions

public List<AggregationServiceAggExpressionDesc> getAggregationExpressions()

getAggregationService

public AggregationServiceMatchRecognize getAggregationService()

getPreviousExprNodes

public Set<ExprPreviousMatchRecognizeNode> getPreviousExprNodes()

getViewName

public String getViewName()

Description copied from interface: ViewFactory

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

Returns:

readable name

getAllStates

public RegexNFAState[] getAllStates()

getNumEventsEventsPerStreamDefine

public int getNumEventsEventsPerStreamDefine()