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

Class RowRecogPartitionStateRepoGroup

java.lang.Object

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

All Implemented Interfaces:

RowRecogPartitionStateRepo

public class RowRecogPartitionStateRepoGroup
extends Object
implements RowRecogPartitionStateRepo

Partition-by implementation for partition state.

Field Summary

Fields

Modifier and Type	Field and Description
static int	INITIAL_COLLECTION_MIN Empty state collection initial threshold.

Constructor Summary

Constructors

Constructor and Description
RowRecogPartitionStateRepoGroup(RowRecogPreviousStrategyImpl getter, RowRecogPartitionStateRepoGroupMeta meta, boolean keepScheduleState, RowRecogPartitionTerminationStateComparator terminationStateCompare)

Method Summary

Modifier and Type	Method and Description
void	accept(RowRecogNFAViewServiceVisitor visitor)
RowRecogPartitionStateRepo	copyForIterate(boolean forOutOfOrderReprocessing) Copy state for iteration.
void	destroy()
static Object	getKeys(EventBean theEvent, RowRecogPartitionStateRepoGroupMeta meta)
RowRecogPartitionStateRepoScheduleState	getScheduleState()
RowRecogPartitionStateImpl	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()
Map<Object,RowRecogPartitionStateImpl>	getStates()
int	incrementAndGetEventSequenceNum()
boolean	isPartitioned()
int	removeOld(EventBean[] oldData, 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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

INITIAL_COLLECTION_MIN

public static final int INITIAL_COLLECTION_MIN

Empty state collection initial threshold.

See Also:

Constant Field Values

Constructor Detail

RowRecogPartitionStateRepoGroup

public RowRecogPartitionStateRepoGroup(RowRecogPreviousStrategyImpl getter,
                                       RowRecogPartitionStateRepoGroupMeta meta,
                                       boolean keepScheduleState,
                                       RowRecogPartitionTerminationStateComparator terminationStateCompare)

Method Detail

incrementAndGetEventSequenceNum

public int incrementAndGetEventSequenceNum()

Specified by:

incrementAndGetEventSequenceNum in interface RowRecogPartitionStateRepo

setEventSequenceNum

public void setEventSequenceNum(int num)

Specified by:

setEventSequenceNum in interface RowRecogPartitionStateRepo

getScheduleState

public RowRecogPartitionStateRepoScheduleState getScheduleState()

Specified by:

getScheduleState in interface RowRecogPartitionStateRepo

removeState

public void removeState(Object partitionKey)

Specified by:

removeState in interface RowRecogPartitionStateRepo

copyForIterate

public RowRecogPartitionStateRepo copyForIterate(boolean forOutOfOrderReprocessing)

Description copied from interface: RowRecogPartitionStateRepo

Copy state for iteration.

Specified by:

copyForIterate in interface RowRecogPartitionStateRepo

Parameters:

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

Returns:

copied state

removeOld

public int removeOld(EventBean[] oldData,
                     boolean isEmpty,
                     boolean[] found)

Description copied from interface: RowRecogPartitionStateRepo

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

Specified by:

removeOld in interface RowRecogPartitionStateRepo

Parameters:

oldData - to remove

isEmpty - indicator if there are not matches

found - indicator if any partial matches exist to be deleted

Returns:

number removed

getState

public RowRecogPartitionState getState(Object key)

Description copied from interface: RowRecogPartitionStateRepo

Return state for key or create state if not found.

Specified by:

getState in interface RowRecogPartitionStateRepo

Parameters:

key - to look up

Returns:

state

getState

public RowRecogPartitionStateImpl getState(EventBean theEvent,
                                           boolean isCollect)

Description copied from interface: RowRecogPartitionStateRepo

Return state for event or create state if not found.

Specified by:

getState in interface RowRecogPartitionStateRepo

Parameters:

theEvent - to look up

isCollect - true if a collection of unused state can occur

Returns:

state

accept

public void accept(RowRecogNFAViewServiceVisitor visitor)

Specified by:

accept in interface RowRecogPartitionStateRepo

isPartitioned

public boolean isPartitioned()

Specified by:

isPartitioned in interface RowRecogPartitionStateRepo

getStates

public Map<Object,RowRecogPartitionStateImpl> getStates()

getStateCount

public int getStateCount()

Specified by:

getStateCount in interface RowRecogPartitionStateRepo

getKeys

public static Object getKeys(EventBean theEvent,
                             RowRecogPartitionStateRepoGroupMeta meta)

destroy

public void destroy()

Specified by:

destroy in interface RowRecogPartitionStateRepo