Struct hdfs::HdfsFsCache

pub struct HdfsFsCache<'a> {
    // some fields omitted
}

HdfsFsCache which caches HdfsFs instances.

The original libhdfs allows only one HdfsFs instance for the same namenode. In otherwords, Some APIs of libhdfs are not thread-safe. So, You must get HdfsFs instance through HdfsFsCache, caching initialized HdfsFs instances and returning them.

Methods

impl<'a> HdfsFsCache<'a>

fn new() -> HdfsFsCache<'a>

fn get(&mut self, path: &str) -> Result<HdfsFs<'a>, HdfsErr>