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 and Description
static EventTableIndexServiceImpl	INSTANCE

Constructor Summary

Constructors

Constructor and Description
EventTableIndexServiceImpl()

Method Summary

Modifier and Type	Method and Description
boolean	allowInitIndex(boolean isRecoveringResilient)
EventTableFactory	createComposite(int indexedStreamNum, EventType eventType, String[] indexProps, EPTypeClass[] indexCoercionTypes, EventPropertyValueGetter indexGetter, MultiKeyFromObjectArray transformFireAndForget, DataInputOutputSerde<Object> keySerde, String[] rangeProps, EPTypeClass[] rangeCoercionTypes, EventPropertyValueGetter[] rangeGetters, DataInputOutputSerde<Object>[] rangeSerdes, DataInputOutputSerde<Object> 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<Object> keySerde, boolean unique, String optionalIndexName, EventPropertyValueGetter getter, DataInputOutputSerde<Object> optionalValueSerde, boolean isFireAndForget, StateMgmtSetting stateMgmtSettings)
EventTableFactory	createInArray(int streamNum, EventType eventType, String[] propertyNames, EPTypeClass[] indexTypes, DataInputOutputSerde<Object>[] indexSerdes, boolean unique, EventPropertyValueGetter[] getters, boolean isFireAndForget, StateMgmtSetting stateMgmtSettings)
EventTableFactory	createSorted(int indexedStreamNum, EventType eventType, String indexedProp, EPTypeClass indexType, EventPropertyValueGetter getter, DataInputOutputSerde<Object> serde, DataInputOutputSerde<Object> optionalValueSerde, boolean isFireAndForget, StateMgmtSetting stateMgmtSettings)
EventTableFactory	createUnindexed(int indexedStreamNum, EventType eventType, DataInputOutputSerde<Object> optionalValueSerde, boolean isFireAndForget, StateMgmtSetting stateMgmtSettings)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final EventTableIndexServiceImpl INSTANCE

Constructor Detail

EventTableIndexServiceImpl

public EventTableIndexServiceImpl()

Method Detail

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<Object> keySerde,
                                          boolean unique,
                                          String optionalIndexName,
                                          EventPropertyValueGetter getter,
                                          DataInputOutputSerde<Object> optionalValueSerde,
                                          boolean isFireAndForget,
                                          StateMgmtSetting stateMgmtSettings)

Specified by:

createHashedOnly in interface EventTableIndexService

createUnindexed

public EventTableFactory createUnindexed(int indexedStreamNum,
                                         EventType eventType,
                                         DataInputOutputSerde<Object> 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<Object> serde,
                                      DataInputOutputSerde<Object> 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<Object> keySerde,
                                         String[] rangeProps,
                                         EPTypeClass[] rangeCoercionTypes,
                                         EventPropertyValueGetter[] rangeGetters,
                                         DataInputOutputSerde<Object>[] rangeSerdes,
                                         DataInputOutputSerde<Object> optionalValueSerde,
                                         boolean isFireAndForget)

Specified by:

createComposite in interface EventTableIndexService

createInArray

public EventTableFactory createInArray(int streamNum,
                                       EventType eventType,
                                       String[] propertyNames,
                                       EPTypeClass[] indexTypes,
                                       DataInputOutputSerde<Object>[] 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