com.espertech.esper.common.internal.epl.rowrecog.core

Class RowRecogDesc

java.lang.Object

com.espertech.esper.common.internal.epl.rowrecog.core.RowRecogDesc

public class RowRecogDesc
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static EPTypeClass	EPTYPE

Constructor Summary

Constructors

Constructor and Description
RowRecogDesc()

Method Summary

Modifier and Type	Method and Description
AggregationResultFutureAssignable[]	getAggregationResultFutureAssignables()
AggregationServiceFactory[]	getAggregationServiceFactories()
ExprEvaluator[]	getColumnEvaluators()
String[]	getColumnNames()
EventType	getCompositeEventType()
TimePeriodCompute	getIntervalCompute()
EventType	getMultimatchEventType()
int[]	getMultimatchStreamNumToVariable()
String[]	getMultimatchVariablesArray()
int[]	getMultimatchVariableToStreamNum()
List<Pair<Integer,int[]>>	getNextStatesPerState()
int	getNumEventsEventsPerStreamDefine()
EventType	getParentEventType()
ExprEvaluator	getPartitionEvalMayNull()
DataInputOutputSerde<Object>	getPartitionEvalSerde()
EPType[]	getPartitionEvalTypes()
StateMgmtSetting	getPartitionMgmtStateMgmtSettings()
int[]	getPreviousRandomAccessIndexes()
EventType	getRowEventType()
StateMgmtSetting	getScheduleMgmtStateMgmtSettings()
MatchRecognizeSkipEnum	getSkip()
int[]	getStartStates()
RowRecogNFAStateBase[]	getStatesOrdered()
LinkedHashMap<String,Pair<Integer,Boolean>>	getVariableStreams()
boolean	isAllMatches()
boolean	isCollectMultimatches()
boolean	isDefineAsksMultimatches()
boolean	isHasInterval()
boolean	isIterateOnly()
boolean	isOrTerminated()
boolean	isUnbound()
void	setAggregationResultFutureAssignables(AggregationResultFutureAssignable[] aggregationResultFutureAssignables)
void	setAggregationServiceFactories(AggregationServiceFactory[] aggregationServiceFactories)
void	setAllMatches(boolean allMatches)
void	setCollectMultimatches(boolean collectMultimatches)
void	setColumnEvaluators(ExprEvaluator[] columnEvaluators)
void	setColumnNames(String[] columnNames)
void	setCompositeEventType(EventType compositeEventType)
void	setDefineAsksMultimatches(boolean defineAsksMultimatches)
void	setHasInterval(boolean hasInterval)
void	setIntervalCompute(TimePeriodCompute intervalCompute)
void	setIterateOnly(boolean iterateOnly)
void	setMultimatchEventType(EventType multimatchEventType)
void	setMultimatchStreamNumToVariable(int[] multimatchStreamNumToVariable)
void	setMultimatchVariablesArray(String[] multimatchVariablesArray)
void	setMultimatchVariableToStreamNum(int[] multimatchVariableToStreamNum)
void	setNextStatesPerState(List<Pair<Integer,int[]>> nextStatesPerState)
void	setNumEventsEventsPerStreamDefine(int numEventsEventsPerStreamDefine)
void	setOrTerminated(boolean orTerminated)
void	setParentEventType(EventType parentEventType)
void	setPartitionEvalMayNull(ExprEvaluator partitionEvalMayNull)
void	setPartitionEvalSerde(DataInputOutputSerde<Object> partitionEvalSerde)
void	setPartitionEvalTypes(EPType[] partitionEvalTypes)
void	setPartitionMgmtStateMgmtSettings(StateMgmtSetting partitionMgmtStateMgmtSettings)
void	setPreviousRandomAccessIndexes(int[] previousRandomAccessIndexes)
void	setRowEventType(EventType rowEventType)
void	setScheduleMgmtStateMgmtSettings(StateMgmtSetting scheduleMgmtStateMgmtSettings)
void	setSkip(MatchRecognizeSkipEnum skip)
void	setStartStates(int[] startStates)
void	setStatesOrdered(RowRecogNFAStateBase[] statesOrdered)
void	setUnbound(boolean unbound)
void	setVariableStreams(LinkedHashMap<String,Pair<Integer,Boolean>> variableStreams)

Methods inherited from class java.lang.Object

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

Field Detail

EPTYPE

public static final EPTypeClass EPTYPE

Constructor Detail

RowRecogDesc

public RowRecogDesc()

Method Detail

getParentEventType

public EventType getParentEventType()

setParentEventType

public void setParentEventType(EventType parentEventType)

getMultimatchEventType

public EventType getMultimatchEventType()

setMultimatchEventType

public void setMultimatchEventType(EventType multimatchEventType)

setRowEventType

public void setRowEventType(EventType rowEventType)

getRowEventType

public EventType getRowEventType()

getCompositeEventType

public EventType getCompositeEventType()

setCompositeEventType

public void setCompositeEventType(EventType compositeEventType)

setMultimatchStreamNumToVariable

public void setMultimatchStreamNumToVariable(int[] multimatchStreamNumToVariable)

setPartitionEvalMayNull

public void setPartitionEvalMayNull(ExprEvaluator partitionEvalMayNull)

getPartitionEvalTypes

public EPType[] getPartitionEvalTypes()

setPartitionEvalTypes

public void setPartitionEvalTypes(EPType[] partitionEvalTypes)

getPartitionEvalSerde

public DataInputOutputSerde<Object> getPartitionEvalSerde()

setPartitionEvalSerde

public void setPartitionEvalSerde(DataInputOutputSerde<Object> partitionEvalSerde)

getMultimatchStreamNumToVariable

public int[] getMultimatchStreamNumToVariable()

getPartitionEvalMayNull

public ExprEvaluator getPartitionEvalMayNull()

getVariableStreams

public LinkedHashMap<String,Pair<Integer,Boolean>> getVariableStreams()

setVariableStreams

public void setVariableStreams(LinkedHashMap<String,Pair<Integer,Boolean>> variableStreams)

isHasInterval

public boolean isHasInterval()

setHasInterval

public void setHasInterval(boolean hasInterval)

isIterateOnly

public boolean isIterateOnly()

setIterateOnly

public void setIterateOnly(boolean iterateOnly)

isUnbound

public boolean isUnbound()

setUnbound

public void setUnbound(boolean unbound)

isOrTerminated

public boolean isOrTerminated()

setOrTerminated

public void setOrTerminated(boolean orTerminated)

isCollectMultimatches

public boolean isCollectMultimatches()

setCollectMultimatches

public void setCollectMultimatches(boolean collectMultimatches)

isDefineAsksMultimatches

public boolean isDefineAsksMultimatches()

setDefineAsksMultimatches

public void setDefineAsksMultimatches(boolean defineAsksMultimatches)

getNumEventsEventsPerStreamDefine

public int getNumEventsEventsPerStreamDefine()

setNumEventsEventsPerStreamDefine

public void setNumEventsEventsPerStreamDefine(int numEventsEventsPerStreamDefine)

getMultimatchVariablesArray

public String[] getMultimatchVariablesArray()

setMultimatchVariablesArray

public void setMultimatchVariablesArray(String[] multimatchVariablesArray)

getStatesOrdered

public RowRecogNFAStateBase[] getStatesOrdered()

setStatesOrdered

public void setStatesOrdered(RowRecogNFAStateBase[] statesOrdered)

getNextStatesPerState

public List<Pair<Integer,int[]>> getNextStatesPerState()

setNextStatesPerState

public void setNextStatesPerState(List<Pair<Integer,int[]>> nextStatesPerState)

getStartStates

public int[] getStartStates()

setStartStates

public void setStartStates(int[] startStates)

isAllMatches

public boolean isAllMatches()

setAllMatches

public void setAllMatches(boolean allMatches)

getSkip

public MatchRecognizeSkipEnum getSkip()

setSkip

public void setSkip(MatchRecognizeSkipEnum skip)

getColumnEvaluators

public ExprEvaluator[] getColumnEvaluators()

setColumnEvaluators

public void setColumnEvaluators(ExprEvaluator[] columnEvaluators)

getColumnNames

public String[] getColumnNames()

setColumnNames

public void setColumnNames(String[] columnNames)

getMultimatchVariableToStreamNum

public int[] getMultimatchVariableToStreamNum()

setMultimatchVariableToStreamNum

public void setMultimatchVariableToStreamNum(int[] multimatchVariableToStreamNum)

getIntervalCompute

public TimePeriodCompute getIntervalCompute()

setIntervalCompute

public void setIntervalCompute(TimePeriodCompute intervalCompute)

getPreviousRandomAccessIndexes

public int[] getPreviousRandomAccessIndexes()

setPreviousRandomAccessIndexes

public void setPreviousRandomAccessIndexes(int[] previousRandomAccessIndexes)

getAggregationServiceFactories

public AggregationServiceFactory[] getAggregationServiceFactories()

setAggregationServiceFactories

public void setAggregationServiceFactories(AggregationServiceFactory[] aggregationServiceFactories)

getAggregationResultFutureAssignables

public AggregationResultFutureAssignable[] getAggregationResultFutureAssignables()

setAggregationResultFutureAssignables

public void setAggregationResultFutureAssignables(AggregationResultFutureAssignable[] aggregationResultFutureAssignables)

getPartitionMgmtStateMgmtSettings

public StateMgmtSetting getPartitionMgmtStateMgmtSettings()

setPartitionMgmtStateMgmtSettings

public void setPartitionMgmtStateMgmtSettings(StateMgmtSetting partitionMgmtStateMgmtSettings)

getScheduleMgmtStateMgmtSettings

public StateMgmtSetting getScheduleMgmtStateMgmtSettings()

setScheduleMgmtStateMgmtSettings

public void setScheduleMgmtStateMgmtSettings(StateMgmtSetting scheduleMgmtStateMgmtSettings)