public class NativeOssFileSystem
extends org.apache.hadoop.fs.FileSystem
限定符和类型 | 类和说明 |
---|---|
class |
NativeOssFileSystem.NativeOssFsInputStream |
限定符和类型 | 字段和说明 |
---|---|
static String |
FOLDER_SUFFIX |
static org.apache.commons.logging.Log |
LOG |
static long |
MAX_OSS_FILE_SIZE |
static int |
OSS_MAX_LISTING_LENGTH |
static String |
OSSREADER_ALGORITHM_VERSION |
static int |
OSSREADER_ALGORITHM_VERSION_DEFAULT |
static String |
PATH_DELIMITER |
构造器和说明 |
---|
NativeOssFileSystem() |
NativeOssFileSystem(NativeFileSystemStore store) |
限定符和类型 | 方法和说明 |
---|---|
org.apache.hadoop.fs.FSDataOutputStream |
append(org.apache.hadoop.fs.Path f,
int bufferSize,
org.apache.hadoop.util.Progressable progress) |
org.apache.hadoop.fs.FSDataOutputStream |
create(org.apache.hadoop.fs.Path f,
org.apache.hadoop.fs.permission.FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
org.apache.hadoop.util.Progressable progress) |
boolean |
delete(org.apache.hadoop.fs.Path path)
已过时。
|
boolean |
delete(org.apache.hadoop.fs.Path f,
boolean recurse) |
org.apache.hadoop.fs.FileStatus |
getFileStatus(org.apache.hadoop.fs.Path f) |
String |
getScheme() |
URI |
getUri() |
org.apache.hadoop.fs.Path |
getWorkingDirectory() |
void |
initialize(URI uri,
org.apache.hadoop.conf.Configuration conf) |
org.apache.hadoop.fs.FileStatus[] |
listStatus(org.apache.hadoop.fs.Path f)
If
f is a file, this method will make a single call to Oss. |
boolean |
mkdir(org.apache.hadoop.fs.Path f) |
boolean |
mkdirs(org.apache.hadoop.fs.Path f,
org.apache.hadoop.fs.permission.FsPermission permission) |
org.apache.hadoop.fs.FSDataInputStream |
open(org.apache.hadoop.fs.Path f,
int bufferSize) |
boolean |
rename(org.apache.hadoop.fs.Path src,
org.apache.hadoop.fs.Path dst) |
void |
setWorkingDirectory(org.apache.hadoop.fs.Path newDir)
Set the working directory to the given directory.
|
addDelegationTokens, append, append, cancelDeleteOnExit, canonicalizeUri, checkPath, 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, deleteOnExit, deleteSnapshot, enableSymlinks, exists, fixRelativePart, get, get, get, getAllStatistics, getBlockSize, getCanonicalServiceName, getCanonicalUri, getChildFileSystems, getContentSummary, getDefaultBlockSize, getDefaultBlockSize, getDefaultPort, getDefaultReplication, getDefaultReplication, getDefaultUri, getDelegationToken, getFileBlockLocations, getFileBlockLocations, getFileChecksum, getFileLinkStatus, getFileSystemClass, getFSofPath, getHomeDirectory, getInitialWorkingDirectory, getLength, getLinkTarget, getLocal, getName, getNamed, getReplication, getServerDefaults, getServerDefaults, getStatistics, getStatistics, getStatus, getStatus, getUsed, globStatus, globStatus, isDirectory, isFile, isSymlinksEnabled, listCorruptFileBlocks, listFiles, listLocatedStatus, listLocatedStatus, listStatus, listStatus, listStatus, makeQualified, mkdirs, mkdirs, moveFromLocalFile, moveFromLocalFile, moveToLocalFile, newInstance, newInstance, newInstance, newInstanceLocal, open, primitiveCreate, primitiveMkdir, primitiveMkdir, printStatistics, processDeleteOnExit, rename, renameSnapshot, resolveLink, resolvePath, setDefaultUri, setDefaultUri, setOwner, setPermission, setReplication, setTimes, setVerifyChecksum, setWriteChecksum, startLocalOutput, supportsSymlinks
public static final org.apache.commons.logging.Log LOG
public static final long MAX_OSS_FILE_SIZE
public static final int OSS_MAX_LISTING_LENGTH
public static final int OSSREADER_ALGORITHM_VERSION_DEFAULT
public NativeOssFileSystem()
public NativeOssFileSystem(NativeFileSystemStore store)
public void initialize(URI uri, org.apache.hadoop.conf.Configuration conf) throws IOException
initialize
在类中 org.apache.hadoop.fs.FileSystem
IOException
public org.apache.hadoop.fs.FSDataOutputStream append(org.apache.hadoop.fs.Path f, int bufferSize, org.apache.hadoop.util.Progressable progress) throws IOException
append
在类中 org.apache.hadoop.fs.FileSystem
IOException
public org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path f, org.apache.hadoop.fs.permission.FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, org.apache.hadoop.util.Progressable progress) throws IOException
create
在类中 org.apache.hadoop.fs.FileSystem
IOException
@Deprecated public boolean delete(org.apache.hadoop.fs.Path path) throws IOException
delete
在类中 org.apache.hadoop.fs.FileSystem
IOException
public boolean delete(org.apache.hadoop.fs.Path f, boolean recurse) throws IOException
delete
在类中 org.apache.hadoop.fs.FileSystem
IOException
public org.apache.hadoop.fs.FileStatus getFileStatus(org.apache.hadoop.fs.Path f) throws IOException
getFileStatus
在类中 org.apache.hadoop.fs.FileSystem
IOException
public String getScheme()
getScheme
在类中 org.apache.hadoop.fs.FileSystem
public URI getUri()
getUri
在类中 org.apache.hadoop.fs.FileSystem
public org.apache.hadoop.fs.FileStatus[] listStatus(org.apache.hadoop.fs.Path f) throws IOException
If f
is a file, this method will make a single call to Oss.
If f
is a directory, this method will make a maximum of
(n / 1000) + 2 calls to Oss, where n is the total number of
files and directories contained directly in f
.
listStatus
在类中 org.apache.hadoop.fs.FileSystem
IOException
public boolean mkdirs(org.apache.hadoop.fs.Path f, org.apache.hadoop.fs.permission.FsPermission permission) throws IOException
mkdirs
在类中 org.apache.hadoop.fs.FileSystem
IOException
public boolean mkdir(org.apache.hadoop.fs.Path f) throws IOException
IOException
public org.apache.hadoop.fs.FSDataInputStream open(org.apache.hadoop.fs.Path f, int bufferSize) throws IOException
open
在类中 org.apache.hadoop.fs.FileSystem
IOException
public boolean rename(org.apache.hadoop.fs.Path src, org.apache.hadoop.fs.Path dst) throws IOException
rename
在类中 org.apache.hadoop.fs.FileSystem
IOException
public void setWorkingDirectory(org.apache.hadoop.fs.Path newDir)
setWorkingDirectory
在类中 org.apache.hadoop.fs.FileSystem
public org.apache.hadoop.fs.Path getWorkingDirectory()
getWorkingDirectory
在类中 org.apache.hadoop.fs.FileSystem
Copyright © 2016. All Rights Reserved.