Struct DbfsClient

pub struct DbfsClient { /* private fields */ }

DBFS Client

Implementations

impl DbfsClient

pub fn new(url_base: &str, token: &str) -> Self

Create New DBFS Client

@param url_base: the base part of the DBFS endpoint, e.g. “https://adb-xxx.azuredatabricks.net” @param token: The Databricks API token

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

Read DBFS file, returns AsyncRead + AsyncBufRead

pub async fn read_file(&self, path: &str) -> Result<Vec<u8>>

Read the whole file into a Vec

pub async fn write_file<T>(&self, path: &str, data: T) -> Result<()>

where T: AsRef<[u8]>,

Write data to file, the existing content will be overwritten

pub async fn upload_file<T>( &self, local_path: T, remote_path: &str, ) -> Result<String>

where T: AsRef<Path>,

Upload a local file to DBFS

pub async fn download_file<T>( &self, remote_path: &str, local_path: T, ) -> Result<PathBuf>

where T: AsRef<Path>,

Download DBFS file to local path

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

Get DBFS file status

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

Delete DBFS file

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

Get all status of the files under the directory

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

Create directory recursively

pub async fn move_file(&self, src_path: &str, dest_path: &str) -> Result<()>

Move a DBFS file from one place to another

Trait Implementations

impl Clone for DbfsClient

fn clone(&self) -> DbfsClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DbfsClient

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

Formats the value using the given formatter.