如何在 Java 管道中使用 Python ParDo？
How to use Python ParDo in a Java pipeline?
我有一个用于数据分析的 Python 代码，我想将它嵌入到一个更大的管道中，该管道是用 Apache Beam Java SDK 编写的。
我知道还有一个 Python SDK，但我不知道如何将它们结合起来。
如何做到？
目前不支持。这是一个好主意，并且正在考虑中。正在进行的可移植性方面的大部分工作 API 都有可能实现这一点，但目前尚无实际实现时间的估计。
我有一个用于数据分析的 Python 代码，我想将它嵌入到一个更大的管道中，该管道是用 Apache Beam Java SDK 编写的。 我知道还有一个 Python SDK，但我不知道如何将它们结合起来。
如何做到？
目前不支持。这是一个好主意，并且正在考虑中。正在进行的可移植性方面的大部分工作 API 都有可能实现这一点，但目前尚无实际实现时间的估计。