v2.1.1a
What's Changed
-
[New] Implemented
StreamingDataFrame.apply(expand=True)to produce multiple individual values based on the collection. [#246]
You may use.apply(expand=True)to produce multiple values to the output topics for a single input message
Docs -
[Fix] Make "and" and "or" comparisons lazy in
StreamingSeries[#248]
In previous versions, code likesdf['a'] | sdf['b']andsdf['a'] & sdf['b']was always evaluating both sides of the expression, while usualandandorcan evaluate the right side lazily.
Full Changelog: v2.1alpha1...v2.1.1a