如何统计流数据处理的时候,触发handler的时间?

请问如何统计流数据处理的时候,触发handler的时间?

请先 登录 后评论

1 个回答

Jason Tang - 时序数据库技术支持

如果是简单的测试触发handler的时间话,可以按照下面的示例进行设计:

def triggerTime(mutable tmpTable, msg)
{	
	update msg set triggerTime=now()
	tmpTable.append!(msg)
}

temTable是一个临时内存表,handler对传入的数据表msg的处理工作是增加了一列triggerTime,保存触发handler的时间,并存入临时表temTable,temTable的表结构相比传入handler的流数据表多一列triggerTime

请先 登录 后评论