@InterfaceAudience.Public @InterfaceStability.Evolving public class AzureBlobFileSystemStore extends Object implements Closeable
Constructor and Description |
---|
AzureBlobFileSystemStore(URI uri,
boolean isSecureScheme,
Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
void |
access(Path path,
FsAction mode) |
void |
close() |
void |
createDirectory(Path path,
FsPermission permission,
FsPermission umask) |
OutputStream |
createFile(Path path,
org.apache.hadoop.fs.FileSystem.Statistics statistics,
boolean overwrite,
FsPermission permission,
FsPermission umask) |
void |
createFilesystem() |
void |
delete(Path path,
boolean recursive) |
void |
deleteFilesystem() |
org.apache.hadoop.fs.azurebfs.AbfsConfiguration |
getAbfsConfiguration() |
AclStatus |
getAclStatus(Path path) |
FileStatus |
getFileStatus(Path path) |
Hashtable<String,String> |
getFilesystemProperties() |
boolean |
getIsNamespaceEnabled() |
Hashtable<String,String> |
getPathStatus(Path path) |
String |
getPrimaryGroup() |
String |
getUser() |
boolean |
isAtomicRenameKey(String key) |
FileStatus[] |
listStatus(Path path) |
FileStatus[] |
listStatus(Path path,
String startFrom) |
void |
modifyAclEntries(Path path,
List<AclEntry> aclSpec) |
org.apache.hadoop.fs.azurebfs.services.AbfsInputStream |
openFileForRead(Path path,
org.apache.hadoop.fs.FileSystem.Statistics statistics) |
OutputStream |
openFileForWrite(Path path,
org.apache.hadoop.fs.FileSystem.Statistics statistics,
boolean overwrite) |
void |
removeAcl(Path path) |
void |
removeAclEntries(Path path,
List<AclEntry> aclSpec) |
void |
removeDefaultAcl(Path path) |
void |
rename(Path source,
Path destination) |
void |
setAcl(Path path,
List<AclEntry> aclSpec) |
void |
setFilesystemProperties(Hashtable<String,String> properties) |
void |
setOwner(Path path,
String owner,
String group) |
void |
setPathProperties(Path path,
Hashtable<String,String> properties) |
void |
setPermission(Path path,
FsPermission permission) |
public AzureBlobFileSystemStore(URI uri, boolean isSecureScheme, Configuration configuration) throws IOException
IOException
public String getUser()
public String getPrimaryGroup()
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public boolean getIsNamespaceEnabled() throws AzureBlobFileSystemException
AzureBlobFileSystemException
public org.apache.hadoop.fs.azurebfs.AbfsConfiguration getAbfsConfiguration()
public Hashtable<String,String> getFilesystemProperties() throws AzureBlobFileSystemException
AzureBlobFileSystemException
public void setFilesystemProperties(Hashtable<String,String> properties) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public Hashtable<String,String> getPathStatus(Path path) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public void setPathProperties(Path path, Hashtable<String,String> properties) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public void createFilesystem() throws AzureBlobFileSystemException
AzureBlobFileSystemException
public void deleteFilesystem() throws AzureBlobFileSystemException
AzureBlobFileSystemException
public OutputStream createFile(Path path, org.apache.hadoop.fs.FileSystem.Statistics statistics, boolean overwrite, FsPermission permission, FsPermission umask) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public void createDirectory(Path path, FsPermission permission, FsPermission umask) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public org.apache.hadoop.fs.azurebfs.services.AbfsInputStream openFileForRead(Path path, org.apache.hadoop.fs.FileSystem.Statistics statistics) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public OutputStream openFileForWrite(Path path, org.apache.hadoop.fs.FileSystem.Statistics statistics, boolean overwrite) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public void rename(Path source, Path destination) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public void delete(Path path, boolean recursive) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public FileStatus getFileStatus(Path path) throws IOException
IOException
public FileStatus[] listStatus(Path path) throws IOException
path
- The list path.IOException
@InterfaceStability.Unstable public FileStatus[] listStatus(Path path, String startFrom) throws IOException
path
- Path the list path.startFrom
- the entry name that list results should start with.
For example, if folder "/folder" contains four files: "afile", "bfile", "hfile", "ifile".
Then listStatus(Path("/folder"), "hfile") will return "/folder/hfile" and "folder/ifile"
Notice that if startFrom is a non-existent entry name, then the list response contains
all entries after this non-existent entry in lexical order:
listStatus(Path("/folder"), "cfile") will return "/folder/hfile" and "/folder/ifile".IOException
public void setOwner(Path path, String owner, String group) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public void setPermission(Path path, FsPermission permission) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public void modifyAclEntries(Path path, List<AclEntry> aclSpec) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public void removeAclEntries(Path path, List<AclEntry> aclSpec) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public void removeDefaultAcl(Path path) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public void removeAcl(Path path) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public void setAcl(Path path, List<AclEntry> aclSpec) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public AclStatus getAclStatus(Path path) throws IOException
IOException
public void access(Path path, FsAction mode) throws AzureBlobFileSystemException
AzureBlobFileSystemException
public boolean isAtomicRenameKey(String key)
Copyright © 2020 Apache Software Foundation. All rights reserved.