Class RowRecogDesc
java.lang.Object
com.espertech.esper.common.internal.epl.rowrecog.core.RowRecogDesc
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionString[]
int[]
String[]
int[]
int
EPType[]
int[]
getSkip()
int[]
boolean
boolean
boolean
boolean
boolean
boolean
boolean
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 partitionEvalSerde) void
setPartitionEvalTypes
(EPType[] partitionEvalTypes) void
setPartitionMgmtStateMgmtSettings
(StateMgmtSetting partitionMgmtStateMgmtSettings) void
setPreviousRandomAccessIndexes
(int[] previousRandomAccessIndexes) void
setRowEventType
(EventType rowEventType) void
setScheduleMgmtStateMgmtSettings
(StateMgmtSetting scheduleMgmtStateMgmtSettings) void
void
setStartStates
(int[] startStates) void
setStatesOrdered
(RowRecogNFAStateBase[] statesOrdered) void
setUnbound
(boolean unbound) void
setVariableStreams
(LinkedHashMap<String, Pair<Integer, Boolean>> variableStreams)
-
Field Details
-
EPTYPE
-
-
Constructor Details
-
RowRecogDesc
public RowRecogDesc()
-
-
Method Details
-
getParentEventType
-
setParentEventType
-
getMultimatchEventType
-
setMultimatchEventType
-
setRowEventType
-
getRowEventType
-
getCompositeEventType
-
setCompositeEventType
-
setMultimatchStreamNumToVariable
public void setMultimatchStreamNumToVariable(int[] multimatchStreamNumToVariable) -
setPartitionEvalMayNull
-
getPartitionEvalTypes
-
setPartitionEvalTypes
-
getPartitionEvalSerde
-
setPartitionEvalSerde
-
getMultimatchStreamNumToVariable
public int[] getMultimatchStreamNumToVariable() -
getPartitionEvalMayNull
-
getVariableStreams
-
setVariableStreams
-
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
-
setMultimatchVariablesArray
-
getStatesOrdered
-
setStatesOrdered
-
getNextStatesPerState
-
setNextStatesPerState
-
getStartStates
public int[] getStartStates() -
setStartStates
public void setStartStates(int[] startStates) -
isAllMatches
public boolean isAllMatches() -
setAllMatches
public void setAllMatches(boolean allMatches) -
getSkip
-
setSkip
-
getColumnEvaluators
-
setColumnEvaluators
-
getColumnNames
-
setColumnNames
-
getMultimatchVariableToStreamNum
public int[] getMultimatchVariableToStreamNum() -
setMultimatchVariableToStreamNum
public void setMultimatchVariableToStreamNum(int[] multimatchVariableToStreamNum) -
getIntervalCompute
-
setIntervalCompute
-
getPreviousRandomAccessIndexes
public int[] getPreviousRandomAccessIndexes() -
setPreviousRandomAccessIndexes
public void setPreviousRandomAccessIndexes(int[] previousRandomAccessIndexes) -
getAggregationServiceFactories
-
setAggregationServiceFactories
-
getAggregationResultFutureAssignables
-
setAggregationResultFutureAssignables
public void setAggregationResultFutureAssignables(AggregationResultFutureAssignable[] aggregationResultFutureAssignables) -
getPartitionMgmtStateMgmtSettings
-
setPartitionMgmtStateMgmtSettings
-
getScheduleMgmtStateMgmtSettings
-
setScheduleMgmtStateMgmtSettings
-