System-aware dynamic partitioning for batch and streaming workloads - resources referenced in paper

Dynamic Repartitioning core library: https://github.com/zzvara/dynamic-repartitioning

Dynamic Repartitioning on Apache Spark: https://github.com/zzvara/spark-dynamic

Dynamic Repartitioning on Apache Flink: https://github.com/zzvara/flink-dynamic

Measurement code for hashing techniques: https://github.com/szape/dr-microbenchmarks

Measurement code for sampling techniques: https://github.com/zzvara/dr-sampling-measurements

Space Saving algorithm: https://github.com/zzvara/space-saving

Lossy Counting algorithm: https://github.com/zzvara/dr-freq-count