Hi all, Great discussion thread. May I take this KIP up? If it’s alright my plan is to update the KIP with the operator `markAsPartitioned()`.
As you have discussed and pointed out, there are implications to downstream joins or aggregation operations. Still, the operator is intended for advanced users so my two cents is it would be a valuable addition nonetheless. We could add this as a caution/consideration as part of the java doc. Let me know, thanks. Shay