Struct webhdfs::async_client::HdfsClient

pub struct HdfsClient { /* fields omitted */ }

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