diff --git a/_images/datastream.png b/_images/datastream.png new file mode 100644 index 0000000..c56a2e0 Binary files /dev/null and b/_images/datastream.png differ diff --git a/_images/flink-cluster1.png b/_images/flink-cluster1.png new file mode 100644 index 0000000..536d797 Binary files /dev/null and b/_images/flink-cluster1.png differ diff --git a/_images/flink-cluster2.png b/_images/flink-cluster2.png new file mode 100644 index 0000000..abcc5c1 Binary files /dev/null and b/_images/flink-cluster2.png differ diff --git a/_images/flink-cluster3.png b/_images/flink-cluster3.png new file mode 100644 index 0000000..058474f Binary files /dev/null and b/_images/flink-cluster3.png differ diff --git a/_images/flink1.png b/_images/flink1.png new file mode 100644 index 0000000..a57b46f Binary files /dev/null and b/_images/flink1.png differ diff --git a/_images/flink2.png b/_images/flink2.png new file mode 100644 index 0000000..7b18903 Binary files /dev/null and b/_images/flink2.png differ diff --git a/_images/flink3.png b/_images/flink3.png new file mode 100644 index 0000000..2a00650 Binary files /dev/null and b/_images/flink3.png differ diff --git a/_images/jobmanager-1.png b/_images/jobmanager-1.png new file mode 100644 index 0000000..41243de Binary files /dev/null and b/_images/jobmanager-1.png differ diff --git a/_images/plan_visualizer.png b/_images/plan_visualizer.png new file mode 100644 index 0000000..85b8c55 Binary files /dev/null and b/_images/plan_visualizer.png differ diff --git a/flink.html b/flink.html new file mode 100644 index 0000000..4526f87 --- /dev/null +++ b/flink.html @@ -0,0 +1,285 @@ + + + + + + Flink + + + + + + + + + + + + + + + + + + + + + + + + +
+
+
+
+

Flink

+
+
+ +
+
+ 

+cat log.log | grep ERROR | cut -f2 -d: > errors.txt
+
+
+ +
+

Entrada

+ + 

cat log.log

+
+ +
+

Processamento

+ + 

grep ERROR

+ +

+ 
cut -f2 -d:
+

+
+ +
+

Saída

+ +

+ 
> errors.txt
+

+
+
+ +
+
+

cat

+ +

Tem começo e fim

+ +

"bounded"

+
+ +
+

Dados "infinitos"

+ +

"unbounded"

+
+
+ +
+
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+

Operators

+ +
    +
  • map
    • +
  • flatMap
    • +
  • filter
    • +
  • reduce
    • +
  • split/select
    • +
  • join
    • +
  • keyBy
    • +
  • window
    • +
+
+
+ +
+
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+
+ +
+
+ +
+ +
+ +
+ +
+ +
+ +
+ +
+
+ +
+
+ +
+
+ +
+
+ +
+ +
+ +
+
+ +
+
+
+
+
+ + + + + + + +