'LeftOuterJoin for Beam in Python

It seems like currently there is no implementation for Joins (e.g. LeftOuterJoin) in Beam Python.

For Java there is org.apache.beam.sdk.extensions.joinlibrary, but it seems like no extensions are yet available for Python. Is there any roadmap to implement extensions?

Would it then make sense to reimplement joinlibrary in Python or how else would one get LeftOuterJoin?



Solution 1:[1]

There is not-officially implemented library for left/right/inner/outer Join in Python. It's good and ready to use.

https://github.com/pavan-kattamuri/dataflow_joins/blob/master/custom_transforms/joins.py

Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source
Solution 1 gecko655