esper 常用类

简介: com.espertech.esper.client.EPServiceProvider 这是一个接口,用于提供EPRuntime和EPAdministrator。 EPServiceProvider com.espertech.esper.client.EPServiceProviderManager.getDefaultProvider() 返回默认的EPServiceProvi

com.espertech.esper.client.EPServiceProvider
这是一个接口,用于提供EPRuntime和EPAdministrator。
EPServiceProvider com.espertech.esper.client.EPServiceProviderManager.getDefaultProvider()
返回默认的EPServiceProvider。
EPAdministrator com.espertech.esper.client.EPServiceProvider.getEPAdministrator()
创建并返回EPAdministrator对象。
EPRuntime com.espertech.esper.client.EPServiceProvider.getEPRuntime() 
创建并返回EPRuntime对象。

com.espertech.esper.client.EPStatement
此接口用于提供 开始,停止,销毁 一个statement的方法。




void com.espertech.esper.client.EPStatement.start()
开始运行这个epl语句。
void com.espertech.esper.client.EPStatement.stop()
停止运行这个epl语句。
void com.espertech.esper.client.EPStatement.destory()
销毁这个epl语句。
String com.espertech.esper.client.EPStatement.getText()
返回对应的epl语句。
String com.espertech.esper.client.EPStatement.getName()
返回它的名字,这个名字是esper框架自动生成的,比如一个名字可能是这样子的“522da9a5-65dd-4c5f-a238-7c6ea7500a5c”。

boolean com.espertech.esper.client.EPStatement.isStarted()
当前这个epl语句是否生效。类似的还有 isStopped(),isDestroyed()。



com.espertech.esper.client.EPAdministrator
管理员接口,用于管理事件流处理引擎。它有创建pattern与EPL的方法。
EPStatement com.espertech.esper.client.EPAdministrator.createEPL(String eplStatement) 
创建并启动一个 EPL statement。
EPStatement com.espertech.esper.client.EPAdministrator.createEPL(String eplStatement, String statementName)
创建并启动一个 EPL statement,这个statement有名字。

String[] com.espertech.esper.client.EPAdministrator.getStatementNames()
返回所有的这个EP管理员创建过的epl。包括运行的和停止的,不包括销毁的。
EPStatement com.espertech.esper.client.EPAdministrator.getStatement(String name)
根据指定的状态名称返回这个EPStatement。


void com.espertech.esper.client.EPListenable.addListener(UpdateListener listener)
EPStatementEPListenable的实现类。此方法用于添加listener。
com.espertech.esper.client.UpdateListener
此接口用于esper向用户通知新旧事件。
void test.AppleListener.update(EventBean[] newEvents, EventBean[] oldEvents)
UpdateListener接口中的方法。用于通知可用的新事件或移除的旧事件。一般情况下,二者中的一个为null。
void com.espertech.esper.client.EPRuntime.sendEvent(Object object) 
发送一个pojo给EPRuntime,这个pojo代表一个事件。 
void com.espertech.esper.client.EPRuntime.sendEvent(Map map, String mapEventTypeName) 
发送一个map给EPRuntime。
com.espertech.esper.client.EventBean
此接口代表一个事件。
Object com.espertech.esper.client.EventBean.get(String propertyExpression) 
返回事件中的指定属性。

EPL:select name from User
//假设newEvents长度为一
newEvents[0].get("name")能得到进入的User事件的name属性值

EPL:select count(*) from User.win:time(5 sec)
//假设newEvents长度为一
newEvents[0].get("count(*)")能得到5秒内进入引擎的User事件数量有多少

ConfigurationOperations com.espertech.esper.client.EPAdministrator.getConfiguration()

得到ConfigurationOperations对象,用于配置EPRuntime。

void com.espertech.esper.client.ConfigurationOperations.addEventType(String eventTypeName, Map<String, Object> typeMap)

配置map事件的格式与名字。
目录
相关文章
|
4月前
|
安全 算法 Java
常用类以及接口
常用类以及接口
|
2月前
|
前端开发 Android开发 Kotlin
Kotlin小技巧之用Transformations.map方法转换LiveData
`Transformations.map`在Kotlin的Android开发中用于LiveData的数据转换,它在数据变化时自动转换并更新新LiveData。例如,从Int转为String。当原始LiveData更新时,转换后的LiveData也相应更新,适合MVVM架构。观察者可以订阅转换后的LiveData以更新UI。
29 2
|
2月前
|
并行计算 Java 大数据
Java中的函数式接口与流式编程
Java中的函数式接口与流式编程
|
4月前
|
Java C# C++
【从Java转C#】第八章:委托、lambda、事件
【从Java转C#】第八章:委托、lambda、事件
|
安全 Java 程序员
【Java挠头】可变参、foreach、Annotation等特性
【Java挠头】可变参、foreach、Annotation等特性
|
存储 安全 算法
3. 常用类
看类的描述 Random类是用于生成随机数的类
60 0
3. 常用类
|
存储 安全 Java
第5章 常用类
包装类、String、时间API、Math等,以及Comparable和Compartor两个比较器。
85 0
|
SQL Java 测试技术
JAVA8新特性 函数式接口以及常用的Stream流操作
JAVA8新特性 函数式接口以及常用的Stream流操作
JAVA8新特性 函数式接口以及常用的Stream流操作
|
存储 Java 开发工具
TreeSet子类排序操作 | 带你学《Java语言高级特性》之一百零五
本节分析了TreeSet子类排序操作和重复元素消除的过程。
TreeSet子类排序操作 | 带你学《Java语言高级特性》之一百零五