python - 如何在 PyFlink 中导入私有包

Question

我正在尝试在 PyFlink 中导入一个私有包。

我有一个需要调用私有库中的函数的 UDF（不能通过 pip install 获得，因为 repo 是私有的）。

因此我不能使用这样的东西：

table_env.set_python_requirements(requirements_file_path="/path/to/requirements.txt")

如何导入这个私有包以在我的 PyFlink UDF 函数中访问它？

标签： pythonapache-flinkpyflink