def METHOD_NAME(
    self, hdfs_path, local_path, overwrite=True, parallelism=1, **kwargs
):
    c = self.get_conn()
    out = c.download(
        hdfs_path=hdfs_path,
        local_path=local_path,
        overwrite=overwrite,
        n_threads=parallelism,
        **kwargs,
    )
    logging.debug("Download file {} to {}".format(hdfs_path, local_path))
    return out