com.xxdb.streaming.client.cep

Class EventHandler

java.lang.Object

com.xxdb.streaming.client.cep.EventHandler

public class EventHandler
extends Object

Constructor Summary

Constructors

Constructor and Description
EventHandler(List<EventSchema> eventSchemas, List<String> eventTimeFields, List<String> commonFields)

Method Summary

Modifier and Type	Method and Description
boolean	checkInputTable(String tableName, BasicTable outputTable, StringBuilder errMsg)
boolean	deserializeEvent(List<IMessage> msgs, List<String> eventTypes, List<List<Entity>> attributes, ErrorCodeInfo errorInfo)
boolean	serializeEvent(String eventType, List<Entity> attributes, List<Entity> serializedEvent, StringBuilder errMsg)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventHandler

public EventHandler(List<EventSchema> eventSchemas,
                    List<String> eventTimeFields,
                    List<String> commonFields)

Method Detail

checkInputTable

public boolean checkInputTable(String tableName,
                               BasicTable outputTable,
                               StringBuilder errMsg)

serializeEvent

public boolean serializeEvent(String eventType,
                              List<Entity> attributes,
                              List<Entity> serializedEvent,
                              StringBuilder errMsg)

deserializeEvent

public boolean deserializeEvent(List<IMessage> msgs,
                                List<String> eventTypes,
                                List<List<Entity>> attributes,
                                ErrorCodeInfo errorInfo)