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