Added
- Added synchronization group mechanism to align multiple data sources based on selected columns. It can be accessed with
pw.io.register_input_synchronization_group. pw.io.register_input_synchronization_groupnow supports the following types of columns:pw.DateTimeUtc,pw.DateTimeNaive,pw.DateTimeDuration, andint.
Changed
- Enhanced error reporting for runtime errors across most operators, providing a trace that simplifies identifying the root cause.
Fixed
- Bugfix for problem with list_documents() when no documents present in store.
- The append-only property of tables created by
pw.io.kafka.readis now set correctly.