A B C D E F G H I K L M N O P R S T U W 

A

acquireLease(String) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
Get a lease on the blob identified by key.
acquireLease(Path) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
Get a self-renewing lease on the specified file.
append(Path, int, Progressable) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
This optional operation is not yet supported.
AzureException - Exception in org.apache.hadoop.fs.azure
Thrown if there is a problem communicating with Azure Storage service.
AzureException(String) - Constructor for exception org.apache.hadoop.fs.azure.AzureException
 
AzureException(String, Throwable) - Constructor for exception org.apache.hadoop.fs.azure.AzureException
 
AzureException(Throwable) - Constructor for exception org.apache.hadoop.fs.azure.AzureException
 
AzureFileSystemInstrumentation - Class in org.apache.hadoop.fs.azure.metrics
A metrics source for the WASB file system to track all the metrics we care about for getting a clear picture of the performance/reliability/interaction of the Hadoop cluster with Azure Storage.
AzureFileSystemInstrumentation(Configuration) - Constructor for class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
AzureFileSystemMetricsSystem - Class in org.apache.hadoop.fs.azure.metrics
AzureFileSystemMetricsSystem
AzureLinkedStack<E> - Class in org.apache.hadoop.fs.azure
A simple generic stack implementation using linked lists.
AzureLinkedStack() - Constructor for class org.apache.hadoop.fs.azure.AzureLinkedStack
 
AzureNativeFileSystemStore - Class in org.apache.hadoop.fs.azure
Core implementation of Windows Azure Filesystem for Hadoop.
AzureNativeFileSystemStore() - Constructor for class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 

B

BandwidthGaugeUpdater - Class in org.apache.hadoop.fs.azure.metrics
Internal implementation class to help calculate the current bytes uploaded/downloaded and the maximum bandwidth gauges.
BandwidthGaugeUpdater(AzureFileSystemInstrumentation) - Constructor for class org.apache.hadoop.fs.azure.metrics.BandwidthGaugeUpdater
Create a new updater object with default values.
BandwidthGaugeUpdater(AzureFileSystemInstrumentation, int, boolean) - Constructor for class org.apache.hadoop.fs.azure.metrics.BandwidthGaugeUpdater
Create a new updater object with some overrides (used in unit tests).
bind(StorageCredentials, OperationContext, boolean) - Static method in class org.apache.hadoop.fs.azure.SendRequestIntercept
Binds a new lister to the operation context so the WASB file system can appropriately intercept sends.
blockDownloaded(long) - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Indicate that we just downloaded a block and record its latency.
blockDownloaded(Date, Date, long) - Method in class org.apache.hadoop.fs.azure.metrics.BandwidthGaugeUpdater
Indicate that a block has been downloaded.
blockUploaded(long) - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Indicate that we just uploaded a block and record its latency.
blockUploaded(Date, Date, long) - Method in class org.apache.hadoop.fs.azure.metrics.BandwidthGaugeUpdater
Indicate that a block has been uploaded.

C

changePermissionStatus(String, PermissionStatus) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
Changes the permission status on the given key.
checkPath(Path) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
cleanup() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem.FolderRenamePending
Clean up after execution of rename.
clientErrorEncountered() - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Indicate that we just encountered a client-side error.
close() - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
close() - Method in class org.apache.hadoop.fs.azure.metrics.BandwidthGaugeUpdater
 
close() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
createNonRecursive(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
createNonRecursive(Path, FsPermission, EnumSet<CreateFlag>, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
createNonRecursive(Path, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
currentDownloadBytesPerSecond(long) - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Record the current bytes-per-second download rate seen.
currentUploadBytesPerSecond(long) - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Record the current bytes-per-second upload rate seen.

D

DEFAULT_DOWNLOAD_BLOCK_SIZE - Static variable in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
DEFAULT_UPLOAD_BLOCK_SIZE - Static variable in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
delete(String, SelfRenewingLease) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
delete(String) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
delete(Path) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
Deprecated.
delete(Path, boolean) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
delete(Path, boolean, boolean) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
Delete the specified file or folder.
deleteFilesWithDanglingTempData(Path) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
Looks under the given root path for any blob that are left "dangling", meaning that they are place-holder blobs that we created while we upload the data to a temporary blob, but for some reason we crashed in the middle of the upload and left them there.
directoryCreated() - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Indicate that we just created a directory through WASB.
directoryDeleted() - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Indicate that we just deleted a directory through WASB.
dump() - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 

E

ErrorMetricUpdater - Class in org.apache.hadoop.fs.azure.metrics
An event listener to the ResponseReceived event from Azure Storage that will update error metrics appropriately when it gets that event.
eventOccurred(ResponseReceivedEvent) - Method in class org.apache.hadoop.fs.azure.metrics.ErrorMetricUpdater
 
eventOccurred(ResponseReceivedEvent) - Method in class org.apache.hadoop.fs.azure.metrics.ResponseReceivedMetricUpdater
Handle the response-received event from Azure SDK.
eventOccurred(SendingRequestEvent) - Method in class org.apache.hadoop.fs.azure.SendRequestIntercept
Handler which processes the sending request event from Azure SDK.
execute() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem.FolderRenamePending
Execute a folder rename.

F

fileCreated() - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Indicate that we just created a file through WASB.
fileDeleted() - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Indicate that we just deleted a file through WASB.
fileSystemClosed() - Static method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemMetricsSystem
 
fileSystemStarted() - Static method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemMetricsSystem
 
finalize() - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
finalize() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
free() - Method in class org.apache.hadoop.fs.azure.SelfRenewingLease
Free the lease and stop the keep-alive thread.

G

getAccountKeyFromConfiguration(String, Configuration) - Static method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
getBandwidthGaugeUpdater() - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
getBlockDownloadLatency() - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Get the current rolling average of the download latency.
getBlockUploadLatency() - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Get the current rolling average of the upload latency.
getCloudBlob() - Method in class org.apache.hadoop.fs.azure.SelfRenewingLease
 
getCurrentMaximumDownloadBandwidth() - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Get the current maximum download bandwidth.
getCurrentMaximumUploadBandwidth() - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Get the current maximum upload bandwidth.
getCurrentWebResponses() - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Gets the current number of web responses obtained from Azure Storage.
getDstKey() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem.FolderRenamePending
 
getFileBlockLocations(FileStatus, long, long) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
Return an array containing hostnames, offset and size of portions of the given file.
getFiles() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem.FolderRenamePending
 
getFileStatus(Path) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
getFileSystemInstanceId() - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
The unique identifier for this file system in the metrics.
getFolderLease() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem.FolderRenamePending
 
getInstrumentation() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
Gets the metrics source for this file system.
getLeaseID() - Method in class org.apache.hadoop.fs.azure.SelfRenewingLease
 
getLinkInFileMetadata(String) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
If the blob with the given key exists and has a link in its metadata to a temporary file (see storeEmptyLinkFile), this method returns the key to that temporary file.
getMetrics(MetricsCollector, boolean) - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
getMetricsRegistryInfo() - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Get the metrics registry information.
getPathNameWarning() - Method in class org.apache.hadoop.fs.azure.WasbFsck
 
getScheme() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
getScheme() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem.Secure
 
getSourceMetadata() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem.FolderRenamePending
 
getSrcKey() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem.FolderRenamePending
 
getStorageAccountKey(String, Configuration) - Method in interface org.apache.hadoop.fs.azure.KeyProvider
Key providers must implement this method.
getStorageAccountKey(String, Configuration) - Method in class org.apache.hadoop.fs.azure.ShellDecryptionKeyProvider
 
getStorageAccountKey(String, Configuration) - Method in class org.apache.hadoop.fs.azure.SimpleKeyProvider
 
getStorageAccountKeyName(String) - Method in class org.apache.hadoop.fs.azure.SimpleKeyProvider
 
getStore() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
For unit test purposes, retrieves the AzureNativeFileSystemStore store backing this file system.
getUri() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
getUriDefaultPort() - Method in class org.apache.hadoop.fs.azure.Wasb
 
getWorkingDirectory() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 

H

hflush() - Method in class org.apache.hadoop.fs.azure.SyncableDataOutputStream
 
hook(OperationContext, AzureFileSystemInstrumentation) - Static method in class org.apache.hadoop.fs.azure.metrics.ErrorMetricUpdater
Hooks a new listener to the given operationContext that will update the error metrics for the WASB file system appropriately in response to ResponseReceived events.
hook(OperationContext, AzureFileSystemInstrumentation, BandwidthGaugeUpdater) - Static method in class org.apache.hadoop.fs.azure.metrics.ResponseReceivedMetricUpdater
Hooks a new listener to the given operationContext that will update the metrics for the WASB file system appropriately in response to ResponseReceived events.
hook(OperationContext, float, float) - Static method in class org.apache.hadoop.fs.azure.SelfThrottlingIntercept
 
hsync() - Method in class org.apache.hadoop.fs.azure.SyncableDataOutputStream
 

I

initialize(URI, Configuration, AzureFileSystemInstrumentation) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
Method for the URI and configuration object necessary to create a storage session with an Azure session.
initialize(URI, Configuration) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
isAtomicRenameKey(String) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
Checks if the given key in Azure storage should have synchronized atomic folder rename createNonRecursive implemented.
isEmpty() - Method in class org.apache.hadoop.fs.azure.AzureLinkedStack
 
isFreed() - Method in class org.apache.hadoop.fs.azure.SelfRenewingLease
 
isKeyForDirectorySet(String, Set<String>) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
isPageBlobKey(String) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
Checks if the given key in Azure Storage should be stored as a page blob instead of block blob.

K

KEY_ACCOUNT_KEY_PREFIX - Static variable in class org.apache.hadoop.fs.azure.SimpleKeyProvider
 
KEY_ATOMIC_RENAME_DIRECTORIES - Static variable in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
Configuration key to indicate the set of directories in WASB where we should do atomic folder rename synchronized with createNonRecursive.
KEY_PAGE_BLOB_DIRECTORIES - Static variable in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
Configuration key to indicate the set of directories in WASB where we should store files as page blobs instead of block blobs.
KeyProvider - Interface in org.apache.hadoop.fs.azure
The interface that every Azure file system key provider must implement.
KeyProviderException - Exception in org.apache.hadoop.fs.azure
Thrown if there is a problem instantiating a KeyProvider or retrieving a key using a KeyProvider object.
KeyProviderException(String) - Constructor for exception org.apache.hadoop.fs.azure.KeyProviderException
 
KeyProviderException(String, Throwable) - Constructor for exception org.apache.hadoop.fs.azure.KeyProviderException
 
KeyProviderException(Throwable) - Constructor for exception org.apache.hadoop.fs.azure.KeyProviderException
 

L

LEASE_RENEWAL_PERIOD - Static variable in class org.apache.hadoop.fs.azure.SelfRenewingLease
 
list(String, int, int) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
list(String, int, int, String) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
listAll(String, int, int, String) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
listStatus(Path) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
Retrieve the status of a given path if it is a file, or of all the contained files if it is a directory.
LOG - Static variable in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
LOG - Static variable in class org.apache.hadoop.fs.azure.metrics.BandwidthGaugeUpdater
 
LOG - Static variable in class org.apache.hadoop.fs.azure.metrics.ResponseReceivedMetricUpdater
 
LOG - Static variable in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
LOG - Static variable in class org.apache.hadoop.fs.azure.SelfThrottlingIntercept
 
LOG - Static variable in class org.apache.hadoop.fs.azure.SendRequestIntercept
 

M

main(String[]) - Static method in class org.apache.hadoop.fs.azure.WasbFsck
 
makeAbsolute(Path) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
Get the absolute version of the path (fully qualified).
makeRenamePendingFileContents() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem.FolderRenamePending
Return the contents of the JSON file to represent the operations to be performed for a folder rename.
METRIC_TAG_ACCOUNT_NAME - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
METRIC_TAG_CONTAINTER_NAME - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
METRIC_TAG_FILESYSTEM_ID - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
mkdirs(Path, FsPermission) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
mkdirs(Path, FsPermission, boolean) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 

N

NativeAzureFileSystem - Class in org.apache.hadoop.fs.azure
A FileSystem for reading and writing files stored on Windows Azure.
NativeAzureFileSystem() - Constructor for class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
NativeAzureFileSystem(NativeFileSystemStore) - Constructor for class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
NativeAzureFileSystem.FolderRenamePending - Class in org.apache.hadoop.fs.azure
A description of a folder rename operation, including the source and destination keys, and descriptions of the files in the source folder.
NativeAzureFileSystem.FolderRenamePending(String, String, SelfRenewingLease, NativeAzureFileSystem) - Constructor for class org.apache.hadoop.fs.azure.NativeAzureFileSystem.FolderRenamePending
 
NativeAzureFileSystem.FolderRenamePending(Path, NativeAzureFileSystem) - Constructor for class org.apache.hadoop.fs.azure.NativeAzureFileSystem.FolderRenamePending
 
NativeAzureFileSystem.Secure - Class in org.apache.hadoop.fs.azure
A FileSystem for reading and writing files stored on Windows Azure.
NativeAzureFileSystem.Secure() - Constructor for class org.apache.hadoop.fs.azure.NativeAzureFileSystem.Secure
 
newMetricsSourceName() - Static method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
Creates a new metrics source name that's unique within this process.

O

open(Path, int) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
org.apache.hadoop.fs.azure - package org.apache.hadoop.fs.azure
A distributed implementation of FileSystem for reading and writing files on Azure Block Storage.
org.apache.hadoop.fs.azure.metrics - package org.apache.hadoop.fs.azure.metrics
Infrastructure for a Metrics2 source that provides information on Windows Azure Filesystem for Hadoop instances.

P

pathToKey(Path) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
Convert the path to a key.
peek() - Method in class org.apache.hadoop.fs.azure.AzureLinkedStack
 
pop() - Method in class org.apache.hadoop.fs.azure.AzureLinkedStack
 
purge(String) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
push(E) - Method in class org.apache.hadoop.fs.azure.AzureLinkedStack
 

R

rawBytesDownloaded(long) - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Indicate that we just downloaded some data to Azure storage.
rawBytesUploaded(long) - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Indicate that we just uploaded some data to Azure storage.
recoverFilesWithDanglingTempData(Path, Path) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
Looks under the given root path for any blob that are left "dangling", meaning that they are place-holder blobs that we created while we upload the data to a temporary blob, but for some reason we crashed in the middle of the upload and left them there.
redo() - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem.FolderRenamePending
Recover from a folder rename failure by redoing the intended work, as recorded in the -RenamePending.json file.
registerSource(String, String, MetricsSource) - Static method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemMetricsSystem
 
rename(String, String) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
rename(String, String, boolean, SelfRenewingLease) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
rename(Path, Path) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
responseReceived(ResponseReceivedEvent) - Method in class org.apache.hadoop.fs.azure.SelfThrottlingIntercept
 
ResponseReceivedMetricUpdater - Class in org.apache.hadoop.fs.azure.metrics
An event listener to the ResponseReceived event from Azure Storage that will update metrics appropriately when it gets that event.
resumeAutoUpdate() - Method in class org.apache.hadoop.fs.azure.metrics.BandwidthGaugeUpdater
Resumes auto-update (undo suppressAutoUpdate).
retrieve(String) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
retrieve(String, long) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
retrieveMetadata(String) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
run(String[]) - Method in class org.apache.hadoop.fs.azure.WasbFsck
 

S

SelfRenewingLease - Class in org.apache.hadoop.fs.azure
An Azure blob lease that automatically renews itself indefinitely using a background thread.
SelfRenewingLease(StorageInterface.CloudBlobWrapper) - Constructor for class org.apache.hadoop.fs.azure.SelfRenewingLease
 
SelfThrottlingIntercept - Class in org.apache.hadoop.fs.azure
Introduces delays in our Azure traffic to prevent overrunning the server-side throttling limits.
SelfThrottlingIntercept(OperationContext, float, float) - Constructor for class org.apache.hadoop.fs.azure.SelfThrottlingIntercept
 
sendingRequest(SendingRequestEvent) - Method in class org.apache.hadoop.fs.azure.SelfThrottlingIntercept
 
SendRequestIntercept - Class in org.apache.hadoop.fs.azure
Manages the lifetime of binding on the operation contexts to intercept send request events to Azure storage.
serverErrorEncountered() - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Indicate that we just encountered a server-caused error.
setAccountName(String) - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Sets the account name to tag all the metrics with.
setContainerName(String) - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Sets the container name to tag all the metrics with.
setMockFileSystemForTesting(FileSystem) - Method in class org.apache.hadoop.fs.azure.WasbFsck
For testing purposes, set the file system to use here instead of relying on getting it from the FileSystem class based on the URI.
setOwner(Path, String, String) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
setPermission(Path, FsPermission) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
setWorkingDirectory(Path) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
Set the working directory to the given directory.
ShellDecryptionKeyProvider - Class in org.apache.hadoop.fs.azure
Shell decryption key provider which invokes an external script that will perform the key decryption.
ShellDecryptionKeyProvider() - Constructor for class org.apache.hadoop.fs.azure.ShellDecryptionKeyProvider
 
SimpleKeyProvider - Class in org.apache.hadoop.fs.azure
Key provider that simply returns the storage account key from the configuration as plaintext.
SimpleKeyProvider() - Constructor for class org.apache.hadoop.fs.azure.SimpleKeyProvider
 
size() - Method in class org.apache.hadoop.fs.azure.AzureLinkedStack
 
SKIP_AZURE_METRICS_PROPERTY_NAME - Static variable in class org.apache.hadoop.fs.azure.NativeAzureFileSystem
 
storeEmptyFolder(String, PermissionStatus) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
storeEmptyLinkFile(String, String, PermissionStatus) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
Stores an empty blob that's linking to the temporary file where're we're uploading the initial data.
storefile(String, PermissionStatus) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
SUFFIX - Static variable in class org.apache.hadoop.fs.azure.NativeAzureFileSystem.FolderRenamePending
 
suppressAutoUpdate() - Method in class org.apache.hadoop.fs.azure.metrics.BandwidthGaugeUpdater
For unit test purposes, suppresses auto-update of the metrics from the dedicated thread.
sync() - Method in class org.apache.hadoop.fs.azure.SyncableDataOutputStream
Deprecated.
SyncableDataOutputStream - Class in org.apache.hadoop.fs.azure
Support the Syncable interface on top of a DataOutputStream.
SyncableDataOutputStream(OutputStream) - Constructor for class org.apache.hadoop.fs.azure.SyncableDataOutputStream
 

T

THREAD_NAME - Static variable in class org.apache.hadoop.fs.azure.metrics.BandwidthGaugeUpdater
 
toString() - Method in class org.apache.hadoop.fs.azure.AzureLinkedStack
 
triggerUpdate(boolean) - Method in class org.apache.hadoop.fs.azure.metrics.BandwidthGaugeUpdater
Triggers the update of the metrics gauge based on all the blocks uploaded/downloaded so far.

U

unregisterSource(String) - Static method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemMetricsSystem
 
updateBytesReadInLastSecond(long) - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Sets the current gauge value for how many bytes were read in the last second.
updateBytesWrittenInLastSecond(long) - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Sets the current gauge value for how many bytes were written in the last second.
updateFolderLastModifiedTime(String, Date, SelfRenewingLease) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 
updateFolderLastModifiedTime(String, SelfRenewingLease) - Method in class org.apache.hadoop.fs.azure.AzureNativeFileSystemStore
 

W

Wasb - Class in org.apache.hadoop.fs.azure
WASB implementation of AbstractFileSystem.
WASB_BYTES_READ - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
WASB_BYTES_WRITTEN - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
WASB_CLIENT_ERRORS - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
WASB_DIRECTORIES_CREATED - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
WASB_DIRECTORIES_DELETED - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
WASB_DOWNLOAD_LATENCY - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
WASB_DOWNLOAD_RATE - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
WASB_FILES_CREATED - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
WASB_FILES_DELETED - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
WASB_RAW_BYTES_DOWNLOADED - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
WASB_RAW_BYTES_UPLOADED - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
WASB_SERVER_ERRORS - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
WASB_UPLOAD_LATENCY - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
WASB_UPLOAD_RATE - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
WASB_WEB_RESPONSES - Static variable in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
 
WasbFsck - Class in org.apache.hadoop.fs.azure
An fsck tool implementation for WASB that does various admin/cleanup/recovery tasks on the WASB file system.
WasbFsck(Configuration) - Constructor for class org.apache.hadoop.fs.azure.WasbFsck
 
webResponse() - Method in class org.apache.hadoop.fs.azure.metrics.AzureFileSystemInstrumentation
Indicate that we just got a web response from Azure Storage.
writeFile(FileSystem) - Method in class org.apache.hadoop.fs.azure.NativeAzureFileSystem.FolderRenamePending
Write to disk the information needed to redo folder rename, in JSON format.
A B C D E F G H I K L M N O P R S T U W 

Copyright © 2019 Apache Software Foundation. All Rights Reserved.