pathwaycom/pathway v0.7.5 on GitHub

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.

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.

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