You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Pathway now warns when unintentionally creating Table with empty universe.
pw.io.kafka.write in raw and plaintext formats now supports output for tables with multiple columns. For such tables, it requires the specification of the column that must be used as a value of the produced Kafka messages and gives a possibility to provide column which must be used as a key.
pw.io.kafka.write can now output values from the table using Kafka message headers in 'raw' and 'plaintext' output format.
Changed
instance arguments to groupby, join, with_id_from now determine how entries are distributed between machines.
flatten results remain on the same machine as their source entries.
join sends each record between machines at most once.
BREAKING: flatten, join, groupby (if used with instance), with_id_from (if used with instance) generate IDs of the produced rows differently than in the previous versions.
pathway spawn with multiple workers prints only output from the first worker.