NativeS3FileSystem and S3AFileSystem instead.@InterfaceAudience.Public @InterfaceStability.Stable @Deprecated public class S3FileSystem extends FileSystem
FileSystem backed by
Amazon S3.NativeS3FileSystemDEFAULT_FS, FS_DEFAULT_NAME_KEY, LOG, SHUTDOWN_HOOK_PRIORITY, statistics, TRASH_PREFIX| Constructor and Description |
|---|
S3FileSystem()
Deprecated.
|
S3FileSystem(org.apache.hadoop.fs.s3.FileSystemStore store)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
FSDataOutputStream |
append(Path f,
int bufferSize,
Progressable progress)
Deprecated.
This optional operation is not yet supported.
|
protected URI |
canonicalizeUri(URI rawUri)
Deprecated.
Canonicalize the given URI.
|
protected void |
checkPath(Path path)
Deprecated.
Check that a Path belongs to this FileSystem.
|
FSDataOutputStream |
create(Path file,
FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress)
Deprecated.
Create an FSDataOutputStream at the indicated Path with write-progress
reporting.
|
boolean |
delete(Path path,
boolean recursive)
Deprecated.
Delete a file.
|
String |
getCanonicalServiceName()
Deprecated.
Get a canonical service name for this file system.
|
long |
getDefaultBlockSize()
Deprecated.
Return the number of bytes that large input files should be optimally
be split into to minimize i/o time.
|
FileStatus |
getFileStatus(Path f)
Deprecated.
FileStatus for S3 file systems.
|
String |
getScheme()
Deprecated.
Return the protocol scheme for the FileSystem.
|
URI |
getUri()
Deprecated.
Returns a URI whose scheme and authority identify this FileSystem.
|
Path |
getWorkingDirectory()
Deprecated.
Get the current working directory for the given file system
|
void |
initialize(URI uri,
Configuration conf)
Deprecated.
Called after a new FileSystem instance is constructed.
|
boolean |
isFile(Path path)
Deprecated.
True iff the named path is a regular file.
|
FileStatus[] |
listStatus(Path f)
Deprecated.
List the statuses of the files/directories in the given path if the path is
a directory.
|
boolean |
mkdirs(Path path,
FsPermission permission)
Deprecated.
Make the given file and all non-existent parents into
directories.
|
FSDataInputStream |
open(Path path,
int bufferSize)
Deprecated.
Opens an FSDataInputStream at the indicated Path.
|
boolean |
rename(Path src,
Path dst)
Deprecated.
Renames Path src to Path dst.
|
void |
setWorkingDirectory(Path dir)
Deprecated.
Set the current working directory for the given file system.
|
addDelegationTokens, append, append, areSymlinksEnabled, cancelDeleteOnExit, clearStatistics, close, closeAll, closeAllForUGI, completeLocalOutput, concat, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyToLocalFile, copyToLocalFile, copyToLocalFile, create, create, create, create, create, create, create, create, create, create, create, create, createNewFile, createNonRecursive, createNonRecursive, createNonRecursive, createSnapshot, createSnapshot, createSymlink, delete, deleteOnExit, deleteSnapshot, enableSymlinks, exists, fixRelativePart, get, get, get, getAclStatus, getAllStatistics, getAllStoragePolicies, getBlockSize, getCanonicalUri, getContentSummary, getDefaultBlockSize, getDefaultPort, getDefaultReplication, getDefaultReplication, getDefaultUri, getFileBlockLocations, getFileBlockLocations, getFileChecksum, getFileChecksum, getFileLinkStatus, getFileSystemClass, getFSofPath, getGlobalStorageStatistics, getHomeDirectory, getInitialWorkingDirectory, getLength, getLinkTarget, getLocal, getName, getNamed, getQuotaUsage, getReplication, getServerDefaults, getServerDefaults, getStatistics, getStatistics, getStatus, getStatus, getStoragePolicy, getStorageStatistics, getTrashRoot, getTrashRoots, getUsed, getUsed, getXAttr, getXAttrs, getXAttrs, globStatus, globStatus, isDirectory, listCorruptFileBlocks, listFiles, listLocatedStatus, listLocatedStatus, listStatus, listStatus, listStatus, listStatusIterator, listXAttrs, makeQualified, mkdirs, mkdirs, modifyAclEntries, moveFromLocalFile, moveFromLocalFile, moveToLocalFile, newInstance, newInstance, newInstance, newInstanceLocal, open, primitiveCreate, primitiveMkdir, primitiveMkdir, printStatistics, processDeleteOnExit, removeAcl, removeAclEntries, removeDefaultAcl, removeXAttr, rename, renameSnapshot, resolveLink, resolvePath, setAcl, setDefaultUri, setDefaultUri, setOwner, setPermission, setReplication, setStoragePolicy, setTimes, setVerifyChecksum, setWriteChecksum, setXAttr, setXAttr, startLocalOutput, supportsSymlinks, truncate, unsetStoragePolicygetConf, setConfpublic S3FileSystem()
public S3FileSystem(org.apache.hadoop.fs.s3.FileSystemStore store)
public String getScheme()
getScheme in class FileSystems3public URI getUri()
FileSystemgetUri in class FileSystempublic void initialize(URI uri, Configuration conf) throws IOException
FileSysteminitialize in class FileSystemuri - a uri whose authority section names the host, port, etc.
for this FileSystemconf - the configurationIOExceptionpublic Path getWorkingDirectory()
FileSystemgetWorkingDirectory in class FileSystempublic void setWorkingDirectory(Path dir)
FileSystemsetWorkingDirectory in class FileSystemprotected void checkPath(Path path)
checkPath in class FileSystempath - to checkIllegalArgumentException - if there is an FS mismatchprotected URI canonicalizeUri(URI rawUri)
FileSystemcanonicalizeUri in class FileSystemNetUtils.getCanonicalUri(URI, int)public boolean mkdirs(Path path, FsPermission permission) throws IOException
FileSystemmkdirs in class FileSystempermission - Currently ignored.path - path to createIOExceptionpublic boolean isFile(Path path) throws IOException
FileSystemisFile in class FileSystempath - path to checkIOExceptionpublic FileStatus[] listStatus(Path f) throws IOException
FileSystemDoes not guarantee to return the List of files/directories status in a sorted order.
listStatus in class FileSystemf - given pathFileNotFoundException - when the path does not exist;
IOException see specific implementationIOExceptionpublic FSDataOutputStream append(Path f, int bufferSize, Progressable progress) throws IOException
append in class FileSystemf - the existing file to be appended.bufferSize - the size of the buffer to be used.progress - for reporting progress if it is not null.IOExceptionpublic FSDataOutputStream create(Path file, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) throws IOException
FileSystemcreate in class FileSystempermission - Currently ignored.file - the file name to openoverwrite - if a file with this name already exists, then if true,
the file will be overwritten, and if false an error will be thrown.bufferSize - the size of the buffer to be used.replication - required block replication for the file.IOExceptionFileSystem.setPermission(Path, FsPermission)public FSDataInputStream open(Path path, int bufferSize) throws IOException
FileSystemopen in class FileSystempath - the file name to openbufferSize - the size of the buffer to be used.IOExceptionpublic boolean rename(Path src, Path dst) throws IOException
FileSystemrename in class FileSystemsrc - path to be renameddst - new path after renameIOException - on failurepublic boolean delete(Path path, boolean recursive) throws IOException
FileSystemdelete in class FileSystempath - the path to delete.recursive - if path is a directory and set to
true, the directory is deleted else throws an exception. In
case of a file the recursive can be set to either true or false.IOExceptionpublic FileStatus getFileStatus(Path f) throws IOException
getFileStatus in class FileSystemf - The path we want information fromFileNotFoundException - when the path does not exist;
IOException see specific implementationIOExceptionpublic long getDefaultBlockSize()
FileSystemgetDefaultBlockSize in class FileSystempublic String getCanonicalServiceName()
FileSystemgetCanonicalServiceName in class FileSystemSecurityUtil.buildDTServiceName(URI, int)Copyright © 2017 Apache Software Foundation. All rights reserved.