pathwaycom/pathway v0.15.4

on GitHub

Added

• pw.io.kafka.read now supports reading entries starting from a specified timestamp.
• pw.io.nats.read and pw.io.nats.write methods for reading from and writing Pathway tables to NATS.

Changed

• pw.Table.diff now supports setting instance parameter that allows computing differences for multiple groups.
• pw.io.postgres.write_snapshot now keeps the Postgres table fully in sync with the current state of the table in Pathway. This means that if an entry is deleted in Pathway, the same entry will also be deleted from the Postgres table managed by the output connector.

Fixed

• pw.PyObjectWrapper is now picklable.