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