com.xxdb.streaming.client.cep

Class EventSender

java.lang.Object

com.xxdb.streaming.client.cep.EventSender

public class EventSender
extends Object

Constructor Summary

Constructors

Constructor and Description
EventSender(DBConnection conn, String tableName, List<EventSchema> eventSchemas, List<String> eventTimeFields, List<String> commonFields)

Method Summary

Modifier and Type	Method and Description
BasicDictionary	appendEventWithResponse(String engine, String eventType, List<Entity> attributes, String responseType, int timeout, String condition)
void	sendEvent(String eventType, List<Entity> attributes)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventSender

public EventSender(DBConnection conn,
                   String tableName,
                   List<EventSchema> eventSchemas,
                   List<String> eventTimeFields,
                   List<String> commonFields)
            throws IOException

Throws:

IOException

Method Detail

sendEvent

public void sendEvent(String eventType,
                      List<Entity> attributes)

appendEventWithResponse

public BasicDictionary appendEventWithResponse(String engine,
                                               String eventType,
                                               List<Entity> attributes,
                                               String responseType,
                                               int timeout,
                                               String condition)