public abstract class EventAdapterAvroHandlerBase extends Object implements com.espertech.esper.event.avro.EventAdapterAvroHandler
Constructor and Description |
---|
EventAdapterAvroHandlerBase() |
Modifier and Type | Method and Description |
---|---|
com.espertech.esper.client.EventBean |
adapterForTypeAvro(Object avroGenericDataDotRecord,
com.espertech.esper.client.EventType existingType) |
void |
avroCompat(com.espertech.esper.client.EventType existingType,
Map<String,Object> selPropertyTypes) |
Object |
convertEvent(com.espertech.esper.client.EventBean theEvent,
com.espertech.esper.event.avro.AvroSchemaEventType targetType) |
com.espertech.esper.client.EventBeanFactory |
getEventBeanFactory(com.espertech.esper.client.EventType type,
com.espertech.esper.event.EventAdapterService eventAdapterService) |
com.espertech.esper.event.EventBeanManufacturer |
getEventBeanManufacturer(com.espertech.esper.event.avro.AvroSchemaEventType avroSchemaEventType,
com.espertech.esper.event.EventAdapterService eventAdapterService,
com.espertech.esper.event.WriteablePropertyDescriptor[] properties) |
com.espertech.esper.epl.core.select.SelectExprProcessorRepresentationFactory |
getOutputFactory() |
com.espertech.esper.util.TypeWidenerCustomizer |
getTypeWidenerCustomizer(com.espertech.esper.client.EventType eventType) |
void |
init(com.espertech.esper.client.ConfigurationEngineDefaults.EventMeta.AvroSettings avroSettings,
com.espertech.esper.epl.core.engineimport.EngineImportService engineImportService) |
protected abstract com.espertech.esper.event.avro.AvroSchemaEventType |
makeType(com.espertech.esper.event.EventTypeMetadata metadata,
String eventTypeName,
int typeId,
com.espertech.esper.event.EventAdapterService eventAdapterService,
org.apache.avro.Schema schema,
com.espertech.esper.client.ConfigurationEventTypeAvro optionalConfig,
com.espertech.esper.client.EventType[] supertypes,
Set<com.espertech.esper.client.EventType> deepSupertypes) |
com.espertech.esper.event.avro.AvroSchemaEventType |
newEventTypeFromNormalized(com.espertech.esper.event.EventTypeMetadata metadata,
String eventTypeName,
int typeId,
com.espertech.esper.event.EventAdapterService eventAdapterService,
Map<String,Object> properties,
Annotation[] annotations,
com.espertech.esper.client.ConfigurationEventTypeAvro optionalConfig,
com.espertech.esper.client.EventType[] superTypes,
Set<com.espertech.esper.client.EventType> deepSuperTypes,
String statementName,
String engineURI) |
com.espertech.esper.event.avro.AvroSchemaEventType |
newEventTypeFromSchema(com.espertech.esper.event.EventTypeMetadata metadata,
String eventTypeName,
int typeId,
com.espertech.esper.event.EventAdapterService eventAdapterService,
com.espertech.esper.client.ConfigurationEventTypeAvro requiredConfig,
com.espertech.esper.client.EventType[] superTypes,
Set<com.espertech.esper.client.EventType> deepSuperTypes) |
void |
validateExistingType(com.espertech.esper.client.EventType existingType,
com.espertech.esper.event.avro.AvroSchemaEventType proposedType) |
protected abstract com.espertech.esper.event.avro.AvroSchemaEventType makeType(com.espertech.esper.event.EventTypeMetadata metadata, String eventTypeName, int typeId, com.espertech.esper.event.EventAdapterService eventAdapterService, org.apache.avro.Schema schema, com.espertech.esper.client.ConfigurationEventTypeAvro optionalConfig, com.espertech.esper.client.EventType[] supertypes, Set<com.espertech.esper.client.EventType> deepSupertypes)
public void init(com.espertech.esper.client.ConfigurationEngineDefaults.EventMeta.AvroSettings avroSettings, com.espertech.esper.epl.core.engineimport.EngineImportService engineImportService)
init
in interface com.espertech.esper.event.avro.EventAdapterAvroHandler
public com.espertech.esper.event.avro.AvroSchemaEventType newEventTypeFromSchema(com.espertech.esper.event.EventTypeMetadata metadata, String eventTypeName, int typeId, com.espertech.esper.event.EventAdapterService eventAdapterService, com.espertech.esper.client.ConfigurationEventTypeAvro requiredConfig, com.espertech.esper.client.EventType[] superTypes, Set<com.espertech.esper.client.EventType> deepSuperTypes)
newEventTypeFromSchema
in interface com.espertech.esper.event.avro.EventAdapterAvroHandler
public com.espertech.esper.event.avro.AvroSchemaEventType newEventTypeFromNormalized(com.espertech.esper.event.EventTypeMetadata metadata, String eventTypeName, int typeId, com.espertech.esper.event.EventAdapterService eventAdapterService, Map<String,Object> properties, Annotation[] annotations, com.espertech.esper.client.ConfigurationEventTypeAvro optionalConfig, com.espertech.esper.client.EventType[] superTypes, Set<com.espertech.esper.client.EventType> deepSuperTypes, String statementName, String engineURI)
newEventTypeFromNormalized
in interface com.espertech.esper.event.avro.EventAdapterAvroHandler
public com.espertech.esper.client.EventBean adapterForTypeAvro(Object avroGenericDataDotRecord, com.espertech.esper.client.EventType existingType)
adapterForTypeAvro
in interface com.espertech.esper.event.avro.EventAdapterAvroHandler
public com.espertech.esper.epl.core.select.SelectExprProcessorRepresentationFactory getOutputFactory()
getOutputFactory
in interface com.espertech.esper.event.avro.EventAdapterAvroHandler
public com.espertech.esper.event.EventBeanManufacturer getEventBeanManufacturer(com.espertech.esper.event.avro.AvroSchemaEventType avroSchemaEventType, com.espertech.esper.event.EventAdapterService eventAdapterService, com.espertech.esper.event.WriteablePropertyDescriptor[] properties)
getEventBeanManufacturer
in interface com.espertech.esper.event.avro.EventAdapterAvroHandler
public com.espertech.esper.client.EventBeanFactory getEventBeanFactory(com.espertech.esper.client.EventType type, com.espertech.esper.event.EventAdapterService eventAdapterService)
getEventBeanFactory
in interface com.espertech.esper.event.avro.EventAdapterAvroHandler
public void validateExistingType(com.espertech.esper.client.EventType existingType, com.espertech.esper.event.avro.AvroSchemaEventType proposedType)
validateExistingType
in interface com.espertech.esper.event.avro.EventAdapterAvroHandler
public void avroCompat(com.espertech.esper.client.EventType existingType, Map<String,Object> selPropertyTypes) throws com.espertech.esper.epl.expression.core.ExprValidationException
avroCompat
in interface com.espertech.esper.event.avro.EventAdapterAvroHandler
com.espertech.esper.epl.expression.core.ExprValidationException
public Object convertEvent(com.espertech.esper.client.EventBean theEvent, com.espertech.esper.event.avro.AvroSchemaEventType targetType)
convertEvent
in interface com.espertech.esper.event.avro.EventAdapterAvroHandler
public com.espertech.esper.util.TypeWidenerCustomizer getTypeWidenerCustomizer(com.espertech.esper.client.EventType eventType)
getTypeWidenerCustomizer
in interface com.espertech.esper.event.avro.EventAdapterAvroHandler