如何在Java管道中使用Python ParDo?

时间:2022-01-04 15:33:41

I have a Python code for data analysis and I want to embed it inside a much bigger pipeline which is written in Apache Beam Java SDK. I know that there is also a Python SDK but I don't know how to combine between them.

我有一个用于数据分析的Python代码,我想将它嵌入一个用Apache Beam Java SDK编写的更大的管道中。我知道还有一个Python SDK,但我不知道如何在它们之间进行组合。

How can it be done?

如何做呢?

1 个解决方案

#1


2  

This is currently not supported. It is a great idea, and something that is being considered. Much of the work on the in-progress portability API has the potential to enable this, but there is no estimate for when it will actually be possible.

目前不支持此功能。这是一个好主意,正在考虑的事情。正在进行的可移植性API的大部分工作都有可能实现这一点,但是没有估计实际可行的时间。

#1


2  

This is currently not supported. It is a great idea, and something that is being considered. Much of the work on the in-progress portability API has the potential to enable this, but there is no estimate for when it will actually be possible.

目前不支持此功能。这是一个好主意,正在考虑的事情。正在进行的可移植性API的大部分工作都有可能实现这一点,但是没有估计实际可行的时间。