v3.16.0

What's Changed

💎 New features

[experimental] StreamingDataFrame.join_lookup

StreamingDataFrame.join_lookup() is a new special type of join that allows you to enrich records in a streaming dataframe with the data from external systems.

You can use it to enrich streaming data with configuration or reference data from an external source, like a database.
Note: This is an experimental feature, and the API may change in the future.

Docs - https://quix.io/docs/quix-streams/joins.html#lookup-join

By @ovv in #895 #910

Accept the Application(quix_portal_api=...) parameter to specify the dedicated Quix Cloud control plane URL.

By @daniil-quix in #902

🦠 Bugfixes

• Add fix for using reducer with window with test added by @petrpan26 in #918

📖 Docs

• Add Solar Farm Enrichment tutorial by @daniil-quix in #903

🛠️ Internal

• API to collect duplicates in join-related store by @gwaramadze in #906
• Topics refactoring by @daniil-quix in #896
• Lazy creation of RocksDB column families by @gwaramadze in #905

Dependencies

• Bump types-requests from 2.32.0.20250515 to 2.32.0.20250602 by @dependabot in #914
• Bump mypy from 1.15.0 to 1.16.0 by @dependabot in #915
• Bump types-jsonschema from 4.23.0.20241208 to 4.23.0.20250516 by @dependabot in #897

New Contributors

• @petrpan26 made their first contribution in #918

Full Changelog: v3.15.0...v3.16.0