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.