|
@@ -281,6 +281,7 @@ public class ConfigurationBuilder {
|
|
|
conf.set("fs.swebhdfs.impl", SWebHdfsFileSystem.class.getName());
|
|
|
|
|
|
configureWASB();
|
|
|
+ configureADL();
|
|
|
|
|
|
return conf;
|
|
|
}
|
|
@@ -302,6 +303,18 @@ public class ConfigurationBuilder {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * Fill adl properties if adl:// scheme configured
|
|
|
+ */
|
|
|
+ public void configureADL() {
|
|
|
+ if (defaultFsUri.getScheme().equals("adl")) {
|
|
|
+ conf.set("fs.adl.impl", "com.microsoft.azure.datalake.store.AdlFileSystem");
|
|
|
+ copyPropertyIfExists(CORE_SITE,"dfs.webhdfs.oauth2.access.token.provider");
|
|
|
+ copyPropertyIfExists(CORE_SITE,"fs.azure.datalake.token.provider.service.urls");
|
|
|
+ copyPropertyIfExists(CORE_SITE,"fs.azure.datalake.token.provider.script");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* Builds the authentication configuration
|
|
|
* @return map of HDFS auth params for view
|