Package com.espertech.esper.common.internal.epl.rowrecog.state

Interface RowRecogPartitionStateRepo

All Known Implementing Classes:

RowRecogPartitionStateRepoGroup, RowRecogPartitionStateRepoNoGroup

public interface RowRecogPartitionStateRepo

Service for holding partition state.

Method Summary

Modifier and Type	Method	Description
void	accept(RowRecogNFAViewServiceVisitor visitor)
RowRecogPartitionStateRepo	copyForIterate(boolean forOutOfOrderReprocessing)	Copy state for iteration.
void	destroy()
RowRecogPartitionStateRepoScheduleState	getScheduleState()
RowRecogPartitionState	getState(EventBean theEvent, boolean isCollect)	Return state for event or create state if not found.
RowRecogPartitionState	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)

Method Details

getState

RowRecogPartitionState getState(Object key)

Return state for key or create state if not found.

Parameters:

key - to look up

Returns:

state

getState

RowRecogPartitionState 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

Returns:

number removed

copyForIterate

RowRecogPartitionStateRepo copyForIterate(boolean forOutOfOrderReprocessing)

Copy state for iteration.

Parameters:

forOutOfOrderReprocessing - indicator whether we are processing out-of-order events

Returns:

copied state

removeState

void removeState(Object partitionKey)

accept

void accept(RowRecogNFAViewServiceVisitor visitor)

isPartitioned

boolean isPartitioned()

getStateCount

int getStateCount()

incrementAndGetEventSequenceNum

int incrementAndGetEventSequenceNum()

setEventSequenceNum

void setEventSequenceNum(int num)

getScheduleState

RowRecogPartitionStateRepoScheduleState getScheduleState()

destroy

void destroy()