可以通过getStreamEngineStat()函数监视所有引擎的运行情况。
如果想查询指定的引擎使用情况,可以这样使用,比如查询该节点上所有时间序列聚合引擎的运行情况:
getStreamEngineStat().TimeSeriesEngine
结果如下:
memoryUsed表示该引擎占用的内存大小,时间序列引擎占用内存大小和garbageSize有关,garbageSize的默认是50000行,含义是每个组所保留的记录数。如果计算窗口结束,某个组的记录数超过garbageSize,就会清空已经计算完的且保存了的记录条数,该部分占用内存就会释放。