我们有一个基于 Flink 和 Kinesis Analytics 的流式事件处理管道。需要根据传入事件对某些指标实施异常检测。理想情况下，异常检测流程应该是同一个 Flink 作业的一部分。我知道有一个现成的可用函数 (RANDOM_CUT_FOREST) 基于 Kinesis Analytics SQL 应用程序的已发表 论文。
是否可以从 Kinesis Analytics Java 应用程序中使用此功能？Flink 中是否还有其他可用于流式异常检测的生产就绪库？
我们有一个基于 Flink 和 Kinesis Analytics 的流式事件处理管道。需要根据传入事件对某些指标实施异常检测。理想情况下，异常检测流程应该是同一个 Flink 作业的一部分。我知道有一个现成的可用函数 (RANDOM_CUT_FOREST) 基于 Kinesis Analytics SQL 应用程序的已发表 论文。
是否可以从 Kinesis Analytics Java 应用程序中使用此功能？Flink 中是否还有其他可用于流式异常检测的生产就绪库？