Struct hdfs_native::client::Client

pub struct Client { /* private fields */ }

Implementations

impl Client

pub fn new(url: &str) -> Result<Self>

Creates a new HDFS Client. The URL must include the protocol and host, and optionally a port. If a port is included, the host is treated as a single NameNode. If no port is included, the host is treated as a name service that will be resolved using the HDFS config.

viewfs schemes are not currently supported.

pub async fn get_file_info(&self, path: &str) -> Result<FileStatus>

Retrieve the file status for the file at path.

pub async fn list_status( &self, path: &str, recursive: bool ) -> Result<Vec<FileStatus>>

Retrives a list of all files in directories located at path. Wrapper around list_status_iter that returns Err if any part of the stream fails, or Ok if all file statuses were found successfully.

pub fn list_status_iter( &self, path: &str, recursive: bool ) -> ListStatusIterator

Retrives an iterator of all files in directories located at path.

pub async fn read(&self, path: &str) -> Result<FileReader>

Opens a file reader for the file at path. Path should not include a scheme.

pub async fn create( &self, src: &str, write_options: WriteOptions ) -> Result<FileWriter>

pub async fn mkdirs( &self, path: &str, permission: u32, create_parent: bool ) -> Result<()>

Create a new directory at path with the given permission. If create_parent is true, any missing parent directories will be created as well, otherwise an error will be returned if the parent directory doesn’t already exist.

pub async fn rename(&self, src: &str, dst: &str, overwrite: bool) -> Result<()>

Renames src to dst. Returns Ok(()) on success, and Err otherwise.

pub async fn delete(&self, path: &str, recursive: bool) -> Result<bool>

Deletes the file or directory at path. If recursive is false and path is a non-empty directory, this will fail. Returns Ok(true) if it was successfully deleted.

Trait Implementations

impl Debug for Client

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.