@@ -62,23 +62,14 @@ impl HdfsObjectStore {
62
62
63
63
/// Creates a new HdfsObjectStore using the specified URL
64
64
///
65
- /// Connect to a single NameNode
65
+ /// Connect to a NameNode
66
66
/// ```rust
67
67
/// # use hdfs_native_object_store::HdfsObjectStore;
68
68
/// # fn main() -> object_store::Result<()> {
69
69
/// let store = HdfsObjectStore::with_url("hdfs://127.0.0.1:9000")?;
70
70
/// # Ok(())
71
71
/// # }
72
72
/// ```
73
- ///
74
- /// Connect to a NameService
75
- /// ```rust
76
- /// # use hdfs_native_object_store::HdfsObjectStore;
77
- /// # fn main() -> object_store::Result<()> {
78
- /// let store = HdfsObjectStore::with_url("hdfs://ns")?;
79
- /// # Ok(())
80
- /// # }
81
- /// ```
82
73
pub fn with_url ( url : & str ) -> Result < Self > {
83
74
Ok ( Self :: new ( Arc :: new ( Client :: new ( url) . to_object_store_err ( ) ?) ) )
84
75
}
@@ -92,8 +83,8 @@ impl HdfsObjectStore {
92
83
/// # fn main() -> object_store::Result<()> {
93
84
/// let config = HashMap::from([
94
85
/// ("dfs.ha.namenodes.ns".to_string(), "nn1,nn2".to_string()),
95
- /// ("dfs.namenode.rpc-address.nn1".to_string(), "nn1.example.com:9000".to_string()),
96
- /// ("dfs.namenode.rpc-address.nn2".to_string(), "nn2.example.com:9000".to_string()),
86
+ /// ("dfs.namenode.rpc-address.ns. nn1".to_string(), "nn1.example.com:9000".to_string()),
87
+ /// ("dfs.namenode.rpc-address.ns. nn2".to_string(), "nn2.example.com:9000".to_string()),
97
88
/// ]);
98
89
/// let store = HdfsObjectStore::with_config("hdfs://ns", config)?;
99
90
/// # Ok(())
0 commit comments