Package com.espertech.esper.common.internal.epl.index.base

Class EventTableIndexServiceImpl

java.lang.Object

com.espertech.esper.common.internal.epl.index.base.EventTableIndexServiceImpl

All Implemented Interfaces:

EventTableIndexService

public class EventTableIndexServiceImpl
extends Object
implements EventTableIndexService

Field Summary

Fields

Modifier and Type	Field	Description
static final EventTableIndexServiceImpl	INSTANCE

Constructor Summary

Constructors

Constructor	Description
EventTableIndexServiceImpl()

Method Summary

Modifier and Type	Method	Description
boolean	allowInitIndex(boolean isRecoveringResilient)
EventTableFactory	createComposite(int indexedStreamNum, EventType eventType, String[] indexProps, EPTypeClass[] indexCoercionTypes, EventPropertyValueGetter indexGetter, MultiKeyFromObjectArray transformFireAndForget, DataInputOutputSerde keySerde, String[] rangeProps, EPTypeClass[] rangeCoercionTypes, EventPropertyValueGetter[] rangeGetters, DataInputOutputSerde[] rangeSerdes, DataInputOutputSerde optionalValueSerde, boolean isFireAndForget)
EventTableFactory	createCustom(String indexName, int indexedStreamNum, EventType eventType, boolean unique, EventAdvancedIndexProvisionRuntime advancedIndexProvisionDesc)
EventTableFactory	createHashedOnly(int indexedStreamNum, EventType eventType, String[] indexProps, MultiKeyFromObjectArray transformFireAndForget, DataInputOutputSerde keySerde, boolean unique, String optionalIndexName, EventPropertyValueGetter getter, DataInputOutputSerde optionalValueSerde, boolean isFireAndForget, StateMgmtSetting stateMgmtSettings)
EventTableFactory	createInArray(int streamNum, EventType eventType, String[] propertyNames, EPTypeClass[] indexTypes, DataInputOutputSerde[] indexSerdes, boolean unique, EventPropertyValueGetter[] getters, boolean isFireAndForget, StateMgmtSetting stateMgmtSettings)
EventTableFactory	createSorted(int indexedStreamNum, EventType eventType, String indexedProp, EPTypeClass indexType, EventPropertyValueGetter getter, DataInputOutputSerde serde, DataInputOutputSerde optionalValueSerde, boolean isFireAndForget, StateMgmtSetting stateMgmtSettings)
EventTableFactory	createUnindexed(int indexedStreamNum, EventType eventType, DataInputOutputSerde optionalValueSerde, boolean isFireAndForget, StateMgmtSetting stateMgmtSettings)

Methods inherited from class java.lang.Object

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

Field Details

INSTANCE

public static final EventTableIndexServiceImpl INSTANCE

Constructor Details

EventTableIndexServiceImpl

public EventTableIndexServiceImpl()

Method Details

allowInitIndex

public boolean allowInitIndex(boolean isRecoveringResilient)

Specified by:

allowInitIndex in interface EventTableIndexService

createHashedOnly

public EventTableFactory createHashedOnly(int indexedStreamNum,
 EventType eventType,
 String[] indexProps,
 MultiKeyFromObjectArray transformFireAndForget,
 DataInputOutputSerde keySerde,
 boolean unique,
 String optionalIndexName,
 EventPropertyValueGetter getter,
 DataInputOutputSerde optionalValueSerde,
 boolean isFireAndForget,
 StateMgmtSetting stateMgmtSettings)

Specified by:

createHashedOnly in interface EventTableIndexService

createUnindexed

public EventTableFactory createUnindexed(int indexedStreamNum,
 EventType eventType,
 DataInputOutputSerde optionalValueSerde,
 boolean isFireAndForget,
 StateMgmtSetting stateMgmtSettings)

Specified by:

createUnindexed in interface EventTableIndexService

createSorted

public EventTableFactory createSorted(int indexedStreamNum,
 EventType eventType,
 String indexedProp,
 EPTypeClass indexType,
 EventPropertyValueGetter getter,
 DataInputOutputSerde serde,
 DataInputOutputSerde optionalValueSerde,
 boolean isFireAndForget,
 StateMgmtSetting stateMgmtSettings)

Specified by:

createSorted in interface EventTableIndexService

createComposite

public EventTableFactory createComposite(int indexedStreamNum,
 EventType eventType,
 String[] indexProps,
 EPTypeClass[] indexCoercionTypes,
 EventPropertyValueGetter indexGetter,
 MultiKeyFromObjectArray transformFireAndForget,
 DataInputOutputSerde keySerde,
 String[] rangeProps,
 EPTypeClass[] rangeCoercionTypes,
 EventPropertyValueGetter[] rangeGetters,
 DataInputOutputSerde[] rangeSerdes,
 DataInputOutputSerde optionalValueSerde,
 boolean isFireAndForget)

Specified by:

createComposite in interface EventTableIndexService

createInArray

public EventTableFactory createInArray(int streamNum,
 EventType eventType,
 String[] propertyNames,
 EPTypeClass[] indexTypes,
 DataInputOutputSerde[] indexSerdes,
 boolean unique,
 EventPropertyValueGetter[] getters,
 boolean isFireAndForget,
 StateMgmtSetting stateMgmtSettings)

Specified by:

createInArray in interface EventTableIndexService

createCustom

public EventTableFactory createCustom(String indexName,
 int indexedStreamNum,
 EventType eventType,
 boolean unique,
 EventAdvancedIndexProvisionRuntime advancedIndexProvisionDesc)

Specified by:

createCustom in interface EventTableIndexService