Skip to content

Latest commit

 

History

History
19 lines (13 loc) · 497 Bytes

README.md

File metadata and controls

19 lines (13 loc) · 497 Bytes

wordstream-flink

Streaming filter on Flink for netcat on Windows. You need to run netcat "nc" on Windows using the following commnad:

nc64.exe -L -p 9999

In Linux/Mac OS, this command will be:

nc -l 9999

The code can be run directly from within the Intellij IDEA IDE.

Flink examples:

  • FilterSettings: Basic streaming by filtering double input only. Other types of input will be ignored.
  • WaterMarkEventSettings: Creating a sum 10-second window every 5 seconds.