Method create_file

tests/util/adls_util.py:37–42

(self, path, file_data, overwrite=True)

    self.adls_cli_client = HadoopFsCommandLineClient("ADLS")

  def create_file(self, path, file_data, overwrite=True):
    if not overwrite and self.exists(path): return False
    with self.adlsclient.open(path, 'wb') as f:
      num_bytes = f.write(file_data)
      assert num_bytes == len(file_data), "ADLS write failed."
    return True

  def make_dir(self, path, permission=None):
    self.adlsclient.mkdir(path)