com.espertech.esper.event.avro

Interface EventAdapterAvroHandler

All Known Implementing Classes:

EventAdapterAvroHandlerUnsupported

public interface EventAdapterAvroHandler

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	HANDLER_IMPL

Method Summary

Modifier and Type	Method and Description
EventBean	adapterForTypeAvro(java.lang.Object avroGenericDataDotRecord, EventType existingType)
void	avroCompat(EventType existingType, java.util.Map<java.lang.String,java.lang.Object> selPropertyTypes)
java.lang.Object	convertEvent(EventBean theEvent, AvroSchemaEventType targetType)
EventBeanFactory	getEventBeanFactory(EventType type, EventAdapterService eventAdapterService)
EventBeanManufacturer	getEventBeanManufacturer(AvroSchemaEventType avroSchemaEventType, EventAdapterService eventAdapterService, WriteablePropertyDescriptor[] properties)
SelectExprProcessorRepresentationFactory	getOutputFactory()
TypeWidenerCustomizer	getTypeWidenerCustomizer(EventType eventType)
void	init(ConfigurationEngineDefaults.EventMeta.AvroSettings avroSettings, EngineImportService engineImportService)
AvroSchemaEventType	newEventTypeFromNormalized(EventTypeMetadata metadata, java.lang.String eventTypeName, int typeId, EventAdapterService eventAdapterService, java.util.Map<java.lang.String,java.lang.Object> properties, java.lang.annotation.Annotation[] annotations, ConfigurationEventTypeAvro optionalConfig, EventType[] superTypes, java.util.Set<EventType> deepSuperTypes, java.lang.String statementName, java.lang.String engineURI)
AvroSchemaEventType	newEventTypeFromSchema(EventTypeMetadata metadata, java.lang.String eventTypeName, int typeId, EventAdapterService eventAdapterService, ConfigurationEventTypeAvro requiredConfig, EventType[] superTypes, java.util.Set<EventType> deepSuperTypes)
void	validateExistingType(EventType existingType, AvroSchemaEventType proposedType)

Field Detail

HANDLER_IMPL

static final java.lang.String HANDLER_IMPL

See Also:

Constant Field Values

Method Detail

init

void init(ConfigurationEngineDefaults.EventMeta.AvroSettings avroSettings,
          EngineImportService engineImportService)

getOutputFactory

SelectExprProcessorRepresentationFactory getOutputFactory()

newEventTypeFromSchema

AvroSchemaEventType newEventTypeFromSchema(EventTypeMetadata metadata,
                                           java.lang.String eventTypeName,
                                           int typeId,
                                           EventAdapterService eventAdapterService,
                                           ConfigurationEventTypeAvro requiredConfig,
                                           EventType[] superTypes,
                                           java.util.Set<EventType> deepSuperTypes)

newEventTypeFromNormalized

AvroSchemaEventType newEventTypeFromNormalized(EventTypeMetadata metadata,
                                               java.lang.String eventTypeName,
                                               int typeId,
                                               EventAdapterService eventAdapterService,
                                               java.util.Map<java.lang.String,java.lang.Object> properties,
                                               java.lang.annotation.Annotation[] annotations,
                                               ConfigurationEventTypeAvro optionalConfig,
                                               EventType[] superTypes,
                                               java.util.Set<EventType> deepSuperTypes,
                                               java.lang.String statementName,
                                               java.lang.String engineURI)

adapterForTypeAvro

EventBean adapterForTypeAvro(java.lang.Object avroGenericDataDotRecord,
                             EventType existingType)

getEventBeanManufacturer

EventBeanManufacturer getEventBeanManufacturer(AvroSchemaEventType avroSchemaEventType,
                                               EventAdapterService eventAdapterService,
                                               WriteablePropertyDescriptor[] properties)

getEventBeanFactory

EventBeanFactory getEventBeanFactory(EventType type,
                                     EventAdapterService eventAdapterService)

validateExistingType

void validateExistingType(EventType existingType,
                          AvroSchemaEventType proposedType)

avroCompat

void avroCompat(EventType existingType,
                java.util.Map<java.lang.String,java.lang.Object> selPropertyTypes)
         throws ExprValidationException

Throws:

ExprValidationException

convertEvent

java.lang.Object convertEvent(EventBean theEvent,
                              AvroSchemaEventType targetType)

getTypeWidenerCustomizer

TypeWidenerCustomizer getTypeWidenerCustomizer(EventType eventType)