Expand description
Hadoop WebHDFS API for Rust
Quick start:
use webhdfs::*;
use webhdfs::sync_client::ReadHdfsFile;
use std::io::Read;
let cx = SyncHdfsClientBuilder::new("http://namenode:50070".parse().unwrap())
.user_name("johnd".to_owned())
.build().unwrap();
let mut file = ReadHdfsFile::open(cx, "/user/johnd/in.txt".to_owned()).unwrap();
let mut buf = [0u8; 100];
let _ = file.read(&mut buf).unwrap();
Re-exports§
pub use async_client::HdfsClient;
pub use async_client::HdfsClientBuilder;
pub use sync_client::SyncHdfsClient;
pub use sync_client::SyncHdfsClientBuilder;
pub use datatypes::*;
Modules§
- async_
client - Asynchronous WebHDFS client implementation
- config
- File-based configuration.
- datatypes
- sync_
client - Synchronous WebHDFS client
Structs§
- Append
Options - Create
Options - Create
Symlink Options - Delete
Options - Error
- Mkdirs
Options - NatMap
- Open
Options - Uri
- The URI component of a request.