Struct HDFS

pub struct HDFS<S: Read + Write, D: Read + Write> { /* private fields */ }

Implementations

impl HDFS<BufStream<TcpStream>, BufStream<TcpStream>>

pub fn connect<S: ToString>( name_node: impl ToNameNodes, user: impl Into<Option<S>>, ) -> Result<Self>

pub fn connect_with(config: ClientConfig) -> Result<Self>

impl<S: Read + Write, D: Read + Write> HDFS<S, D>

pub fn new( create_ipc: impl Fn() -> Result<HRpc<S>> + 'static, connect_datanode: impl Fn(&DatanodeIdProto, IOType) -> Result<D> + 'static, ) -> Result<Self>

pub fn client_name(&self) -> &str

pub fn get_rpc(&mut self) -> &mut HRpc<S>

pub fn new_rpc(&mut self) -> Result<HRpc<S>, Error>

pub fn open( &mut self, path: impl AsRef<Path>, ) -> Result<FileReader<D>, HDFSError>

open a file

pub fn reader_options(&mut self) -> ReaderOptions

use reader option to custom file read options

pub fn create( &mut self, path: impl AsRef<Path>, ) -> Result<FileWriter<S, D>, HDFSError>

create a file

pub fn append( &mut self, path: impl AsRef<Path>, ) -> Result<FileWriter<S, D>, HDFSError>

open a existing file and append content to it

pub fn writer_options(&mut self) -> WriterOptions

pub fn create_dir(&mut self, path: impl AsRef<Path>) -> Result<(), HDFSError>

pub fn create_dir_all( &mut self, path: impl AsRef<Path>, ) -> Result<(), HDFSError>

pub fn read(&mut self, path: impl AsRef<Path>) -> Result<Vec<u8>, HDFSError>

read the entire contents of a file into a bytes vector.

pub fn read_dir( &mut self, path: impl AsRef<Path>, ) -> Result<Vec<HdfsFileStatusProto>, HDFSError>

pub fn remove_dir(&mut self, path: impl AsRef<Path>) -> Result<(), HDFSError>

pub fn remove_dir_all( &mut self, path: impl AsRef<Path>, ) -> Result<(), HDFSError>

pub fn remove_file(&mut self, path: impl AsRef<Path>) -> Result<(), HDFSError>

pub fn rename( &mut self, from: impl AsRef<Path>, to: impl AsRef<Path>, ) -> Result<(), HDFSError>