com.espertech.esper.rowregex
Interface RegexPartitionStateRepo

All Known Implementing Classes:

RegexPartitionStateRepoGroup, RegexPartitionStateRepoNoGroup

public interface RegexPartitionStateRepo

Service for holding partition state.

Method Summary

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(java.lang.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(java.lang.Object partitionKey)
void	setEventSequenceNum(int num)

Method Detail

getState

RegexPartitionState getState(java.lang.Object key)

Return state for key or create state if not found.

Parameters:

key - to look up

Returns:

state

getState

RegexPartitionState getState(EventBean theEvent,
                             boolean isCollect)

Return state for event or create state if not found.

Parameters:

theEvent - to look up

isCollect - true if a collection of unused state can occur

Returns:

state

removeOld

int removeOld(EventBean[] events,
              boolean isEmpty,
              boolean[] found)

Remove old events from the state, applicable for "prev" function and partial NFA state.

Parameters:

events - to remove

isEmpty - indicator if there are not matches

found - indicator if any partial matches exist to be deleted

copyForIterate

RegexPartitionStateRepo copyForIterate(boolean forOutOfOrderReprocessing)

Copy state for iteration.

Returns:

copied state

removeState

void removeState(java.lang.Object partitionKey)

accept

void accept(EventRowRegexNFAViewServiceVisitor visitor)

isPartitioned

boolean isPartitioned()

getStateCount

int getStateCount()

incrementAndGetEventSequenceNum

int incrementAndGetEventSequenceNum()

setEventSequenceNum

void setEventSequenceNum(int num)

getScheduleState

RegexPartitionStateRepoScheduleState getScheduleState()

destroy

void destroy()