python - Python 中 Beam 的 LeftOuterJoin

Question

似乎目前在 Beam Python 中没有实现连接（例如 LeftOuterJoin）。

对于 Java，有org.apache.beam.sdk.extensions.joinlibrary，但似乎还没有可用于 Python 的扩展。是否有实施扩展的路线图？

那么在 Python 中重新实现 joinlibrary 是否有意义，否则如何获得 LeftOuterJoin？

标签： pythonapache-beam

Answer 1

Python 中的左/右/内/外连接没有官方实现的库。它很好，可以使用。

https://github.com/pavan-kattamuri/da​​taflow_joins/blob/master/custom_transforms/joins.py

• 示例：https ://github.com/pavan-kattamuri/da​​taflow_joins/blob/master/test.py