This repo has some WIP for some ideas I have about using Kafka Streams to process data based on simple spatio-temporal windows instead of just temporal windows.
Here we have Clojure and Java code which aggregates to simple hexbins.
More to come, I hope...
Copyright © 2016 Tom Faulhaber
Distributed under the Eclipse Public License either version 1.0 or (at your option) any later version.