如果是简单的测试触发handler的时间话,可以按照下面的示例进行设计:
def triggerTime(mutable tmpTable, msg) { update msg set triggerTime=now() tmpTable.append!(msg)
}
temTable是一个临时内存表,handler对传入的数据表msg的处理工作是增加了一列triggerTime,保存触发handler的时间,并存入临时表temTable,temTable的表结构相比传入handler的流数据表多一列triggerTime。