Announcing Flink-HTM – Anomaly Detection for Apache Flink

[eronwright]

Announcing the flink-htm project, providing distributed, real-time anomaly detection with Apache Flink and Numenta's Hierarchical Temporal Memory (HTM). https://github.com/nupic-community/flink-htm

Read more about HTM theory at http://numenta.org/. Note that flink-htm uses the official Java implementation of the NuPIC framework - HTM.java.

The flink-htm library provides: - HTM learning operators on Flink data streams, providing anomaly scores and inference data - Distributed learning with Flink keyed streams - Full integration with Flink checkpointing for reliable processing - a Scala DSL to construct HTM networks - a River View connector for temporal datasets curated by Numenta

Please check the wiki section for an introductory video and example code. The project is at an early stage - volunteers wanted!