org.apache.hadoop.hdfs

类 DFSUtil

java.lang.Object

org.apache.hadoop.hdfs.DFSUtil

public class DFSUtil
extends Object

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	DFSUtil.StaleComparator Comparator for sorting DataNodeInfo[] based on stale states.

构造器概要

构造器

构造器和说明
DFSUtil()

方法概要

方法

限定符和类型	方法和说明
static String	bytes2String(byte[] bytes) Converts a byte array to a string using UTF8 encoding.
static URI	createUri(String scheme, InetSocketAddress address) Create a URI from the scheme and address
static float	getInvalidateWorkPctPerIteration(Configuration conf) Get DFS_NAMENODE_INVALIDATE_WORK_PCT_PER_ITERATION from configuration.
static int	getReplWorkMultiplier(Configuration conf) Get DFS_NAMENODE_REPLICATION_WORK_MULTIPLIER_PER_ITERATION from configuration.
static boolean	isValidName(String src) Whether the pathname is valid.
static BlockLocation[]	locatedBlocks2Locations(LocatedBlocks blocks) Convert a LocatedBlocks to BlockLocations[]
static byte[]	string2Bytes(String str) Converts a string to a byte array using UTF8 encoding.

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

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

构造器详细资料

DFSUtil

public DFSUtil()

方法详细资料

isValidName

public static boolean isValidName(String src)

Whether the pathname is valid. Currently prohibits relative paths, and names which contain a ":" or "/"

bytes2String

public static String bytes2String(byte[] bytes)

Converts a byte array to a string using UTF8 encoding.

string2Bytes

public static byte[] string2Bytes(String str)

Converts a string to a byte array using UTF8 encoding.

locatedBlocks2Locations

public static BlockLocation[] locatedBlocks2Locations(LocatedBlocks blocks)

Convert a LocatedBlocks to BlockLocations[]

参数:

blocks - a LocatedBlocks

返回:

an array of BlockLocations

createUri

public static URI createUri(String scheme,
            InetSocketAddress address)

Create a URI from the scheme and address

getInvalidateWorkPctPerIteration

public static float getInvalidateWorkPctPerIteration(Configuration conf)

Get DFS_NAMENODE_INVALIDATE_WORK_PCT_PER_ITERATION from configuration.

参数:

conf - Configuration

返回:

Value of DFS_NAMENODE_INVALIDATE_WORK_PCT_PER_ITERATION

抛出:

IllegalArgumentException - If the value is not positive

getReplWorkMultiplier

public static int getReplWorkMultiplier(Configuration conf)

Get DFS_NAMENODE_REPLICATION_WORK_MULTIPLIER_PER_ITERATION from configuration.

参数:

conf - Configuration

返回:

Value of DFS_NAMENODE_REPLICATION_WORK_MULTIPLIER_PER_ITERATION

抛出:

IllegalArgumentException - If the value is not positive