Package | Description |
---|---|
com.espertech.esper.common.internal.epl.rowrecog.core |
Match-recognize core.
|
com.espertech.esper.common.internal.epl.rowrecog.state |
Match-recognize state management.
|
com.espertech.esper.common.internal.metrics.instrumentation |
Modifier and Type | Field and Description |
---|---|
protected static Comparator<RowRecogNFAStateEntry> |
RowRecogHelper.END_STATE_COMPARATOR |
Modifier and Type | Method and Description |
---|---|
List<RowRecogNFAStateEntry> |
RowRecogIteratorResult.getEndStates()
Returns the end states
|
Modifier and Type | Method and Description |
---|---|
int |
RowRecogPartitionTerminationStateComparator.compare(RowRecogNFAStateEntry o1,
RowRecogNFAStateEntry o2) |
boolean |
RowRecogPartitionTerminationStateComparator.compareTerminationStateToEndState(RowRecogNFAStateEntry terminationState,
RowRecogNFAStateEntry endState) |
protected static EventBean[] |
RowRecogNFAViewUtil.getMultimatchArray(int[] multimatchStreamNumToVariable,
RowRecogNFAStateEntry state,
int stream) |
Modifier and Type | Method and Description |
---|---|
protected static String |
RowRecogNFAViewUtil.printStates(List<RowRecogNFAStateEntry> states,
Map<Integer,String> streamsVariables,
LinkedHashMap<String,Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable) |
Constructor and Description |
---|
RowRecogIteratorResult(List<RowRecogNFAStateEntry> endStates,
int eventSequenceNum)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
List<RowRecogNFAStateEntry> |
RowRecogPartitionStateImpl.getCurrentStatesForPrint() |
List<RowRecogNFAStateEntry> |
RowRecogPartitionState.getCurrentStatesForPrint() |
Iterator<RowRecogNFAStateEntry> |
RowRecogPartitionStateImpl.getCurrentStatesIterator()
Returns partial matches.
|
Iterator<RowRecogNFAStateEntry> |
RowRecogPartitionState.getCurrentStatesIterator() |
static List<RowRecogNFAStateEntry> |
RowRecogPartitionStateImpl.removeEventFromState(EventBean oldEvent,
Iterator<RowRecogNFAStateEntry> states) |
Modifier and Type | Method and Description |
---|---|
boolean |
RowRecogPartitionStateRepoScheduleStateImpl.findRemoveAddToList(long matchBeginTime,
RowRecogNFAStateEntry state,
List<RowRecogNFAStateEntry> foundStates) |
boolean |
RowRecogPartitionStateRepoScheduleState.findRemoveAddToList(long matchBeginTime,
RowRecogNFAStateEntry state,
List<RowRecogNFAStateEntry> foundStates)
Find and remove operation, wherein removed items are added to the found list,
returning an indicator whether the item was found and removed
|
boolean |
RowRecogPartitionStateRepoScheduleStateImpl.putOrAdd(long matchBeginTime,
RowRecogNFAStateEntry state) |
boolean |
RowRecogPartitionStateRepoScheduleState.putOrAdd(long matchBeginTime,
RowRecogNFAStateEntry state)
Add entry returning true if the key did not exist.
|
Modifier and Type | Method and Description |
---|---|
boolean |
RowRecogPartitionStateRepoScheduleStateImpl.findRemoveAddToList(long matchBeginTime,
RowRecogNFAStateEntry state,
List<RowRecogNFAStateEntry> foundStates) |
boolean |
RowRecogPartitionStateRepoScheduleState.findRemoveAddToList(long matchBeginTime,
RowRecogNFAStateEntry state,
List<RowRecogNFAStateEntry> foundStates)
Find and remove operation, wherein removed items are added to the found list,
returning an indicator whether the item was found and removed
|
void |
RowRecogPartitionStateRepoScheduleStateImpl.removeAddRemoved(long matchBeginTime,
List<RowRecogNFAStateEntry> foundStates) |
void |
RowRecogPartitionStateRepoScheduleState.removeAddRemoved(long matchBeginTime,
List<RowRecogNFAStateEntry> foundStates) |
static List<RowRecogNFAStateEntry> |
RowRecogPartitionStateImpl.removeEventFromState(EventBean oldEvent,
Iterator<RowRecogNFAStateEntry> states) |
void |
RowRecogPartitionStateImpl.setCurrentStates(List<RowRecogNFAStateEntry> currentStates)
Sets partial matches.
|
void |
RowRecogPartitionState.setCurrentStates(List<RowRecogNFAStateEntry> currentStates) |
Constructor and Description |
---|
RowRecogPartitionStateImpl(RowRecogPreviousStrategyImpl getter,
List<RowRecogNFAStateEntry> currentStates)
Ctor.
|
RowRecogPartitionStateImpl(RowRecogPreviousStrategyImpl getter,
List<RowRecogNFAStateEntry> currentStates,
Object optionalKeys)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
void |
InstrumentationCommonDefault.qRegExState(RowRecogNFAStateEntry currentState,
LinkedHashMap<String,Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable) |
void |
InstrumentationCommon.qRegExState(RowRecogNFAStateEntry currentState,
LinkedHashMap<String,Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable) |
void |
InstrumentationCommonDefault.qRegIntervalState(RowRecogNFAStateEntry endState,
LinkedHashMap<String,Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable,
long runtimeTime) |
void |
InstrumentationCommon.qRegIntervalState(RowRecogNFAStateEntry endState,
LinkedHashMap<String,Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable,
long runtimeTime) |
void |
InstrumentationCommonDefault.qRegMeasure(RowRecogNFAStateEntry endState,
LinkedHashMap<String,Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable) |
void |
InstrumentationCommon.qRegMeasure(RowRecogNFAStateEntry endState,
LinkedHashMap<String,Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable) |
Modifier and Type | Method and Description |
---|---|
void |
InstrumentationCommonDefault.aRegEx(RowRecogPartitionState partitionState,
List<RowRecogNFAStateEntry> endStates,
List<RowRecogNFAStateEntry> terminationStates) |
void |
InstrumentationCommonDefault.aRegEx(RowRecogPartitionState partitionState,
List<RowRecogNFAStateEntry> endStates,
List<RowRecogNFAStateEntry> terminationStates) |
void |
InstrumentationCommon.aRegEx(RowRecogPartitionState partitionState,
List<RowRecogNFAStateEntry> endStates,
List<RowRecogNFAStateEntry> terminationStates) |
void |
InstrumentationCommon.aRegEx(RowRecogPartitionState partitionState,
List<RowRecogNFAStateEntry> endStates,
List<RowRecogNFAStateEntry> terminationStates) |
void |
InstrumentationCommonDefault.aRegExState(List<RowRecogNFAStateEntry> next,
LinkedHashMap<String,Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable) |
void |
InstrumentationCommon.aRegExState(List<RowRecogNFAStateEntry> next,
LinkedHashMap<String,Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable) |
void |
InstrumentationCommonDefault.aRegExStateStart(List<RowRecogNFAStateEntry> nextStates,
LinkedHashMap<String,Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable) |
void |
InstrumentationCommon.aRegExStateStart(List<RowRecogNFAStateEntry> nextStates,
LinkedHashMap<String,Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable) |
Copyright © 2005–2018. All rights reserved.