Apache Flink 1.10
flink.apache.org
flink.apache.org
If you're interested in stuff like this, keep an eye on OctoSQL[1].
We're working hard on event time streaming with exactly-once semantics in pure SQL, being greatly inspired by the work and research done by the Flink contributors.
It's our Bachelor Thesis actually. Though we have much left to work on, with features like distributed execution, so there's still a long way ahead!
http://wwwlgis.informatik.uni-kl.de/cms/dbis/projects/bracki...
The project itself (http://brackit.org) might not be further developed by Dr. Sebastian Baechle and his students under supervision from Dr. Dr. Theo Härder (invented transactions / ACID semantics), but I'm maintaining a fork with a lot of JSON processing enhancements and time travel query additions:
https://github.com/sirixdb/brackit
I'd love to refactor main parts of the query processor and to port it to Kotlin. However, as always it would be amazing to get help :-)
Research possibilities are almost endless of course, especially regarding distributed query processing with Fink or Kafka, looking into how best to support concurrent operations...
Publications:
Separating Key Concerns in Query Processing - Set Orientation, Physical Data Independence, and Parallelism:
http://wwwlgis.informatik.uni-kl.de/cms/fileadmin/publicatio...
XQuery Processing over NoSQL Stores:
http://wwwlgis.informatik.uni-kl.de/cms/fileadmin/publicatio...
BrackitMR: Flexible XQuery Processing in MapReduce:
http://wwwlgis.informatik.uni-kl.de/cms/fileadmin/publicatio...
Unleashing XQuery for Data-independent Programming:
http://wwwlgis.informatik.uni-kl.de/cms/fileadmin/publicatio...
Versatile XQuery Processing in MapReduce:
http://wwwlgis.informatik.uni-kl.de/cms/fileadmin/publicatio...