类org.apache.hadoop.fs.adl.AdlFileSystem源码实例Demo

下面列出了怎么用org.apache.hadoop.fs.adl.AdlFileSystem的API类实例代码及写法,或者点击链接到github查看源代码。

@Override
public void initializeConfiguration(Configuration config)
{
    if (wasbAccessKey.isPresent() && wasbStorageAccount.isPresent()) {
        config.set(format("fs.azure.account.key.%s.blob.core.windows.net", wasbStorageAccount.get()), wasbAccessKey.get());
    }

    if (abfsAccessKey.isPresent() && abfsStorageAccount.isPresent()) {
        config.set(format("fs.azure.account.key.%s.dfs.core.windows.net", abfsStorageAccount.get()), abfsAccessKey.get());
        config.set("fs.abfs.impl", AzureBlobFileSystem.class.getName());
    }

    if (adlClientId.isPresent() && adlCredential.isPresent() && adlRefreshUrl.isPresent()) {
        config.set("fs.adl.oauth2.access.token.provider.type", "ClientCredential");
        config.set("fs.adl.oauth2.client.id", adlClientId.get());
        config.set("fs.adl.oauth2.credential", adlCredential.get());
        config.set("fs.adl.oauth2.refresh.url", adlRefreshUrl.get());
        config.set("fs.adl.impl", AdlFileSystem.class.getName());
    }
    // do not rely on information returned from local system about users and groups
    config.set("fs.azure.skipUserGroupMetadataDuringInitialization", "true");
}
 
 类所在包
 同包方法