org.apache.hadoop.hdfs.server.datanode

Class DataStorage

java.lang.Object

org.apache.hadoop.hdfs.server.common.StorageInfo

org.apache.hadoop.hdfs.server.common.Storage

org.apache.hadoop.hdfs.server.datanode.DataStorage

@InterfaceAudience.Private
public class DataStorage
extends Storage

Data storage information file.

See Also:

Storage

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hdfs.server.common.Storage

Storage.FormatConfirmable, Storage.StorageDirectory, Storage.StorageDirType, Storage.StorageState

Field Summary

Fields

Modifier and Type	Field and Description
static String	BLOCK_SUBDIR_PREFIX
static String	STORAGE_DIR_FINALIZED
static String	STORAGE_DIR_RBW
static String	STORAGE_DIR_TMP

Fields inherited from class org.apache.hadoop.hdfs.server.common.Storage

LAST_PRE_UPGRADE_LAYOUT_VERSION, LAST_UPGRADABLE_HADOOP_VERSION, LAST_UPGRADABLE_LAYOUT_VERSION, LAYOUT_VERSIONS_203, LOG, STORAGE_1_BBW, STORAGE_DIR_CURRENT, STORAGE_DIR_PREVIOUS, STORAGE_FILE_LOCK, STORAGE_FILE_VERSION, STORAGE_PREVIOUS_CKPT, STORAGE_TMP_FINALIZED, STORAGE_TMP_LAST_CKPT, STORAGE_TMP_PREVIOUS, STORAGE_TMP_REMOVED, storageDirs, storageType

Fields inherited from class org.apache.hadoop.hdfs.server.common.StorageInfo

clusterID, cTime, layoutVersion, namespaceID

Constructor Summary

Constructors

Constructor and Description
DataStorage(StorageInfo storageInfo, String strgID)

Method Summary

Methods

Modifier and Type	Method and Description
void	createStorageID(int datanodePort) Create an ID for this storage.
StorageInfo	getBPStorage(String bpid)
String	getStorageID()
boolean	isPreUpgradableLayout(Storage.StorageDirectory sd) Return true if the layout of the given storage directory is from a version of Hadoop prior to the introduction of the "current" and "previous" directories which allow upgrade and rollback.
protected void	setFieldsFromProperties(Properties props, Storage.StorageDirectory sd) Get common storage fields.
protected void	setPropertiesFromFields(Properties props, Storage.StorageDirectory sd) Set common storage fields into the given properties object.

Methods inherited from class org.apache.hadoop.hdfs.server.common.Storage

addStorageDir, checkVersionUpgradable, confirmFormat, deleteDir, dirIterable, dirIterator, dirIterator, getBuildVersion, getFiles, getNumStorageDirs, getRegistrationID, getSingularStorageDir, getStorageDir, is203LayoutVersion, listStorageDirectories, readPreviousVersionProperties, readProperties, readPropertiesFile, rename, setClusterId, setcTime, setLayoutVersion, setNamespaceID, setStorageType, unlockAll, writeAll, writeProperties, writeProperties

Methods inherited from class org.apache.hadoop.hdfs.server.common.StorageInfo

getClusterID, getCTime, getLayoutVersion, getNamespaceID, setStorageInfo, toColonSeparatedString, toString, versionSupportsFederation

Methods inherited from class java.lang.Object

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

Field Detail

BLOCK_SUBDIR_PREFIX

public static final String BLOCK_SUBDIR_PREFIX

See Also:

Constant Field Values

STORAGE_DIR_RBW

public static final String STORAGE_DIR_RBW

See Also:

Constant Field Values

STORAGE_DIR_FINALIZED

public static final String STORAGE_DIR_FINALIZED

See Also:

Constant Field Values

STORAGE_DIR_TMP

public static final String STORAGE_DIR_TMP

See Also:

Constant Field Values

Constructor Detail

DataStorage

public DataStorage(StorageInfo storageInfo,
           String strgID)

Method Detail

getBPStorage

public StorageInfo getBPStorage(String bpid)

getStorageID

public String getStorageID()

Returns:

storage ID.

createStorageID

public void createStorageID(int datanodePort)

Create an ID for this storage.

setPropertiesFromFields

protected void setPropertiesFromFields(Properties props,
                           Storage.StorageDirectory sd)
                                throws IOException

Description copied from class: Storage

Set common storage fields into the given properties object. Should be overloaded if additional fields need to be set.

Overrides:

setPropertiesFromFields in class Storage

Parameters:

props - the Properties object to write into

Throws:

IOException

setFieldsFromProperties

protected void setFieldsFromProperties(Properties props,
                           Storage.StorageDirectory sd)
                                throws IOException

Description copied from class: Storage

Get common storage fields. Should be overloaded if additional fields need to be get.

Overrides:

setFieldsFromProperties in class Storage

Throws:

IOException

isPreUpgradableLayout

public boolean isPreUpgradableLayout(Storage.StorageDirectory sd)
                              throws IOException

Description copied from class: Storage

Return true if the layout of the given storage directory is from a version of Hadoop prior to the introduction of the "current" and "previous" directories which allow upgrade and rollback.

Specified by:

isPreUpgradableLayout in class Storage

Throws:

IOException