THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
//new if 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 DSL to be consistent with the defined semantics.
...