A suite of benchmark applications for distributed data stream processing systems

Develop increasingly sophisticated databases from scratch in Java

SamzaSQL: Streaming SQL implementation on top of Apache Samza and Apache Kafka

Cluster computing using Stateful Dataflow Graphs

Walmart version of the Linear Road streaming benchmark.

S-Store Transactional Streaming Data Management System

A Memory-efficient Graph Store for Interactive Queries

A database with automatic dynamic imputation of missing values.

Real-time visual analytics for soccer matches, leveraging Apache Flink, Apache Kafka and the Elastic stack. Solution to DEBS 2013 Grand Challenge. Coursework in Systems and Architectures for Big Da…

Examples of Flink's in-built connectors with various external systems such as Kafka, Elasticsearch, S3 etc. I will also share few custom connectors using Flink RichSourceFunction API.

Temporal graph data management atop Neo4j

An efficient graph database for large online transactions based on Neo4j

Olga Poppe, Chuan Lei, Lei Ma and Elke A. Rundensteiner. 2021. To Share, or not to Share Online Event Trend Aggregation OverBursty Event Streams. ACM SIGMOD.

GroupSimple-9: integer compression

Real-time social media analytics application that monitors posts and users popularity, leveraging Apache Flink. Research work accepted to the 10th ACM International Conference on Distributed and Ev…