public class BmcFilesystem extends FileSystem
FileSystem
that is backed by the BMC Object Store.
Filesystems using this store take the URI form: oci://bucket@namespace. The bucket must be pre-created.
Unless otherwise noted, APIs try to follow the specification as defined by:
http://hadoop.apache.org/docs/current/hadoop-project-dist/hadoop-common/filesystem/filesystem.html
This is the proxy for the actual implementation, BmcFilesystemImpl
, which may be cached.
FileSystem.DirectoryEntries, FileSystem.DirListingIterator<T extends FileStatus>, FileSystem.Statistics
DEFAULT_FS, FS_DEFAULT_NAME_KEY, SHUTDOWN_HOOK_PRIORITY, statistics, TRASH_PREFIX, USER_HOME_PREFIX
Constructor and Description |
---|
BmcFilesystem() |
access, append, append, appendFile, areSymlinksEnabled, cancelDeleteOnExit, canonicalizeUri, checkPath, clearStatistics, closeAll, closeAllForUGI, completeLocalOutput, concat, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyToLocalFile, copyToLocalFile, copyToLocalFile, create, create, create, create, create, create, create, create, create, create, create, create, createDataInputStreamBuilder, createDataInputStreamBuilder, createDataOutputStreamBuilder, createFile, createMultipartUploader, createNewFile, createNonRecursive, createNonRecursive, createPathHandle, createSnapshot, createSnapshot, createSymlink, delete, deleteOnExit, deleteSnapshot, enableSymlinks, exists, fixRelativePart, get, get, get, getAclStatus, getAdditionalTokenIssuers, getAllStatistics, getAllStoragePolicies, getBlockSize, getCanonicalUri, getChildFileSystems, getDefaultBlockSize, getDefaultReplication, getDefaultReplication, getDefaultUri, getDelegationToken, getFileBlockLocations, getFileBlockLocations, getFileChecksum, getFileChecksum, getFileLinkStatus, getFileSystemClass, getFSofPath, getGlobalStorageStatistics, getHomeDirectory, getInitialWorkingDirectory, getLength, getLinkTarget, getLocal, getName, getNamed, getPathHandle, getQuotaUsage, getReplication, getServerDefaults, getServerDefaults, getStatistics, getStatistics, getStatus, getStatus, getStoragePolicy, getStorageStatistics, getTrashRoot, getTrashRoots, getUsed, getUsed, getXAttr, getXAttrs, getXAttrs, globStatus, globStatus, hasPathCapability, isDirectory, isFile, listCorruptFileBlocks, listLocatedStatus, listLocatedStatus, listStatus, listStatus, listStatus, listStatusBatch, listStatusIterator, listXAttrs, makeQualified, mkdirs, mkdirs, modifyAclEntries, moveFromLocalFile, moveFromLocalFile, moveToLocalFile, msync, newInstance, newInstance, newInstance, newInstanceLocal, open, open, open, openFile, openFile, openFileWithOptions, openFileWithOptions, primitiveCreate, primitiveMkdir, primitiveMkdir, printStatistics, processDeleteOnExit, removeAcl, removeAclEntries, removeDefaultAcl, removeXAttr, rename, renameSnapshot, resolveLink, resolvePath, satisfyStoragePolicy, setAcl, setDefaultUri, setDefaultUri, setOwner, setPermission, setQuota, setQuotaByStorageType, setReplication, setStoragePolicy, setTimes, setVerifyChecksum, setWriteChecksum, setXAttr, setXAttr, startLocalOutput, supportsSymlinks, truncate, unsetStoragePolicy
setConf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addDelegationTokens, collectDelegationTokens
protected com.oracle.bmc.hdfs.BmcFilesystemImpl getDelegate()
public void initialize(URI uri, Configuration configuration) throws IOException
initialize
in class FileSystem
IOException
public String getScheme()
getScheme
in class FileSystem
public FSDataOutputStream append(Path path, int bufferSize, Progressable progress) throws IOException
append
in class FileSystem
IOException
public FSDataOutputStream create(Path path, org.apache.hadoop.fs.permission.FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) throws IOException
create
in class FileSystem
IOException
public FSDataOutputStream createNonRecursive(Path f, org.apache.hadoop.fs.permission.FsPermission permission, EnumSet<CreateFlag> flags, int bufferSize, short replication, long blockSize, Progressable progress) throws IOException
createNonRecursive
in class FileSystem
IOException
public boolean delete(Path path, boolean recursive) throws IOException
delete
in class FileSystem
IOException
public ContentSummary getContentSummary(Path path) throws IOException
getContentSummary
in class FileSystem
IOException
public FileStatus getFileStatus(Path path) throws IOException
getFileStatus
in class FileSystem
IOException
public FileStatus[] listStatus(Path path) throws IOException
listStatus
in class FileSystem
IOException
public boolean mkdirs(Path path, org.apache.hadoop.fs.permission.FsPermission permission) throws IOException
mkdirs
in class FileSystem
IOException
public FSDataInputStream open(Path path, int bufferSize) throws IOException
open
in class FileSystem
IOException
public boolean rename(Path source, Path destination) throws IOException
rename
in class FileSystem
IOException
public long getDefaultBlockSize()
getDefaultBlockSize
in class FileSystem
public int getDefaultPort()
getDefaultPort
in class FileSystem
public String getCanonicalServiceName()
getCanonicalServiceName
in interface DelegationTokenIssuer
getCanonicalServiceName
in class FileSystem
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class FileSystem
IOException
public Path getWorkingDirectory()
getWorkingDirectory
in class FileSystem
public void setWorkingDirectory(Path workingDirectory)
setWorkingDirectory
in class FileSystem
public URI getUri()
getUri
in class FileSystem
public BmcDataStore getDataStore()
public Configuration getConf()
getConf
in interface Configurable
getConf
in class Configured
public RemoteIterator<LocatedFileStatus> listFiles(Path f, boolean recursive) throws FileNotFoundException, IOException
listFiles
in class FileSystem
FileNotFoundException
IOException
Copyright © 2016–2023. All rights reserved.