Struct hdrs::ClientBuilder

pub struct ClientBuilder { /* private fields */ }

The builder of connecting to hdfs clusters.

Examples

use hdrs::{Client, ClientBuilder};

let fs = ClientBuilder::new("default")
    .with_user("default")
    .with_kerberos_ticket_cache_path("/tmp/krb5_111")
    .connect();

Implementations

impl ClientBuilder

pub fn new(name_node: &str) -> ClientBuilder

Create a ClientBuilder with name node

Returns an [hdrs::ClientBuilder]

Notes

The NameNode to use.

If the string given is profile name like ‘default’, the related NameNode configuration will be used (from the XML configuration files).

If the string starts with a protocol type such as file:// or hdfs://, this protocol type will be used. If not, the hdfs:// protocol type will be used. You may specify a NameNode port in the usual way by passing a string of the format hdfs://<hostname>:<port>.

Examples

use hdrs::{Client, ClientBuilder};

let builder = ClientBuilder::new("default");

pub fn with_user(self, user: &str) -> ClientBuilder

Set the user for existing ClientBuilder

Examples

use hdrs::{Client, ClientBuilder};

let client = ClientBuilder::new("default").with_user("default").connect();

pub fn with_kerberos_ticket_cache_path( self, kerberos_ticket_cache_path: &str ) -> ClientBuilder

Set the krb5 ticket cache path for existing ClientBuilder

Examples

use hdrs::{Client, ClientBuilder};

let mut client = ClientBuilder::new("default")
    .with_kerberos_ticket_cache_path("/tmp/krb5_1001")
    .connect();

pub fn connect(self) -> Result<Client>

Connect for existing ClientBuilder to get a hdfs client

Returns an io::Result if any error happens.

Examples

use hdrs::{Client, ClientBuilder};

let mut client = ClientBuilder::new("default").connect();