Versions Compared

Old Version 4

changes.mady.by.user Chen Qin

Saved on

compared with

New Version 5

changes.mady.by.user Chen Qin

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • Add org.apache.flink.util.RichCollector.

    Replace possible userFunciton Collector with it’s extension RichCollector.
  • offer RichCollector from RichFunction RuntimeContext instance

Proposed Changes

We want to introduce outputTag and support operator collect arbitrary types of records with defined output Tags. In this prototype, it demonstrated how things works in raw/hacky form.

...