def _download_partitioned_file(self, n_threads):
    parts = {
      'part-r-00000': 'fee',
      'part-r-00001': 'faa',
      'part-r-00002': 'foo',
    }
    for name, content in parts.items():
      self.client.write('dl/%s' % (name, ), content)
    with temppath() as tpath:
      self.client.download('dl', tpath, n_threads=-1)
      local_parts = os.listdir(tpath)
      eq_(set(local_parts), set(parts)) # We have all the parts.
      for part in local_parts:
        with open(osp.join(tpath, part)) as reader:
          eq_(reader.read(), parts[part]) # Their content is correct.
dataset/ETHPy150Open mtth/hdfs/test/test_client.py/TestDownload._download_partitioned_file/original