pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.register_cached_file#
- StreamExecutionEnvironment.register_cached_file(file_path: str, name: str, executable: bool = False)[source]#
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.