Struct HdfsClient

pub struct HdfsClient { /* private fields */ }

Asynchronous WebHDFS client

Implementations

impl HdfsClient

pub async fn dir( &self, fostate: FOState, path: &str, ) -> FOResult<ListStatusResponse>

Get directory listing

pub async fn stat( &self, fostate: FOState, path: &str, ) -> FOResult<FileStatusResponse>

Get status

pub async fn open( &self, fostate: FOState, path: &str, opts: OpenOptions, ) -> FOResult<Box<dyn Stream<Item = Result<Bytes>> + Unpin>>

Read file data

pub async fn create<'t>( &'t self, fostate: FOState, path: &'t str, data: Data, opts: CreateOptions, ) -> FODResult<()>

Create a HDFS file and write some data

pub async fn append<'t>( &'t self, fostate: FOState, path: &'t str, data: Data, opts: AppendOptions, ) -> FODResult<()>

Append to a HDFS file

pub async fn concat( &self, fostate: FOState, path: &str, paths: Vec<String>, ) -> FOResult<()>

Concatenate files

pub async fn mkdirs( &self, fostate: FOState, path: &str, opts: MkdirsOptions, ) -> FOResult<bool>

Make a directory

pub async fn rename( &self, fostate: FOState, path: &str, destination: String, ) -> FOResult<bool>

Rename a file/directory

pub async fn create_symlink( &self, fostate: FOState, path: &str, destination: String, opts: CreateSymlinkOptions, ) -> FOResult<()>

Create a Symbolic Link

pub async fn delete( &self, fostate: FOState, path: &str, opts: DeleteOptions, ) -> FOResult<bool>

Delete a File/Directory