Versions Compared

Old Version 5

changes.mady.by.user Dong Lin

Saved on

compared with

New Version 6

changes.mady.by.user Dong Lin

Saved on

Key

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

...

This show that the same DataStream program in stream mode can be more than 10X faster with proposed change.


Example Usages


Code Block
languagejava
data1.coGroup(data2)
     .where(tuple -> tuple.f0)
     .equalTo(tuple -> tuple.f0)
     .window(EndOfStreamWindows.get())
     .apply(new CustomCoGroupFunction())
     .addSink(...);


Compatibility, Deprecation, and Migration Plan

...