pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.register_cached_file

StreamExecutionEnvironment.register_cached_file(file_path: str, name: str, executable: bool = False)

Registers a file at the distributed cache under the given name. The file will be accessible from any user-defined function in the (distributed) runtime under a local path. Files may be local files (which will be distributed via BlobServer), or files in a distributed file system. The runtime will copy the files temporarily to a local cache, if needed.

Parameters

• file_path – The path of the file, as a URI (e.g. “file:///some/path” or hdfs://host:port/and/path”).

• name – The name under which the file is registered.

• executable – Flag indicating whether the file should be executable.

New in version 1.16.0.