Announcing the flink-htm project, providing distributed, real-time anomaly detection with Apache Flink and Numenta&#x27;s Hierarchical Temporal Memory (HTM).
https:&#x2F;&#x2F;github.com&#x2F;nupic-community&#x2F;flink-htm<p>Read more about HTM theory at http:&#x2F;&#x2F;numenta.org&#x2F;. Note that flink-htm uses the official Java implementation of the NuPIC framework - HTM.java.<p>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<p>Please check the wiki section for an introductory video and example code. The project is at an early stage - volunteers wanted!
Announcing Flink-HTM – Anomaly Detection for Apache Flink