[FLINK-3549] Make streaming examples more streaming

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.0.0
• Component/s: Examples
• Labels: auto-deprioritized-major auto-deprioritized-minor
• Assignee: Unassigned
• Reporter: Stephan Ewen
• Created: 29/Feb/16 21:03
• Updated: 08/Feb/22 22:37

Description

The following choices make the examples "not streaming"

• Many of the streaming example are currently using a small bounded data set. The data set is immediately consumed, the program finishes
• Many examples read text or csv input files

I suggest to rework the examples to use not static data sets and files, but infinite streams and throttled generated streams (via iterators).

Command line parameters can be used to influence their behavior

Sub-Tasks

• Rework stream join example: Closed
• Sync Scala and Java Streaming Examples: Closed
• Change socket WordCount to be properly windowed: Closed
• Add Streaming State Machine Example: Closed