org.apache.hadoop.fs.aliyun.oss

类 AliyunOSSUtils

java.lang.Object

org.apache.hadoop.fs.aliyun.oss.AliyunOSSUtils

public final class AliyunOSSUtils
extends Object

Utility methods for Aliyun OSS code.

方法概要

限定符和类型	方法和说明
static long	calculatePartSize(long contentLength, long minPartSize) Calculate a proper size of multipart piece.
static com.aliyun.oss.common.auth.CredentialsProvider	getCredentialsProvider(org.apache.hadoop.conf.Configuration conf) Create credential provider specified by configuration, or create default credential provider if not specified.
static String	getValueWithKey(org.apache.hadoop.conf.Configuration conf, String key) Used to get password from configuration.
static String	maybeAddTrailingSlash(String key) Turns a path (relative or otherwise) into an OSS key, adding a trailing "/" if the path is not the root and does not already have a "/" at the end.
static void	skipFully(InputStream is, long n) Skip the requested number of bytes or fail if there are no enough bytes left.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

方法详细资料

getValueWithKey

public static String getValueWithKey(org.apache.hadoop.conf.Configuration conf,
                                     String key)
                              throws IOException

Used to get password from configuration.

参数:

conf - configuration that contains password information

key - the key of the password

返回:

the value for the key

抛出:

IOException - if failed to get password from configuration

skipFully

public static void skipFully(InputStream is,
                             long n)
                      throws IOException

Skip the requested number of bytes or fail if there are no enough bytes left. This allows for the possibility that InputStream.skip(long) may not skip as many bytes as requested (most likely because of reaching EOF).

参数:

is - the input stream to skip.

n - the number of bytes to skip.

抛出:

IOException - thrown when skipped less number of bytes.

calculatePartSize

public static long calculatePartSize(long contentLength,
                                     long minPartSize)

Calculate a proper size of multipart piece. If minPartSize is too small, the number of multipart pieces may exceed the limit of Constants.MULTIPART_UPLOAD_PART_NUM_LIMIT.

参数:

contentLength - the size of file.

minPartSize - the minimum size of multipart piece.

返回:

a revisional size of multipart piece.

getCredentialsProvider

public static com.aliyun.oss.common.auth.CredentialsProvider getCredentialsProvider(org.apache.hadoop.conf.Configuration conf)
                                                                             throws IOException

Create credential provider specified by configuration, or create default credential provider if not specified.

参数:

conf - configuration

返回:

a credential provider

抛出:

IOException - on any problem. Class construction issues may be nested inside the IOE.

maybeAddTrailingSlash

public static String maybeAddTrailingSlash(String key)

Turns a path (relative or otherwise) into an OSS key, adding a trailing "/" if the path is not the root and does not already have a "/" at the end.

参数:

key - OSS key or ""

返回:

the with a trailing "/", or, if it is the root key, "".