pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.add_python_file

StreamExecutionEnvironment.add_python_file(file_path: str)

Adds a python dependency which could be python files, python packages or local directories. They will be added to the PYTHONPATH of the python UDF worker. Please make sure that these dependencies can be imported.

Parameters

file_path – The path of the python dependency.