References

Jump to bottom

Kevin Nguyen edited this page Jun 27, 2023 · 5 revisions

Papers

Benchmarking Distributed Stream Data Processing Systems
Delay-Resistant Geo-Distributed Analytics
AggNet: Cost-Aware Aggregation Networks for Geo-Distributed Streaming Analytics

Online

Programming Tutorials

pumba: https://github.com/alexei-led/pumba
Flink Data Generator: https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/datagen/DataGenerator.java
Server-side socket programming: https://docs.oracle.com/javase/tutorial/networking/sockets/clientServer.html, https://stackoverflow.com/questions/61583168/how-to-programmatically-write-text-to-flink-socket
Deserialization: https://www.baeldung.com/kafka-flink-data-pipeline
Aggregation: https://github.com/eugenp/tutorials/blob/master/apache-kafka/src/main/java/com/baeldung/flink/FlinkDataPipeline.java

Benchmarks

StreamBenchmarks: https://github.com/streamline-eu/StreamBenchmarks/
Yahoo Streaming Benchmark: https://github.com/dataArtisans/yahoo-streaming-benchmark
Flink/Kafka benchmark: https://github.com/Klarrio/open-stream-processing-benchmark/wiki/Benchmark