Exactly-once fault-tolerance in Apache Flink - CS 591 K1: Data Stream Processing and Analytics Spring 2020nlBpnsg7M04xiOlA8ogzaqzkY897bPSqNbfuzkCWiVe QGhRo9apf3X7CshilYJq3fHc1AQ5VYzgZNKN9OYUjaiA+xYKmMOshnx07IiVX6JEqULWnITP09kdNY63Ec2s6YmqFe9Kbif14nM9FkHOZgYlmy+KMkFMQqafkz5XyIwYW0KZ4vZWwoZUWZsPhUbgrf48jLxG/XLund7VmteF nlBpnsg7M04xiOlA8ogzaqzkY897bPSqNbfuzkCWiVe QGhRo9apf3X7CshilYJq3fHc1AQ5VYzgZNKN9OYUjaiA+xYKmMOshnx07IiVX6JEqULWnITP09kdNY63Ec2s6YmqFe9Kbif14nM9FkHOZgYlmy+KMkFMQqafkz5XyIwYW0KZ4vZWwoZUWZsPhUbgrf48jLxG/XLund7VmteF nlBpnsg7M04xiOlA8ogzaqzkY897bPSqNbfuzkCWiVe QGhRo9apf3X7CshilYJq3fHc1AQ5VYzgZNKN9OYUjaiA+xYKmMOshnx07IiVX6JEqULWnITP09kdNY63Ec2s6YmqFe9Kbif14nM9FkHOZgYlmy+KMkFMQqafkz5XyIwYW0KZ4vZWwoZUWZsPhUbgrf48jLxG/XLund7VmteF0 码力 | 81 页 | 13.18 MB | 1 年前3- Apache Flink的过去、现在和未来| Frank | 3 | 12:03 | | Julie | 1 | 12:03 | | Frank | 2 | 12:06 | | Julie | 4 | 12:07 | ------------------------- ----------------------------- | [-inf, 12:01) | | ------------------------- ------------------------- | | Name | Score | Time | | ------------------------- | | Julie | 12 | 12:07 | | | Frank | 5 | 12:06 | | ------------------------- | ---------------------------- Stream Mode:0 码力 | 33 页 | 3.36 MB | 1 年前3
- Flow control and load shedding - CS 591 K1: Data Stream Processing and Analytics Spring 2020University 2020 https://commons.wikimedia.org/wiki/File:Adaptive_streaming_overview_daseddon_2011_07_28.png 5 ??? Vasiliki Kalavri | Boston University 2020 Load shedding as an optimization problem Zdonik. Staying fit: Efficient load shedding techniques for distributed stream processing. (VLDB’07) • N. R. Katsipoulakis, A. Labrinidis, and P. K. Chrysanthis. Concept-driven load shedding: Reducing0 码力 | 43 页 | 2.42 MB | 1 年前3
- Scalable Stream Processing - Spark Streaming and Flinkactions of each type happened each hour. ▶ Store the result in MySQL. [https://databricks.com/blog/2016/07/28/structured-streaming-in-apache-spark.html] 60 / 79 Structured Streaming Example (2/3) ▶ We could am/teaching/cs4240/spring2018 ▶ Structured Streaming In Apache Spark: https://databricks.com/blog/2016/07/28/structured-streaming-in-apache-spark.html 78 / 79 Questions? 79 / 790 码力 | 113 页 | 1.22 MB | 1 年前3
- Course introduction - CS 591 K1: Data Stream Processing and Analytics Spring 2020read and become familiar with the format and schema document: • https://drive.google.com/file/d/0B5g07T_gRDg9Z0lsSTEtTWtpOW8/view Download and play around with “part-00000-of-00500.csv” of: • job events0 码力 | 34 页 | 2.53 MB | 1 年前3
- Fault-tolerance demo & reconfiguration - CS 591 K1: Data Stream Processing and Analytics Spring 20202020 • A Deep Dive into Rescalable State in Apache Flink: https:// flink.apache.org/features/2017/07/04/flink-rescalable-state.html • Buğra Gedik. Partitioning functions for stateful data parallelism0 码力 | 41 页 | 4.09 MB | 1 年前3
- Cardinality and frequency estimation - CS 591 K1: Data Stream Processing and Analytics Spring 2020estimation algorithm. 2007. https://hal.archives-ouvertes.fr/file/index/docid/406166/ filename/FlFuGaMe07.pdf • Cormode, Graham, and Shan Muthukrishnan. An improved data stream summary: the count-min sketch0 码力 | 69 页 | 630.01 KB | 1 年前3
共 7 条
- 1