State management - CS 591 K1: Data Stream Processing and Analytics Spring 2020University 2020 All data maintained by a task and used to compute results: a local or instance variable that is accessed by a task’s business logic Operator state is scoped to an operator task, i.e0 码力 | 24 页 | 914.13 KB | 1 年前3- Flow control and load shedding - CS 591 K1: Data Stream Processing and Analytics Spring 2020and P. K. Chrysanthis. Concept-driven load shedding: Reducing size and error of voluminous and variable data streams. (IEEE Big Data ’18) • H. T. Kung, T. Blackwell, and A. Chapman. Credit-based flow0 码力 | 43 页 | 2.42 MB | 1 年前3
- Streaming languages and operator semantics - CS 591 K1: Data Stream Processing and Analytics Spring 2020Kalavri | Boston University 2020 timely::example(|scope| { let (handle, stream) = scope.loop_variable(100, 1); (0..10).to_stream(scope) .concat(&stream) .inspect(|x| println0 码力 | 53 页 | 532.37 KB | 1 年前3
- PyFlink 1.15 Documentation12, you can download the binary distribution of Scala 2.12, unzip it and then set the environment variable FLINK_HOME to point to the unzipped directory. This makes it use the JAR packages specified by FLINK_HOME0 码力 | 36 页 | 266.77 KB | 1 年前3
- PyFlink 1.16 Documentation12, you can download the binary distribution of Scala 2.12, unzip it and then set the environment variable FLINK_HOME to point to the unzipped directory. This makes it use the JAR packages specified by FLINK_HOME0 码力 | 36 页 | 266.80 KB | 1 年前3
共 5 条
- 1