Crate webhdfs

Source
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§

AppendOptions
CreateOptions
CreateSymlinkOptions
DeleteOptions
Error
MkdirsOptions
NatMap
OpenOptions
Uri
The URI component of a request.

Type Aliases§

Result