Repository: hadoop Updated Branches: refs/heads/branch-2 a8f03ef7e -> 192594229
http://git-wip-us.apache.org/repos/asf/hadoop/blob/19259422/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/ADLPostOpParam.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/ADLPostOpParam.java b/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/ADLPostOpParam.java deleted file mode 100644 index 7f7e749..0000000 --- a/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/ADLPostOpParam.java +++ /dev/null @@ -1,97 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - */ - -package org.apache.hadoop.hdfs.web.resources; - -import java.net.HttpURLConnection; - -/** - * Extended Webhdfs PostOpParam to avoid redirect during append operation for - * azure data lake storage. - */ - -public class ADLPostOpParam extends HttpOpParam<ADLPostOpParam.Op> { - private static final Domain<Op> DOMAIN = new Domain<ADLPostOpParam.Op>(NAME, - Op.class); - - /** - * Constructor. - * - * @param str a string representation of the parameter value. - */ - public ADLPostOpParam(final String str) { - super(DOMAIN, DOMAIN.parse(str)); - } - - @Override - public final String getName() { - return NAME; - } - - /** - * Post operations. - */ - public static enum Op implements HttpOpParam.Op { - APPEND(true, false, HttpURLConnection.HTTP_OK); - - private final boolean redirect; - private final boolean doOutput; - private final int expectedHttpResponseCode; - - Op(final boolean doOut, final boolean doRedirect, - final int expectHttpResponseCode) { - this.doOutput = doOut; - this.redirect = doRedirect; - this.expectedHttpResponseCode = expectHttpResponseCode; - } - - @Override - public Type getType() { - return Type.POST; - } - - @Override - public boolean getRequireAuth() { - return false; - } - - @Override - public boolean getDoOutput() { - return doOutput; - } - - @Override - public boolean getRedirect() { - return redirect; - } - - @Override - public int getExpectedHttpResponseCode() { - return expectedHttpResponseCode; - } - - /** - * @return a URI query string. - */ - @Override - public String toQueryString() { - return NAME + "=" + this; - } - } -} http://git-wip-us.apache.org/repos/asf/hadoop/blob/19259422/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/ADLPutOpParam.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/ADLPutOpParam.java b/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/ADLPutOpParam.java deleted file mode 100644 index d300a1c..0000000 --- a/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/ADLPutOpParam.java +++ /dev/null @@ -1,94 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - */ - -package org.apache.hadoop.hdfs.web.resources; - -import java.net.HttpURLConnection; - -/** - * Extended Webhdfs PutOpParam to avoid redirect during Create operation for - * azure data lake storage. - */ -public class ADLPutOpParam extends HttpOpParam<ADLPutOpParam.Op> { - private static final Domain<Op> DOMAIN = new Domain<Op>(NAME, Op.class); - - /** - * Constructor. - * - * @param str a string representation of the parameter value. - */ - public ADLPutOpParam(final String str) { - super(DOMAIN, DOMAIN.parse(str)); - } - - @Override - public final String getName() { - return NAME; - } - - /** - * Put operations. - */ - public static enum Op implements HttpOpParam.Op { - CREATE(true, false, HttpURLConnection.HTTP_CREATED); - - private final boolean redirect; - private final boolean doOutput; - private final int expectedHttpResponseCode; - private final boolean requireAuth; - - Op(final boolean doOut, final boolean doRedirect, - final int expectHttpResponseCode) { - this.doOutput = doOut; - this.redirect = doRedirect; - this.expectedHttpResponseCode = expectHttpResponseCode; - this.requireAuth = false; - } - - @Override - public HttpOpParam.Type getType() { - return HttpOpParam.Type.PUT; - } - - @Override - public boolean getRequireAuth() { - return requireAuth; - } - - @Override - public boolean getDoOutput() { - return doOutput; - } - - @Override - public boolean getRedirect() { - return redirect; - } - - @Override - public int getExpectedHttpResponseCode() { - return expectedHttpResponseCode; - } - - @Override - public String toQueryString() { - return NAME + "=" + this; - } - } -} http://git-wip-us.apache.org/repos/asf/hadoop/blob/19259422/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/ADLVersionInfo.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/ADLVersionInfo.java b/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/ADLVersionInfo.java deleted file mode 100644 index 0bfe521..0000000 --- a/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/ADLVersionInfo.java +++ /dev/null @@ -1,51 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - */ - -package org.apache.hadoop.hdfs.web.resources; - -import org.apache.hadoop.hdfs.web.ADLConfKeys; - -import java.util.regex.Pattern; - -/** - * Capture ADL Jar version information. Require for debugging and analysis - * purpose in the backend. - */ -public class ADLVersionInfo extends StringParam { - /** - * Parameter name. - */ - public static final String NAME = ADLConfKeys.ADL_WEBSDK_VERSION_KEY; - - private static final StringParam.Domain DOMAIN = new StringParam.Domain(NAME, - Pattern.compile(".+")); - - /** - * Constructor. - * @param featureSetVersion Enabled featured information - */ - public ADLVersionInfo(String featureSetVersion) { - super(DOMAIN, featureSetVersion); - } - - @Override - public final String getName() { - return NAME; - } -} http://git-wip-us.apache.org/repos/asf/hadoop/blob/19259422/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/AppendADLNoRedirectParam.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/AppendADLNoRedirectParam.java b/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/AppendADLNoRedirectParam.java deleted file mode 100644 index b9ea79e..0000000 --- a/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/AppendADLNoRedirectParam.java +++ /dev/null @@ -1,45 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - */ -package org.apache.hadoop.hdfs.web.resources; - -/** - * Overwrite parameter. - */ -public class AppendADLNoRedirectParam extends BooleanParam { - /** - * Parameter name. - */ - public static final String NAME = "append"; - - private static final Domain DOMAIN = new Domain(NAME); - - /** - * Constructor. - * - * @param value the parameter value. - */ - public AppendADLNoRedirectParam(final Boolean value) { - super(DOMAIN, value); - } - - @Override - public final String getName() { - return NAME; - } -} http://git-wip-us.apache.org/repos/asf/hadoop/blob/19259422/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/CreateADLNoRedirectParam.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/CreateADLNoRedirectParam.java b/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/CreateADLNoRedirectParam.java deleted file mode 100644 index 83f3970..0000000 --- a/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/CreateADLNoRedirectParam.java +++ /dev/null @@ -1,44 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.web.resources; - -/** - * Overwrite parameter. - */ -public class CreateADLNoRedirectParam extends BooleanParam { - /** - * Parameter name. - */ - public static final String NAME = "write"; - - private static final Domain DOMAIN = new Domain(NAME); - - /** - * Constructor. - * - * @param value the parameter value. - */ - public CreateADLNoRedirectParam(final Boolean value) { - super(DOMAIN, value); - } - - @Override - public final String getName() { - return NAME; - } -} http://git-wip-us.apache.org/repos/asf/hadoop/blob/19259422/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/LeaseParam.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/LeaseParam.java b/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/LeaseParam.java deleted file mode 100644 index 6801235..0000000 --- a/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/LeaseParam.java +++ /dev/null @@ -1,53 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - */ - -package org.apache.hadoop.hdfs.web.resources; - -/** - * To support single writer semantics. Notify to ADL backend if the stream - * needs to locked in order to protect - * concurrent write operation on the same stream. - * - * Used in append operation. - */ -public class LeaseParam extends StringParam { - - public static final String NAME = "leaseId"; - /** - * Default parameter value. - */ - public static final String DEFAULT = NULL; - - private static final StringParam.Domain DOMAIN = new StringParam.Domain(NAME, - null); - - /** - * Constructor. - * - * @param str a string representation of the parameter value. - */ - public LeaseParam(final String str) { - super(DOMAIN, str == null || str.equals(DEFAULT) ? null : str); - } - - @Override - public final String getName() { - return NAME; - } -} http://git-wip-us.apache.org/repos/asf/hadoop/blob/19259422/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/ReadADLNoRedirectParam.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/ReadADLNoRedirectParam.java b/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/ReadADLNoRedirectParam.java deleted file mode 100644 index a600161..0000000 --- a/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/ReadADLNoRedirectParam.java +++ /dev/null @@ -1,44 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.web.resources; - -/** - * Overwrite parameter. - */ -public class ReadADLNoRedirectParam extends BooleanParam { - /** - * Parameter name. - */ - public static final String NAME = "read"; - - private static final Domain DOMAIN = new Domain(NAME); - - /** - * Constructor. - * - * @param value the parameter value. - */ - public ReadADLNoRedirectParam(final Boolean value) { - super(DOMAIN, value); - } - - @Override - public final String getName() { - return NAME; - } -} http://git-wip-us.apache.org/repos/asf/hadoop/blob/19259422/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/package-info.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/package-info.java b/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/package-info.java deleted file mode 100644 index 2231cc2..0000000 --- a/hadoop-tools/hadoop-azure-datalake/src/main/java/org/apache/hadoop/hdfs/web/resources/package-info.java +++ /dev/null @@ -1,27 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - */ - -/** - * A distributed implementation of {@link - * org.apache.hadoop.hdfs.web.resources} for reading or extending query - * parameter for webhdfs specification. ADL - * specific - * query parameter also goes in the same package. - */ -package org.apache.hadoop.hdfs.web.resources; http://git-wip-us.apache.org/repos/asf/hadoop/blob/19259422/hadoop-tools/hadoop-azure-datalake/src/site/markdown/index.md ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-azure-datalake/src/site/markdown/index.md b/hadoop-tools/hadoop-azure-datalake/src/site/markdown/index.md deleted file mode 100644 index 4158c88..0000000 --- a/hadoop-tools/hadoop-azure-datalake/src/site/markdown/index.md +++ /dev/null @@ -1,219 +0,0 @@ -<!--- - Licensed under the Apache License, Version 2.0 (the "License"); - you may not use this file except in compliance with the License. - You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. See accompanying LICENSE file. ---> - -# Hadoop Azure Data Lake Support - -* [Introduction](#Introduction) -* [Features](#Features) -* [Limitations](#Limitations) -* [Usage](#Usage) - * [Concepts](#Concepts) - * [Webhdfs Compliance](#Webhdfs_Specification_Compliance) - * [OAuth2 Support](#OAuth2_Support) - * [Read Ahead Buffer Management](Read_Ahead_Buffer_Management) - * [Configuring Credentials & FileSystem](#Configuring_Credentials) - * [Accessing adl URLs](#Accessing_adl_URLs) -* [Testing the hadoop-azure Module](#Testing_the_hadoop-azure_Module) - -## <a name="Introduction" />Introduction - -The hadoop-azure-datalake module provides support for integration with -[Azure Data Lake Store]( https://azure.microsoft.com/en-in/documentation/services/data-lake-store/). -The jar file is named azure-datalake-store.jar. - -## <a name="Features" />Features - -* Read and write data stored in an Azure Data Lake Storage account. -* Partial support for [Webhdfs Specification 2.7.0](https://hadoop.apache.org/docs/r2.7.0/hadoop-project-dist/hadoop-hdfs/WebHDFS.html) -* Reference file system paths using URLs using the `adl` scheme for Secure Webhdfs i.e. SSL - encrypted access. -* Can act as a source of data in a MapReduce job, or a sink. -* Tested on both Linux and Windows. -* Tested for scale. - -## <a name="Limitations" />Limitations -Partial or no support for the following operations in [Webhdfs Specification 2.7.0](https://hadoop.apache.org/docs/r2.7.0/hadoop-project-dist/hadoop-hdfs/WebHDFS.html): - -* Operation on Symbolic Link -* Proxy Users -* File Truncate -* File Checksum -* File replication factor -* Home Directory Partial supported based on OAuth2 token information and not the active user on Hadoop cluster. -* Extended Attributes(XAttrs) Operations -* Snapshot Operations -* Delegation Token Operations -* User and group information returned as ListStatus and GetFileStatus is in form of GUID associated in Azure Active Directory. - -## <a name="Usage" />Usage - -### <a name="Concepts" />Concepts -Azure Data Lake Storage access path syntax is - - adl://<Account Name>.azuredatalakestore.net/ - -Get started with azure data lake account with [https://azure.microsoft.com/en-in/documentation/articles/data-lake-store-get-started-portal/](https://azure.microsoft.com/en-in/documentation/articles/data-lake-store-get-started-portal/) - -#### <a name="Webhdfs_Specification_Compliance" />Webhdfs Compliance -Azure Data Lake Storage exposes a public REST endpoint as per [Webhdfs Specification 2.7.0](https://hadoop.apache.org/docs/r2.7.0/hadoop-project-dist/hadoop-hdfs/WebHDFS.html) to access storage file system. - -Syntax to access Azure data lake storage account over [Webhdfs Specification 2.7.0](https://hadoop.apache.org/docs/r2.7.0/hadoop-project-dist/hadoop-hdfs/WebHDFS.html) is - - https://<Account Name>.azuredatalakestore.net/webhdfs/v1/<File System Path>?<Query paramaters> - - -#### <a name="#OAuth2_Support" />OAuth2 Support -Usage of Azure Data Lake Storage requires OAuth2 bearer token to be present as part of the HTTPS header as per OAuth2 specification. Valid OAuth2 bearer token should be obtained from Azure Active Directory for valid users who have access to Azure Data Lake Storage Account. - -Azure Active Directory (Azure AD) is Microsoft�s multi-tenant cloud based directory and identity management service. See [https://azure.microsoft.com/en-in/documentation/articles/active-directory-whatis/](https://azure.microsoft.com/en-in/documentation/articles/active-directory-whatis/) - -Following sections describes on OAuth2 configuration in core-site.xml. - -#### <a name="#Read_Ahead_Buffer_Management" />Read Ahead Buffer Management -Azure Data Lake Storage offers high throughput. To maximize throughput, applications can use this feature to buffer data concurrently, in memory during read operation. This data is cached in memory per process per stream. - - -To Enable/Disable read ahead feature. - - <property> - <name>adl.feature.override.readahead</name> - <value>true</value> - <description> - Enables read aheads in the ADL client, the feature is used to improve read throughput. - This works in conjunction with the value set in adl.feature.override.readahead.max.buffersize. - When set to false the read ahead feature is turned off. - Default : True if not configured. - </description> - </property> - -To configure read ahead buffer size. - - <property> - <name>adl.feature.override.readahead.max.buffersize</name> - <value>8388608</value> - <description> - Define maximum buffer size to cache read ahead data, this is allocated per process to - cache read ahead data. Applicable only when adl.feature.override.readahead is set to true. - Default : 8388608 Byte i.e. 8MB if not configured. - </description> - </property> - -To configure number of concurrent connection to Azure Data Lake Storage Account. - - <property> - <name>adl.feature.override.readahead.max.concurrent.connection</name> - <value>2</value> - <description> - Define maximum concurrent connection can be established to - read ahead. If the data size is<4MB then only 1 read n/w connection - is set. If the data size is >4MB but<8MB then 2 read n/w - connection - is set. Data >8MB then value set under the property would - take - effect. Applicable only when adl.feature.override.readahead is set - to true and buffer size is >8MB. - It is recommended to reset this property if the adl.feature.override.readahead.max.buffersize - is < 8MB to gain performance. Application has to consider - throttling - limit for the account as well before configuring large buffer size. - </description> - </property> - -## <a name="Configuring_Credentials" />Configuring Credentials & FileSystem - -Update core-site.xml for OAuth2 configuration - - <property> - <name>dfs.webhdfs.oauth2.refresh.token.expires.ms.since.epoch</name> - <value>0</value> - </property> - - <property> - <name>dfs.webhdfs.oauth2.credential</name> - <value>bearer.and.refresh.token</value> - </property> - - <property> - <name>dfs.webhdfs.oauth2.access.token</name> - <value>NOT_SET</value> - </property> - - <property> - <name>dfs.webhdfs.oauth2.refresh.url</name> - <value>https://login.windows.net/common/oauth2/token/</value> - </property> - - <property> - <name>dfs.webhdfs.oauth2.access.token.provider</name> - <value>org.apache.hadoop.fs.adl.oauth2.CachedRefreshTokenBasedAccessTokenProvider</value> - </property> - -Application require to set Client id and OAuth2 refresh token from Azure Active Directory associated with client id. See [https://github.com/AzureAD/azure-activedirectory-library-for-java](https://github.com/AzureAD/azure-activedirectory-library-for-java). - -**Do not share client id and refresh token, it must be kept secret.** - - <property> - <name>dfs.webhdfs.oauth2.client.id</name> - <value></value> - </property> - - <property> - <name>dfs.webhdfs.oauth2.refresh.token</name> - <value></value> - </property> - -For ADL FileSystem to take effect. Update core-site.xml with - - <property> - <name>fs.adl.impl</name> - <value>org.apache.hadoop.fs.adl.AdlFileSystem</value> - </property> - - <property> - <name>fs.AbstractFileSystem.adl.impl</name> - <value>org.apache.hadoop.fs.adl.Adl</value> - </property> - - -### <a name="Accessing_adl_URLs" />Accessing adl URLs - -After credentials are configured in core-site.xml, any Hadoop component may -reference files in that Azure Data Lake Storage account by using URLs of the following -format: - - adl://<Account Name>.azuredatalakestore.net/<path> - -The schemes `adl` identify a URL on a file system backed by Azure -Data Lake Storage. `adl` utilizes encrypted HTTPS access for all interaction with -the Azure Data Lake Storage API. - -For example, the following -[FileSystem Shell](../hadoop-project-dist/hadoop-common/FileSystemShell.html) -commands demonstrate access to a storage account named `youraccount`. - - > hadoop fs -mkdir adl://yourcontainer.azuredatalakestore.net/testDir - - > hadoop fs -put testFile adl://yourcontainer.azuredatalakestore.net/testDir/testFile - - > hadoop fs -cat adl://yourcontainer.azuredatalakestore.net/testDir/testFile - test file content -## <a name="Testing_the_hadoop-azure_Module" />Testing the azure-datalake-store Module -The hadoop-azure module includes a full suite of unit tests. Most of the tests will run without additional configuration by running mvn test. This includes tests against mocked storage, which is an in-memory emulation of Azure Data Lake Storage. - -A selection of tests can run against the Azure Data Lake Storage. To run tests against Adl storage. Please configure contract-test-options.xml with Adl account information mentioned in the above sections. Also turn on contract test execution flag to trigger tests against Azure Data Lake Storage. - - <property> - <name>dfs.adl.test.contract.enable</name> - <value>true</value> - </property> http://git-wip-us.apache.org/repos/asf/hadoop/blob/19259422/hadoop-tools/hadoop-azure-datalake/src/test/java/org/apache/hadoop/fs/adl/oauth2/TestCachedRefreshTokenBasedAccessTokenProvider.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-azure-datalake/src/test/java/org/apache/hadoop/fs/adl/oauth2/TestCachedRefreshTokenBasedAccessTokenProvider.java b/hadoop-tools/hadoop-azure-datalake/src/test/java/org/apache/hadoop/fs/adl/oauth2/TestCachedRefreshTokenBasedAccessTokenProvider.java deleted file mode 100644 index e57d3a9..0000000 --- a/hadoop-tools/hadoop-azure-datalake/src/test/java/org/apache/hadoop/fs/adl/oauth2/TestCachedRefreshTokenBasedAccessTokenProvider.java +++ /dev/null @@ -1,147 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - */ -package org.apache.hadoop.fs.adl.oauth2; - -import org.apache.hadoop.conf.Configuration; -import org.apache.hadoop.hdfs.web.oauth2.AccessTokenProvider; - -import org.junit.Before; -import org.junit.Rule; -import org.junit.Test; -import org.junit.rules.TestName; -import static org.junit.Assert.*; -import static org.mockito.Mockito.*; - -import static org.apache.hadoop.hdfs.client.HdfsClientConfigKeys.OAUTH_CLIENT_ID_KEY; -import static org.apache.hadoop.hdfs.client.HdfsClientConfigKeys.OAUTH_REFRESH_URL_KEY; -import static org.apache.hadoop.hdfs.web.oauth2.ConfRefreshTokenBasedAccessTokenProvider.OAUTH_REFRESH_TOKEN_KEY; - -/** - * Verify cache behavior of ConfRefreshTokenBasedAccessTokenProvider instances. - */ -public class TestCachedRefreshTokenBasedAccessTokenProvider { - - private Configuration conf; - - @Rule public TestName name = new TestName(); - String clientId(int id) { - return name.getMethodName() + "_clientID" + id; - } - - @Before - public void initConfig() { - conf = new Configuration(false); - conf.set(OAUTH_CLIENT_ID_KEY, clientId(0)); - conf.set(OAUTH_REFRESH_TOKEN_KEY, "01234567890abcdef"); - conf.set(OAUTH_REFRESH_URL_KEY, "http://dingo.invalid:80";); - } - - @Test - public void testCacheInstance() throws Exception { - final AccessTokenProvider inst0 = mock(AccessTokenProvider.class); - when(inst0.getConf()).thenReturn(conf); - - // verify config - CachedRefreshTokenBasedAccessTokenProvider t1 = new MockProvider(inst0); - t1.setConf(conf); - verify(inst0).setConf(any(Configuration.class)); // cloned, not exact match - - // verify cache hit - CachedRefreshTokenBasedAccessTokenProvider t2 = - new CachedRefreshTokenBasedAccessTokenProvider() { - @Override - AccessTokenProvider newInstance() { - fail("Failed to return cached instance"); - return null; - } - }; - t2.setConf(conf); - - // verify force refresh - conf.setBoolean( - CachedRefreshTokenBasedAccessTokenProvider.FORCE_REFRESH, true); - final AccessTokenProvider inst1 = mock(AccessTokenProvider.class); - when(inst1.getConf()).thenReturn(conf); - CachedRefreshTokenBasedAccessTokenProvider t3 = new MockProvider(inst1); - t3.setConf(conf); - verify(inst1).setConf(any(Configuration.class)); - - // verify cache miss - conf.set(OAUTH_REFRESH_URL_KEY, "http://yak.invalid:80";); - final AccessTokenProvider inst2 = mock(AccessTokenProvider.class); - when(inst2.getConf()).thenReturn(conf); - CachedRefreshTokenBasedAccessTokenProvider t4 = new MockProvider(inst2); - t4.setConf(conf); - verify(inst2).setConf(any(Configuration.class)); - } - - @Test - public void testCacheLimit() throws Exception { - final int iter = CachedRefreshTokenBasedAccessTokenProvider.MAX_PROVIDERS; - for (int i = 0; i < iter; ++i) { - conf.set(OAUTH_CLIENT_ID_KEY, clientId(i)); - AccessTokenProvider inst = mock(AccessTokenProvider.class); - when(inst.getConf()).thenReturn(conf); - CachedRefreshTokenBasedAccessTokenProvider t = new MockProvider(inst); - t.setConf(conf); - verify(inst).setConf(any(Configuration.class)); - } - // verify cache hit - for (int i = 0; i < iter; ++i) { - conf.set(OAUTH_CLIENT_ID_KEY, clientId(i)); - CachedRefreshTokenBasedAccessTokenProvider t = - new CachedRefreshTokenBasedAccessTokenProvider() { - @Override - AccessTokenProvider newInstance() { - fail("Failed to return cached instance"); - return null; - } - }; - t.setConf(conf); - } - - // verify miss, evict 0 - conf.set(OAUTH_CLIENT_ID_KEY, clientId(iter)); - final AccessTokenProvider inst = mock(AccessTokenProvider.class); - when(inst.getConf()).thenReturn(conf); - CachedRefreshTokenBasedAccessTokenProvider t = new MockProvider(inst); - t.setConf(conf); - verify(inst).setConf(any(Configuration.class)); - - // verify miss - conf.set(OAUTH_CLIENT_ID_KEY, clientId(0)); - final AccessTokenProvider inst0 = mock(AccessTokenProvider.class); - when(inst0.getConf()).thenReturn(conf); - CachedRefreshTokenBasedAccessTokenProvider t0 = new MockProvider(inst0); - t0.setConf(conf); - verify(inst0).setConf(any(Configuration.class)); - } - - static class MockProvider extends CachedRefreshTokenBasedAccessTokenProvider { - private final AccessTokenProvider inst; - MockProvider(AccessTokenProvider inst) { - this.inst = inst; - } - @Override - AccessTokenProvider newInstance() { - return inst; - } - } - -} http://git-wip-us.apache.org/repos/asf/hadoop/blob/19259422/hadoop-tools/hadoop-tools-dist/pom.xml ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-tools-dist/pom.xml b/hadoop-tools/hadoop-tools-dist/pom.xml index 61fdddb..002d253 100644 --- a/hadoop-tools/hadoop-tools-dist/pom.xml +++ b/hadoop-tools/hadoop-tools-dist/pom.xml @@ -111,12 +111,6 @@ <version>${project.version}</version> <scope>compile</scope> </dependency> - <dependency> - <groupId>org.apache.hadoop</groupId> - <artifactId>hadoop-azure-datalake</artifactId> - <scope>compile</scope> - <version>${project.version}</version> - </dependency> </dependencies> <build> http://git-wip-us.apache.org/repos/asf/hadoop/blob/19259422/hadoop-tools/pom.xml ---------------------------------------------------------------------- diff --git a/hadoop-tools/pom.xml b/hadoop-tools/pom.xml index 86d573a..16bab03 100644 --- a/hadoop-tools/pom.xml +++ b/hadoop-tools/pom.xml @@ -46,7 +46,6 @@ <module>hadoop-sls</module> <module>hadoop-aws</module> <module>hadoop-azure</module> - <module>hadoop-azure-datalake</module> </modules> <build> --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
