SiddiExtension-MaxK:siddi 的 Max-K 转换器扩展 - 在临时时间段内保存流的 Max K 值

SiddiExtension-MaxK siddi 的 Max-K 转换器扩展 - 在临时时间段内保存流的 Max K 值。 设置： 编译该类，并将 jar 添加到类路径 <CEP>/repository/components/lib。 然后在新行中将实现类的完全限定类名添加到位于 <CEP>/repository/conf/siddhi 的 siddhi.extension 文件中。 这是如何在查询中使用扩展： from inputStream#transform.debs:getVeloities(value, date, K, time) select * insert into outStream;