com.espertech.esper.event

Interface EventAdapterService

All Superinterfaces:

EventBeanService

All Known Implementing Classes:

EventAdapterServiceImpl

public interface EventAdapterService
extends EventBeanService

Interface for a service to resolve event names to event type.

Field Summary

Fields

Modifier and Type	Field and Description
static String	ANONYMOUS_TYPE_NAME_PREFIX

Method Summary

Modifier and Type	Method and Description
EventBean	adapterForAvro(Object avroGenericDataDotRecord, String eventTypeName) Construct an event bean for a given Avro GenericData.Record using the event type name to look up the Avro event type
EventBean	adapterForBean(Object theEvent) Wrap the native event returning an EventBean.
EventBean	adapterForDOM(Node node) Returns an adapter for the XML DOM document that exposes it's data as event properties for use in statements.
EventBean	adapterForMap(Map<String,Object> theEvent, String eventTypeName) Wrap the Map-type event returning an EventBean using the event type name to identify the EventType that the event should carry.
EventBean	adapterForObjectArray(Object[] theEvent, String eventTypeName) Construct an event bean for a given Object-Array using the event type name to look up the Object-Array event type
EventBean	adapterForType(Object theEvent, EventType eventType) Returns an adapter for an event underlying object when the event type is known.
EventBean	adapterForTypedAvro(Object avroGenericDataDotRecord, EventType eventType) Construct an event bean for a given Avro GenericData.Record and given the Avro-event-type
EventBean	adapterForTypedBean(Object bean, EventType eventType) Creates a thin adaper for an event object given an event type.
EventBean	adapterForTypedDOM(Node node, EventType eventType) Returns an adapter for the XML DOM document that exposes it's data as event properties for use in statements.
EventBean	adapterForTypedMap(Map<String,Object> properties, EventType eventType) Create an event map bean from a set of event properties (name and value objectes) stored in a Map.
EventBean	adapterForTypedObjectArray(Object[] props, EventType resultEventType) Construct an event bean for a given Object-Array and given the Object-Array-event-type
EventBean	adapterForTypedWrapper(EventBean theEvent, Map<String,Object> properties, EventType eventType) Creata a wrapper around an event and some additional properties
void	addAutoNamePackage(String javaPackageName) Adds a Java package name of a package that Java event classes reside in.
EventType	addAvroType(String eventTypeName, ConfigurationEventTypeAvro avro, boolean isPreconfiguredStatic, boolean isPreconfigured, boolean isConfigured, boolean isNamedWindow, boolean isInsertInto)
EventType	addAvroType(String eventTypeName, Map<String,Object> types, boolean isPreconfiguredStatic, boolean isPreconfigured, boolean isConfigured, boolean isNamedWindow, boolean isInsertInto, Annotation[] annotations, ConfigurationEventTypeAvro config, String statementName, String engineURI)
EventType	addBeanType(String eventTypeName, Class clazz, boolean isPreconfiguredStatic, boolean isPreconfigured, boolean isConfigured) Add an event type with the given name and Java class.
EventType	addBeanType(String eventTypeName, String fullyQualClassName, boolean considerAutoName, boolean isPreconfiguredStatic, boolean isPreconfigured, boolean isConfigured) Add an event type with the given name and Java fully-qualified class name.
EventType	addBeanTypeByName(String eventTypeName, Class clazz, boolean isNamedWindow)
void	addEventRepresentation(URI eventRepURI, PlugInEventRepresentation pluginEventRep) Add a plug-in event representation.
EventType	addNestableMapType(String eventTypeName, Map<String,Object> propertyTypes, ConfigurationEventTypeMap optionalConfig, boolean isPreconfiguredStatic, boolean isPreconfigured, boolean isConfigured, boolean namedWindow, boolean insertInto) Add an event type with the given name and a given set of properties, wherein properties may itself be Maps, nested and strongly-typed.
EventType	addNestableObjectArrayType(String eventTypeName, Map<String,Object> propertyTypes, ConfigurationEventTypeObjectArray typeConfig, boolean isPreconfiguredStatic, boolean isPreconfigured, boolean isConfigured, boolean namedWindow, boolean insertInto, boolean table, String tableName)
EventType	addPlugInEventType(String name, URI[] resolutionURIs, Serializable initializer) Adds a plug-in event type.
void	addTypeByName(String name, EventType eventType) Adds an event type to the registery available for use, and originating outside as a non-adapter.
EventType	addWrapperType(String eventTypeName, EventType underlyingEventType, Map<String,Object> propertyTypes, boolean isNamedWindow, boolean isInsertInto) Add an event type with the given name and the given underlying event type, as well as the additional given properties.
EventType	addXMLDOMType(String eventTypeName, ConfigurationEventTypeXMLDOM configurationEventTypeXMLDOM, SchemaModel optionalSchemaModel, boolean isPreconfiguredStatic) Adds an XML DOM event type.
EventType	createAnonymousAvroType(String typeName, Map<String,Object> properties, Annotation[] annotations, String statementName, String engineURI)
EventType	createAnonymousBeanType(String schemaName, Class clazz)
EventType	createAnonymousMapType(String typeName, Map<String,Object> propertyTypes, boolean isTransient) Creates a new anonymous EventType instance for an event type that contains a map of name value pairs.
EventType	createAnonymousObjectArrayType(String typeName, Map<String,Object> propertyTypes)
EventType	createAnonymousWrapperType(String typeName, EventType underlyingEventType, Map<String,Object> propertyTypes) Create a new anonymous event type with the given underlying event type, as well as the additional given properties.
EventType	createSemiAnonymousMapType(String typeName, Map<String,Pair<EventType,String>> taggedEventTypes, Map<String,Pair<EventType,String>> arrayEventTypes, boolean isUsedByChildViews) Creates an anonymous map that has no name, however in a fail-over scenario events of this type may be recoverable and therefore the type is only semi-anonymous, identified by the tags and event type names used.
EventBeanAdapterFactory	getAdapterFactoryForType(EventType eventType)
EventType[]	getAllTypes() Return all known event types.
BeanEventTypeFactory	getBeanEventTypeFactory() Returns a subset of the functionality of the service specific to creating POJO bean event types.
ConfigurationEventTypeLegacy	getClassLegacyConfigs(String className) Returns the configured legacy Java class information or null if none defined.
Map<String,EventType>	getDeclaredEventTypes()
EventSender	getDynamicTypeEventSender(EPRuntimeEventSender runtimeEventSender, URI[] uri, ThreadingService threadingService) Returns an event sender that dynamically decides what the event type for a given object is.
EngineImportService	getEngineImportService()
EventAdapterAvroHandler	getEventAdapterAvroHandler()
EventType	getExistsTypeByName(String eventTypeName) Return the event type for a given event name, or null if none is registered for that name.
EventBeanManufacturer	getManufacturer(EventType eventType, WriteablePropertyDescriptor[] properties, EngineImportService engineImportService, boolean allowAnyType) Returns a factory for creating and populating event object instances for the given type.
EventBeanSPI	getShellForType(EventType eventType)
EventSender	getStaticTypeEventSender(EPRuntimeEventSender runtimeEventSender, String eventTypeName, ThreadingService threadingService) Returns an event sender for a specific type, only generating events of that type.
TypeWidenerCustomizer	getTypeWidenerCustomizer(EventType resultEventType)
Set<WriteablePropertyDescriptor>	getWriteableProperties(EventType eventType, boolean allowAnyType) Returns descriptors for all writable properties.
boolean	removeType(String eventTypeName) Removes an event type by a given name indicating by the return value whether the type was found or not.
EventType	replaceXMLEventType(String xmlEventTypeName, ConfigurationEventTypeXMLDOM config, SchemaModel schemaModel)
void	setClassLegacyConfigs(Map<String,ConfigurationEventTypeLegacy> classLegacyInfo) Sets the configured legacy Java class information.
void	setDefaultAccessorStyle(ConfigurationEventTypeLegacy.AccessorStyle defaultAccessorStyle)
void	setDefaultPropertyResolutionStyle(Configuration.PropertyResolutionStyle classPropertyResolutionStyle) Sets the resolution style for case-sentitivity.
EventBean[]	typeCast(List<EventBean> events, EventType targetType) Casts event type of a list of events to either Wrapper or Map type.
void	updateMapEventType(String mapEventTypeName, Map<String,Object> typeMap) Update a given Map event type.
void	updateObjectArrayEventType(String objectArrayEventTypeName, Map<String,Object> typeMap)

Field Detail

ANONYMOUS_TYPE_NAME_PREFIX

static final String ANONYMOUS_TYPE_NAME_PREFIX

See Also:

Constant Field Values

Method Detail

getWriteableProperties

Set<WriteablePropertyDescriptor> getWriteableProperties(EventType eventType,
                                                        boolean allowAnyType)

Returns descriptors for all writable properties.

Parameters:

eventType - to reflect on

allowAnyType - whether any type is allowed to be populated

Returns:

list of writable properties

getManufacturer

EventBeanManufacturer getManufacturer(EventType eventType,
                                      WriteablePropertyDescriptor[] properties,
                                      EngineImportService engineImportService,
                                      boolean allowAnyType)
                               throws EventBeanManufactureException

Returns a factory for creating and populating event object instances for the given type.

Parameters:

eventType - to create underlying objects for

properties - to write

engineImportService - engine imports

allowAnyType - whether any type is allowed to be populated

Returns:

factory

Throws:

EventBeanManufactureException - if a factory cannot be created for the type

adapterForTypedBean

EventBean adapterForTypedBean(Object bean,
                              EventType eventType)

Creates a thin adaper for an event object given an event type.

Specified by:

adapterForTypedBean in interface EventBeanService

Parameters:

bean - event object

eventType - event type

Returns:

event

addTypeByName

void addTypeByName(String name,
                   EventType eventType)
            throws EventAdapterException

Adds an event type to the registery available for use, and originating outside as a non-adapter.

Parameters:

name - to add an event type under

eventType - the type to add

Throws:

EventAdapterException - if the name is already in used by another type

getExistsTypeByName

EventType getExistsTypeByName(String eventTypeName)

Return the event type for a given event name, or null if none is registered for that name.

Specified by:

getExistsTypeByName in interface EventBeanService

Parameters:

eventTypeName - is the event type name to return type for

Returns:

event type for named event, or null if unknown/unnamed type

getAllTypes

EventType[] getAllTypes()

Return all known event types.

Returns:

event types

addNestableMapType

EventType addNestableMapType(String eventTypeName,
                             Map<String,Object> propertyTypes,
                             ConfigurationEventTypeMap optionalConfig,
                             boolean isPreconfiguredStatic,
                             boolean isPreconfigured,
                             boolean isConfigured,
                             boolean namedWindow,
                             boolean insertInto)
                      throws EventAdapterException

Add an event type with the given name and a given set of properties, wherein properties may itself be Maps, nested and strongly-typed.

If the name already exists with the same event property information, returns the existing EventType instance.

If the name already exists with different event property information, throws an exception.

If the name does not already exists, adds the name and constructs a new MapEventType.

Parameters:

eventTypeName - is the name for the event type

propertyTypes - is the names and types of event properties

optionalConfig - an optional set of Map event type names that are supertypes to the type

isConfigured - if the type is application-configured

namedWindow - if the type is from a named window

insertInto - if inserting into a stream

isPreconfigured - whether pre-configured

isPreconfiguredStatic - whether statically pre-configured

Returns:

event type is the type added

Throws:

EventAdapterException - if name already exists and doesn't match property type info

addWrapperType

EventType addWrapperType(String eventTypeName,
                         EventType underlyingEventType,
                         Map<String,Object> propertyTypes,
                         boolean isNamedWindow,
                         boolean isInsertInto)
                  throws EventAdapterException

Add an event type with the given name and the given underlying event type, as well as the additional given properties.

Parameters:

eventTypeName - is the name for the event type

underlyingEventType - is the event type for the event type that this wrapper wraps

propertyTypes - is the names and types of any additional properties

isNamedWindow - if the type is from a named window

isInsertInto - if inserting into a stream

Returns:

eventType is the type added

Throws:

EventAdapterException - if name already exists and doesn't match this type's info

createAnonymousMapType

EventType createAnonymousMapType(String typeName,
                                 Map<String,Object> propertyTypes,
                                 boolean isTransient)

Creates a new anonymous EventType instance for an event type that contains a map of name value pairs. The method accepts a Map that contains the property names as keys and Class objects as the values. The Class instances represent the property types.

New instances are createdStatement by this method on every invocation. Clients to this method need to cache the returned EventType instance to reuse EventType's for same-typed events.

Parameters:

propertyTypes - is a map of String to Class objects

isTransient - transient types are not available by event type id lookup and recovery, they are always re-created on-the-fly

typeName - type name

Returns:

EventType implementation for map field names and value types

adapterForTypedWrapper

EventBean adapterForTypedWrapper(EventBean theEvent,
                                 Map<String,Object> properties,
                                 EventType eventType)

Creata a wrapper around an event and some additional properties

Parameters:

theEvent - is the wrapped event

properties - are the additional properties

eventType - os the type metadata for any wrappers of this type

Returns:

wrapper event bean

addBeanType

EventType addBeanType(String eventTypeName,
                      String fullyQualClassName,
                      boolean considerAutoName,
                      boolean isPreconfiguredStatic,
                      boolean isPreconfigured,
                      boolean isConfigured)
               throws EventAdapterException

Add an event type with the given name and Java fully-qualified class name.

If the name already exists with the same class name, returns the existing EventType instance.

If the name already exists with different class name, throws an exception.

If the name does not already exists, adds the name and constructs a new BeanEventType.

Takes into account all event-type-auto-package names supplied and attempts to resolve the class name via the packages if the direct resolution failed.

Parameters:

eventTypeName - is the name for the event type

fullyQualClassName - is the fully qualified class name

considerAutoName - whether auto-name by Java packages should be considered

isConfigured - indicator whether from configs

isPreconfigured - indicator whether preconfigured

isPreconfiguredStatic - indicator whether static configured

Returns:

event type is the type added

Throws:

EventAdapterException - if name already exists and doesn't match class names

addBeanType

EventType addBeanType(String eventTypeName,
                      Class clazz,
                      boolean isPreconfiguredStatic,
                      boolean isPreconfigured,
                      boolean isConfigured)
               throws EventAdapterException

Add an event type with the given name and Java class.

If the name already exists with the same Class, returns the existing EventType instance.

If the name already exists with different Class name, throws an exception.

If the name does not already exists, adds the name and constructs a new BeanEventType.

Parameters:

eventTypeName - is the name for the event type

clazz - is the fully Java class

isConfigured - if the class is application-configured

isPreconfigured - indicator whether preconfigured

isPreconfiguredStatic - indicator whether static configured

Returns:

event type is the type added

Throws:

EventAdapterException - if name already exists and doesn't match class names

addBeanTypeByName

EventType addBeanTypeByName(String eventTypeName,
                            Class clazz,
                            boolean isNamedWindow)
                     throws EventAdapterException

Throws:

EventAdapterException

adapterForBean

EventBean adapterForBean(Object theEvent)

Wrap the native event returning an EventBean.

Specified by:

adapterForBean in interface EventBeanService

Parameters:

theEvent - to be wrapped

Returns:

event bean wrapping native underlying event

adapterForMap

EventBean adapterForMap(Map<String,Object> theEvent,
                        String eventTypeName)
                 throws EventAdapterException

Wrap the Map-type event returning an EventBean using the event type name to identify the EventType that the event should carry.

Specified by:

adapterForMap in interface EventBeanService

Parameters:

theEvent - to be wrapped

eventTypeName - name for the event type of the event

Returns:

event bean wrapping native underlying event

Throws:

EventAdapterException - if the name has not been declared, or the event cannot be wrapped using that name's event type

adapterForObjectArray

EventBean adapterForObjectArray(Object[] theEvent,
                                String eventTypeName)
                         throws EventAdapterException

Description copied from interface: EventBeanService

Construct an event bean for a given Object-Array using the event type name to look up the Object-Array event type

Specified by:

adapterForObjectArray in interface EventBeanService

Parameters:

theEvent - event underlying

eventTypeName - name of the Object-Array event type

Returns:

event bean

Throws:

EventAdapterException

adapterForTypedMap

EventBean adapterForTypedMap(Map<String,Object> properties,
                             EventType eventType)

Create an event map bean from a set of event properties (name and value objectes) stored in a Map.

Specified by:

adapterForTypedMap in interface EventBeanService

Parameters:

properties - is key-value pairs for the event properties

eventType - is the type metadata for any maps of that type

Returns:

EventBean instance

adapterForDOM

EventBean adapterForDOM(Node node)

Returns an adapter for the XML DOM document that exposes it's data as event properties for use in statements.

Specified by:

adapterForDOM in interface EventBeanService

Parameters:

node - is the node to wrap

Returns:

event wrapper for document

adapterForTypedDOM

EventBean adapterForTypedDOM(Node node,
                             EventType eventType)

Returns an adapter for the XML DOM document that exposes it's data as event properties for use in statements.

Specified by:

adapterForTypedDOM in interface EventBeanService

Parameters:

node - is the node to wrap

eventType - the event type associated with the node

Returns:

event wrapper for document

adapterForType

EventBean adapterForType(Object theEvent,
                         EventType eventType)

Returns an adapter for an event underlying object when the event type is known.

Specified by:

adapterForType in interface EventBeanService

Parameters:

theEvent - underlying

eventType - type

Returns:

event wrapper for object

createAnonymousWrapperType

EventType createAnonymousWrapperType(String typeName,
                                     EventType underlyingEventType,
                                     Map<String,Object> propertyTypes)
                              throws EventAdapterException

Create a new anonymous event type with the given underlying event type, as well as the additional given properties.

Parameters:

underlyingEventType - is the event type for the event type that this wrapper wraps

propertyTypes - is the names and types of any additional properties

typeName - type name

Returns:

eventType is the type createdStatement

Throws:

EventAdapterException - if name already exists and doesn't match this type's info

addXMLDOMType

EventType addXMLDOMType(String eventTypeName,
                        ConfigurationEventTypeXMLDOM configurationEventTypeXMLDOM,
                        SchemaModel optionalSchemaModel,
                        boolean isPreconfiguredStatic)

Adds an XML DOM event type.

Parameters:

eventTypeName - is the name to add the type for

configurationEventTypeXMLDOM - is the XML DOM config info

optionalSchemaModel - is the object model of the schema, or null in none provided

isPreconfiguredStatic - preconfigured thru static config

Returns:

event type

setClassLegacyConfigs

void setClassLegacyConfigs(Map<String,ConfigurationEventTypeLegacy> classLegacyInfo)

Sets the configured legacy Java class information.

Parameters:

classLegacyInfo - is configured legacy

getClassLegacyConfigs

ConfigurationEventTypeLegacy getClassLegacyConfigs(String className)

Returns the configured legacy Java class information or null if none defined.

Parameters:

className - is the fully-qualified class name

Returns:

config

setDefaultPropertyResolutionStyle

void setDefaultPropertyResolutionStyle(Configuration.PropertyResolutionStyle classPropertyResolutionStyle)

Sets the resolution style for case-sentitivity.

Parameters:

classPropertyResolutionStyle - for resolving properties.

addAutoNamePackage

void addAutoNamePackage(String javaPackageName)

Adds a Java package name of a package that Java event classes reside in.

Parameters:

javaPackageName - is the fully-qualified Java package name of the Java package that event classes reside in

getBeanEventTypeFactory

BeanEventTypeFactory getBeanEventTypeFactory()

Returns a subset of the functionality of the service specific to creating POJO bean event types.

Returns:

bean event type factory

addEventRepresentation

void addEventRepresentation(URI eventRepURI,
                            PlugInEventRepresentation pluginEventRep)

Add a plug-in event representation.

Parameters:

eventRepURI - URI is the unique identifier for the event representation

pluginEventRep - is the instance

addPlugInEventType

EventType addPlugInEventType(String name,
                             URI[] resolutionURIs,
                             Serializable initializer)

Adds a plug-in event type.

Parameters:

name - is the name of the event type

resolutionURIs - is the URIs of plug-in event representations, or child URIs of such

initializer - is configs for the type

Returns:

type

getStaticTypeEventSender

EventSender getStaticTypeEventSender(EPRuntimeEventSender runtimeEventSender,
                                     String eventTypeName,
                                     ThreadingService threadingService)

Returns an event sender for a specific type, only generating events of that type.

Parameters:

runtimeEventSender - the runtime handle for sending the wrapped type

eventTypeName - is the name of the event type to return the sender for

threadingService - threading service

Returns:

event sender that is static, single-type

getDynamicTypeEventSender

EventSender getDynamicTypeEventSender(EPRuntimeEventSender runtimeEventSender,
                                      URI[] uri,
                                      ThreadingService threadingService)

Returns an event sender that dynamically decides what the event type for a given object is.

Parameters:

runtimeEventSender - the runtime handle for sending the wrapped type

uri - is for plug-in event representations to provide implementations, if accepted, to make a wrapped event

threadingService - threading service

Returns:

event sender that is dynamic, multi-type based on multiple event bean factories provided by plug-in event representations

updateMapEventType

void updateMapEventType(String mapEventTypeName,
                        Map<String,Object> typeMap)
                 throws EventAdapterException

Update a given Map event type.

Parameters:

mapEventTypeName - name to update

typeMap - additional properties to add, nesting allowed

Throws:

EventAdapterException - when the type is not found or is not a Map

typeCast

EventBean[] typeCast(List<EventBean> events,
                     EventType targetType)

Casts event type of a list of events to either Wrapper or Map type.

Parameters:

events - to cast

targetType - target type

Returns:

type casted event array

removeType

boolean removeType(String eventTypeName)

Removes an event type by a given name indicating by the return value whether the type was found or not.

Does not uncache an existing class loaded by a JVM. Does remove XML root element names. Does not handle value-add event types.

Parameters:

eventTypeName - to remove

Returns:

true if found and removed, false if not found

createSemiAnonymousMapType

EventType createSemiAnonymousMapType(String typeName,
                                     Map<String,Pair<EventType,String>> taggedEventTypes,
                                     Map<String,Pair<EventType,String>> arrayEventTypes,
                                     boolean isUsedByChildViews)

Creates an anonymous map that has no name, however in a fail-over scenario events of this type may be recoverable and therefore the type is only semi-anonymous, identified by the tags and event type names used.

Parameters:

taggedEventTypes - simple type per property name

arrayEventTypes - array type per property name

isUsedByChildViews - if the type is going to be in used by child views

typeName - type name

Returns:

event type

setDefaultAccessorStyle

void setDefaultAccessorStyle(ConfigurationEventTypeLegacy.AccessorStyle defaultAccessorStyle)

replaceXMLEventType

EventType replaceXMLEventType(String xmlEventTypeName,
                              ConfigurationEventTypeXMLDOM config,
                              SchemaModel schemaModel)

getDeclaredEventTypes

Map<String,EventType> getDeclaredEventTypes()

adapterForTypedObjectArray

EventBean adapterForTypedObjectArray(Object[] props,
                                     EventType resultEventType)

Description copied from interface: EventBeanService

Construct an event bean for a given Object-Array and given the Object-Array-event-type

Specified by:

adapterForTypedObjectArray in interface EventBeanService

Parameters:

props - event underlying

resultEventType - event type (Object-array only)

Returns:

event bean

createAnonymousObjectArrayType

EventType createAnonymousObjectArrayType(String typeName,
                                         Map<String,Object> propertyTypes)

createAnonymousAvroType

EventType createAnonymousAvroType(String typeName,
                                  Map<String,Object> properties,
                                  Annotation[] annotations,
                                  String statementName,
                                  String engineURI)

addNestableObjectArrayType

EventType addNestableObjectArrayType(String eventTypeName,
                                     Map<String,Object> propertyTypes,
                                     ConfigurationEventTypeObjectArray typeConfig,
                                     boolean isPreconfiguredStatic,
                                     boolean isPreconfigured,
                                     boolean isConfigured,
                                     boolean namedWindow,
                                     boolean insertInto,
                                     boolean table,
                                     String tableName)
                              throws EventAdapterException

Throws:

EventAdapterException

updateObjectArrayEventType

void updateObjectArrayEventType(String objectArrayEventTypeName,
                                Map<String,Object> typeMap)

getShellForType

EventBeanSPI getShellForType(EventType eventType)

getAdapterFactoryForType

EventBeanAdapterFactory getAdapterFactoryForType(EventType eventType)

createAnonymousBeanType

EventType createAnonymousBeanType(String schemaName,
                                  Class clazz)

addAvroType

EventType addAvroType(String eventTypeName,
                      ConfigurationEventTypeAvro avro,
                      boolean isPreconfiguredStatic,
                      boolean isPreconfigured,
                      boolean isConfigured,
                      boolean isNamedWindow,
                      boolean isInsertInto)
               throws EventAdapterException

Throws:

EventAdapterException

addAvroType

EventType addAvroType(String eventTypeName,
                      Map<String,Object> types,
                      boolean isPreconfiguredStatic,
                      boolean isPreconfigured,
                      boolean isConfigured,
                      boolean isNamedWindow,
                      boolean isInsertInto,
                      Annotation[] annotations,
                      ConfigurationEventTypeAvro config,
                      String statementName,
                      String engineURI)
               throws EventAdapterException

Throws:

EventAdapterException

adapterForAvro

EventBean adapterForAvro(Object avroGenericDataDotRecord,
                         String eventTypeName)

Description copied from interface: EventBeanService

Construct an event bean for a given Avro GenericData.Record using the event type name to look up the Avro event type

Specified by:

adapterForAvro in interface EventBeanService

Parameters:

avroGenericDataDotRecord - event underlying

eventTypeName - name of the Avro event type

Returns:

event bean

getEventAdapterAvroHandler

EventAdapterAvroHandler getEventAdapterAvroHandler()

adapterForTypedAvro

EventBean adapterForTypedAvro(Object avroGenericDataDotRecord,
                              EventType eventType)

Description copied from interface: EventBeanService

Construct an event bean for a given Avro GenericData.Record and given the Avro-event-type

Specified by:

adapterForTypedAvro in interface EventBeanService

Parameters:

avroGenericDataDotRecord - event underlying

eventType - event type (Avro only)

Returns:

event bean

getTypeWidenerCustomizer

TypeWidenerCustomizer getTypeWidenerCustomizer(EventType resultEventType)

getEngineImportService

EngineImportService getEngineImportService()