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!