public interface RegexPartitionStateRepo
Modifier and Type | Method and Description |
---|---|
void |
accept(EventRowRegexNFAViewServiceVisitor visitor) |
RegexPartitionStateRepo |
copyForIterate(boolean forOutOfOrderReprocessing)
Copy state for iteration.
|
void |
destroy() |
RegexPartitionStateRepoScheduleState |
getScheduleState() |
RegexPartitionState |
getState(EventBean theEvent,
boolean isCollect)
Return state for event or create state if not found.
|
RegexPartitionState |
getState(Object key)
Return state for key or create state if not found.
|
int |
getStateCount() |
int |
incrementAndGetEventSequenceNum() |
boolean |
isPartitioned() |
int |
removeOld(EventBean[] events,
boolean isEmpty,
boolean[] found)
Remove old events from the state, applicable for "prev" function and partial NFA state.
|
void |
removeState(Object partitionKey) |
void |
setEventSequenceNum(int num) |
RegexPartitionState getState(Object key)
key
- to look upRegexPartitionState getState(EventBean theEvent, boolean isCollect)
theEvent
- to look upisCollect
- true if a collection of unused state can occurint removeOld(EventBean[] events, boolean isEmpty, boolean[] found)
events
- to removeisEmpty
- indicator if there are not matchesfound
- indicator if any partial matches exist to be deletedRegexPartitionStateRepo copyForIterate(boolean forOutOfOrderReprocessing)
forOutOfOrderReprocessing
- indicator whether we are processing out-of-order eventsvoid removeState(Object partitionKey)
void accept(EventRowRegexNFAViewServiceVisitor visitor)
boolean isPartitioned()
int getStateCount()
int incrementAndGetEventSequenceNum()
void setEventSequenceNum(int num)
RegexPartitionStateRepoScheduleState getScheduleState()
void destroy()