Package org.apache.flink.fs.azurefs

Class EnvironmentVariableKeyProvider

java.lang.Object

org.apache.flink.fs.azurefs.EnvironmentVariableKeyProvider

All Implemented Interfaces:

org.apache.hadoop.fs.azure.KeyProvider

public class EnvironmentVariableKeyProvider
extends Object
implements org.apache.hadoop.fs.azure.KeyProvider

An implementation of KeyProvider, which reads the Azure storage key from an environment variable named "AZURE_STORAGE_KEY".

Field Summary

Fields

Modifier and Type	Field	Description
static String	AZURE_STORAGE_KEY_ENV_VARIABLE

Constructor Summary

Constructors

Constructor	Description
EnvironmentVariableKeyProvider()

Method Summary

Modifier and Type	Method	Description
String	getStorageAccountKey(String s, org.apache.hadoop.conf.Configuration configuration)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

AZURE_STORAGE_KEY_ENV_VARIABLE

public static final String AZURE_STORAGE_KEY_ENV_VARIABLE

See Also:

Constant Field Values

Constructor Detail

EnvironmentVariableKeyProvider

public EnvironmentVariableKeyProvider()

Method Detail

getStorageAccountKey

public String getStorageAccountKey(String s,
                                   org.apache.hadoop.conf.Configuration configuration)
                            throws org.apache.hadoop.fs.azure.KeyProviderException

Specified by:

getStorageAccountKey in interface org.apache.hadoop.fs.azure.KeyProvider

Throws:

org.apache.hadoop.fs.azure.KeyProviderException