Versions Compared

Key

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

...

Users who want to keep the current behavior can prepend a .filter() operator to the aforementioned operators and filter accordingly.

E.g.

//new ifleft join for when old behavior is needed
leftStream.filter((key, value) -> key != null)
.leftJoin(rightStream, (lv, rv) -> join(lv, rv), windows);

Why not make this change opt in?
By default we would like the behavior a stream defined via DSL to be consistent with the defined semantics.

...