com.espertech.esper.event

Class EventTypeUtility

java.lang.Object

com.espertech.esper.event.EventTypeUtility

public class EventTypeUtility
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EventTypeUtility.TimestampPropertyDesc

Constructor Summary

Constructors

Constructor and Description
EventTypeUtility()

Method Summary

Modifier and Type	Method and Description
static Object	buildType(ColumnDesc column, EngineImportService engineImportService)
static LinkedHashMap<String,Object>	buildType(List<ColumnDesc> columns, EventAdapterService eventAdapterService, Set<String> copyFrom, EngineImportService engineImportService)
static Map<String,Object>	compileMapTypeProperties(Map<String,Object> typing, EventAdapterService eventAdapterService) Determine among the Map-type properties which properties are Bean-type event type names, rewrites these as Class-type instead so that they are configured as native property and do not require wrapping, but may require unwrapping.
static EventType	createNonVariantType(boolean isAnonymous, CreateSchemaDesc spec, Annotation[] annotations, ConfigurationInformation configSnapshot, EventAdapterService eventAdapterService, EngineImportService engineImportService)
static String	disallowedAtTypeMessage()
static WriteablePropertyDescriptor	findWritable(String propertyName, Set<WriteablePropertyDescriptor> writables)
static EventPropertyGetterSPI	getNestableGetter(String propertyName, Map<String,PropertySetDescriptorItem> propertyGetters, Map<String,EventPropertyGetterSPI> propertyGetterCache, Map<String,Object> nestableTypes, EventAdapterService eventAdapterService, EventTypeNestableGetterFactory factory, boolean isObjectArray)
static PropertySetDescriptor	getNestableProperties(Map<String,Object> propertiesToAdd, EventAdapterService eventAdapterService, EventTypeNestableGetterFactory factory, EventType[] optionalSuperTypes)
static EventPropertyDescriptor	getNestablePropertyDescriptor(EventType target, Deque<Property> stack)
static EventPropertyDescriptor	getNestablePropertyDescriptor(EventType target, String propertyName)
static Class	getNestablePropertyType(String propertyName, Map<String,PropertySetDescriptorItem> simplePropertyTypes, Map<String,Object> nestableTypes, EventAdapterService eventAdapterService)
static String	getPropertyRemoveArray(String name) Returns the property name without the array type extension, if present.
static Map<String,Object>	getPropertyTypesNonPrimitive(Map<String,Object> propertyTypesMayPrimitive)
static Pair<EventType[],Set<EventType>>	getSuperTypesDepthFirst(ConfigurationEventTypeWithSupertype optionalConfig, EventUnderlyingType representation, Map<String,? extends EventType> nameToTypeMap)
static Pair<EventType[],Set<EventType>>	getSuperTypesDepthFirst(Set<String> superTypesSet, EventUnderlyingType representation, Map<String,? extends EventType> nameToTypeMap)
static boolean	isPropertyArray(String name) Returns true if the name indicates that the type is an array type.
static boolean	isTypeOrSubTypeOf(EventType candidate, EventType superType)
static boolean	isTypeOrSubTypeOf(String typeName, EventType sameTypeOrSubtype)
static EventType	requireEventType(String aspectCamel, String aspectName, EventAdapterService eventAdapterService, String optionalEventTypeName)
static EventTypeUtility.TimestampPropertyDesc	validatedDetermineTimestampProps(EventType type, String startProposed, String endProposed, EventType[] superTypes)
static void	validateEventBeanClassVisibility(Class clazz)
static LinkedHashMap<String,Object>	validateObjectArrayDef(String[] propertyNames, Object[] propertyTypes)
static void	validateTimestampProperties(EventType eventType, String startTimestampProperty, String endTimestampProperty)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventTypeUtility

public EventTypeUtility()

Method Detail

getPropertyTypesNonPrimitive

public static Map<String,Object> getPropertyTypesNonPrimitive(Map<String,Object> propertyTypesMayPrimitive)

requireEventType

public static EventType requireEventType(String aspectCamel,
                                         String aspectName,
                                         EventAdapterService eventAdapterService,
                                         String optionalEventTypeName)
                                  throws ExprValidationException

Throws:

ExprValidationException

getSuperTypesDepthFirst

public static Pair<EventType[],Set<EventType>> getSuperTypesDepthFirst(ConfigurationEventTypeWithSupertype optionalConfig,
                                                                       EventUnderlyingType representation,
                                                                       Map<String,? extends EventType> nameToTypeMap)

getSuperTypesDepthFirst

public static Pair<EventType[],Set<EventType>> getSuperTypesDepthFirst(Set<String> superTypesSet,
                                                                       EventUnderlyingType representation,
                                                                       Map<String,? extends EventType> nameToTypeMap)
                                                                throws EventAdapterException

Throws:

EventAdapterException

getNestablePropertyDescriptor

public static EventPropertyDescriptor getNestablePropertyDescriptor(EventType target,
                                                                    String propertyName)

getNestablePropertyDescriptor

public static EventPropertyDescriptor getNestablePropertyDescriptor(EventType target,
                                                                    Deque<Property> stack)

buildType

public static LinkedHashMap<String,Object> buildType(List<ColumnDesc> columns,
                                                     EventAdapterService eventAdapterService,
                                                     Set<String> copyFrom,
                                                     EngineImportService engineImportService)
                                              throws ExprValidationException

Throws:

ExprValidationException

buildType

public static Object buildType(ColumnDesc column,
                               EngineImportService engineImportService)
                        throws ExprValidationException

Throws:

ExprValidationException

validateTimestampProperties

public static void validateTimestampProperties(EventType eventType,
                                               String startTimestampProperty,
                                               String endTimestampProperty)
                                        throws ConfigurationException

Throws:

ConfigurationException

isTypeOrSubTypeOf

public static boolean isTypeOrSubTypeOf(EventType candidate,
                                        EventType superType)

compileMapTypeProperties

public static Map<String,Object> compileMapTypeProperties(Map<String,Object> typing,
                                                          EventAdapterService eventAdapterService)

Determine among the Map-type properties which properties are Bean-type event type names, rewrites these as Class-type instead so that they are configured as native property and do not require wrapping, but may require unwrapping.

Parameters:

typing - properties of map type

eventAdapterService - event adapter service

Returns:

compiled properties, same as original unless Bean-type event type names were specified.

isPropertyArray

public static boolean isPropertyArray(String name)

Returns true if the name indicates that the type is an array type.

Parameters:

name - the property name

Returns:

true if array type

isTypeOrSubTypeOf

public static boolean isTypeOrSubTypeOf(String typeName,
                                        EventType sameTypeOrSubtype)

getPropertyRemoveArray

public static String getPropertyRemoveArray(String name)

Returns the property name without the array type extension, if present.

Parameters:

name - property name

Returns:

property name with removed array extension name

getNestableProperties

public static PropertySetDescriptor getNestableProperties(Map<String,Object> propertiesToAdd,
                                                          EventAdapterService eventAdapterService,
                                                          EventTypeNestableGetterFactory factory,
                                                          EventType[] optionalSuperTypes)
                                                   throws EPException

Throws:

EPException

getNestablePropertyType

public static Class getNestablePropertyType(String propertyName,
                                            Map<String,PropertySetDescriptorItem> simplePropertyTypes,
                                            Map<String,Object> nestableTypes,
                                            EventAdapterService eventAdapterService)

getNestableGetter

public static EventPropertyGetterSPI getNestableGetter(String propertyName,
                                                       Map<String,PropertySetDescriptorItem> propertyGetters,
                                                       Map<String,EventPropertyGetterSPI> propertyGetterCache,
                                                       Map<String,Object> nestableTypes,
                                                       EventAdapterService eventAdapterService,
                                                       EventTypeNestableGetterFactory factory,
                                                       boolean isObjectArray)

validateObjectArrayDef

public static LinkedHashMap<String,Object> validateObjectArrayDef(String[] propertyNames,
                                                                  Object[] propertyTypes)

createNonVariantType

public static EventType createNonVariantType(boolean isAnonymous,
                                             CreateSchemaDesc spec,
                                             Annotation[] annotations,
                                             ConfigurationInformation configSnapshot,
                                             EventAdapterService eventAdapterService,
                                             EngineImportService engineImportService)
                                      throws ExprValidationException

Throws:

ExprValidationException

findWritable

public static WriteablePropertyDescriptor findWritable(String propertyName,
                                                       Set<WriteablePropertyDescriptor> writables)

validatedDetermineTimestampProps

public static EventTypeUtility.TimestampPropertyDesc validatedDetermineTimestampProps(EventType type,
                                                                                      String startProposed,
                                                                                      String endProposed,
                                                                                      EventType[] superTypes)
                                                                               throws EPException

Throws:

EPException

disallowedAtTypeMessage

public static String disallowedAtTypeMessage()

validateEventBeanClassVisibility

public static void validateEventBeanClassVisibility(Class clazz)