3 处理模型（Processing Model）
Esper的处理模型是持续的：更新监听器listener和订阅者subscriber，当事件到来时，根据声明对事件流、视图、过滤和输出等。
监听器的接口是com.espertech.esper.client.UpdateListener，必须实现update方法，这个函数会在结果到来时触发。
3.2 插入流（Insert Stream）
我们来看一个非常简单的EPL语句：
Select * from Withdrawal
这条语句没有附加任何过滤、视图等条件。这条语句会当Withdrawal或者其子类对象到来时触发。
下面是是一个例子。
图3.1 Output example for a simple statement
上面这个简单的例子中只有new events被提交到语句的监听器中，oldevents没有。
3.3 插入和删除流
一个长度窗口是让引擎只保留最近的N个事件。下面的语句给Withdrawal事件流一个长度窗口。这条语句用于说明数据窗口，一个事件有进就有出的数据窗口。
select * from Withdrawal.win:length(5)
下面这幅图就是数据窗口的一个例子：
它保有5个时间，所以当窗口满了后，最先的w1事件就会被删除，做old events送给监听器。
和长度窗口类似的还有事件窗口。
3.4 过滤和where语句
过滤器会过滤掉那些不符合条件的事件，这些事件就不会被投递到语句的监听器中。例如：
select * fromWithdrawal(amount>=200).win:length(5)
任何amount值小于200的Withdrawal对象都不会被投到监听器的回调函数里面。下图是说明。
上述图可以看到，事件还没有进入到窗口就被过滤了。
Where和having语句则不一样，它是在事件进入到窗口之后再过滤。
select * from Withdrawal.win:length(5)where amount >= 200
3.5 时间窗口（Time Window）
这一节我们说明时间窗口以及时间批处理窗口
3.5.1 时间窗口
时间窗口就是保留特定事件间隔内的事件。
下面是一个示例：
select account, avg(amount)
from Withdrawal.win:time(4 sec)
group by account
having amount > 1000
下面是一个更为简单的例子：
select * from Withdrawal.win:time(4 sec)
下面图示是解释其原理：
3.5.2 Time Batch 事件批处理
就是每隔设定的时间才会去触发一次监听器。
例如如下语句：
select * from Withdrawal.win:time_batch(4sec)
其运行原理如图：