v0.7.5

Added

• Added Table.split() method for splitting table based on an expression into two tables.
• Columns with datatype duration can now be multiplied and divided by floats.
• Columns with datatype duration now support both true and floor division (/ and //) by integers.

Changed

• Pathway is better at typing if_else expressions when optional types are involved.
• table.flatten() operator now supports Json array.
• Buffers (used to delay outputs, configured via delay in common_behavior) now flush the data when the computation is finished. The effect of this change can be seen when run in bounded (batch / multi-revision) mode.
• pw.io.subscribe() takes additional argument on_time_end - the callback function to be called on each closed time of computation.
• pw.io.subscribe() is now a single-worker operator, guaranteeing that on_end is triggered at most once.
• KNNIndex supports now metadata filtering. Each query can specify it's own filter in the JMESPath format.

Fixed

• Resolved an optimization bug causing pw.iterate to malfunction when handling columns effectively pointing to the same data.