From 1527a6fefa9349a19a73311269d489a98ddcb95f Mon Sep 17 00:00:00 2001 From: Julio Biason Date: Fri, 3 Aug 2018 13:42:06 -0300 Subject: [PATCH] Added a simple readme --- README.md | 53 +++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 53 insertions(+) create mode 100644 README.md diff --git a/README.md b/README.md new file mode 100644 index 0000000..4960e26 --- /dev/null +++ b/README.md @@ -0,0 +1,53 @@ +# An example of Flink Windows and Watermarks + +TODO + +## Running + +One window: `nc -l 60000` + +Other window: `sbt "run --hostname 127.0.0.1 --port 60000"` + +## Input + +_TODO_: EXPLAIN THIS + +1 window1 +2 window1 +2 window1 +20 window1 +29 window1 +31 window2 +45 window2 +21 window1 + + +## Output + +CREATE - window1 at 1s seen 1 times +WATERMARK - moved to -9 +CREATE - window1 at 2s seen 1 times +WATERMARK - moved to -8 +REDUCE - window1 at 1s seen 1 times + window1 at 2s seen 1 times, now window1 at 1s seen 2 times +CREATE - window1 at 2s seen 1 times +REDUCE - window1 at 1s seen 2 times + window1 at 2s seen 1 times, now window1 at 1s seen 3 times +CREATE - window1 at 20s seen 1 times +WATERMARK - moved to 10 +REDUCE - window1 at 1s seen 3 times + window1 at 20s seen 1 times, now window1 at 1s seen 4 times +CREATE - window1 at 29s seen 1 times +WATERMARK - moved to 19 +REDUCE - window1 at 1s seen 4 times + window1 at 29s seen 1 times, now window1 at 1s seen 5 times +CREATE - window2 at 31s seen 1 times +WATERMARK - moved to 21 +CREATE - window2 at 45s seen 1 times +WATERMARK - moved to 35 +REDUCE - window2 at 31s seen 1 times + window2 at 45s seen 1 times, now window2 at 31s seen 2 times +FIRING - window1 at 1s seen 5 times to 0, now window1 at 0s seen 5 times +SINK - window1 at 0s seen 5 times +CREATE - window1 at 21s seen 1 times +REDUCE - window1 at 1s seen 5 times + window1 at 21s seen 1 times, now window1 at 1s seen 6 times +FIRING - window1 at 1s seen 6 times to 0, now window1 at 0s seen 6 times +SINK - window1 at 0s seen 6 times +FIRING - window2 at 31s seen 2 times to 30, now window2 at 30s seen 2 times +SINK - window2 at 30s seen 2 times +