code: def enable_hdfs_load(load_func):
      @functools.wraps(load_func)
      def multi_fs_load(path, *args, **kwargs):
          if is_local_path(path):
              return load_func(path, *args, **kwargs)
          else:
              file_name = str(uuid.uuid1())
              file_name = append_suffix(
                  file_name, path.strip("/").split("/")[-1]
              )
              with tempfile.TemporaryDirectory() as tmpdir:
                  temp_path = os.path.join(tmpdir, file_name)
                  classpath = subprocess.Popen(
                      ["hadoop", "classpath", "--glob"],
                      stdout=subprocess.PIPE,
                  ).communicate()[0]
                  os.environ["CLASSPATH"] = classpath.decode("utf-8")
                  import pyarrow.fs as pafs
                  import pyarrow as pa
  
                  hdfs = pa.hdfs.connect()
                  if not hdfs.isfile(path):
                      os.mkdir(temp_path)
                  pafs.copy_files(path, temp_path)
                  return load_func(temp_path, *args, **kwargs)
  
      return multi_fs_load
  
imports: import functools
  import glob
  import os
  import subprocess
  import tempfile
  import uuid
  from urllib.parse import urlparse
  import numpy
  from bigdl.dllib.utils.common import Sample, JTensor, JavaCreator, _get_gateway, _py2java, _java2py
  from bigdl.dllib.utils.log4Error import *
label_desc: Use image node_id 13 for calling a global function with example usage: enable_hdfs_load(load_func) and returns: multi_fs_load, load_func, load_func