org.apache.hadoop.hdfs.server.datanode

Class ReplicaWaitingToBeRecovered

java.lang.Object

org.apache.hadoop.hdfs.protocol.Block

org.apache.hadoop.hdfs.server.datanode.ReplicaInfo

org.apache.hadoop.hdfs.server.datanode.ReplicaWaitingToBeRecovered

All Implemented Interfaces:

Comparable<Block>, Replica, Writable

public class ReplicaWaitingToBeRecovered
extends ReplicaInfo

This class represents a replica that is waiting to be recovered. After a datanode restart, any replica in "rbw" directory is loaded as a replica waiting to be recovered. A replica waiting to be recovered does not provision read nor participates in any pipeline recovery. It will become outdated if its client continues to write or be recovered as a result of lease recovery.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hdfs.server.datanode.ReplicaInfo

ReplicaInfo.ReplicaDirInfo

Field Summary

Fields inherited from class org.apache.hadoop.hdfs.protocol.Block

BLOCK_FILE_PREFIX, blockFilePattern, METADATA_EXTENSION, metaFilePattern

Constructor Summary

Constructors

Constructor and Description
ReplicaWaitingToBeRecovered(Block block, FsVolumeSpi vol, File dir) Constructor
ReplicaWaitingToBeRecovered(long blockId, long len, long genStamp, FsVolumeSpi vol, File dir) Constructor
ReplicaWaitingToBeRecovered(ReplicaWaitingToBeRecovered from) Copy constructor.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object o)
long	getBytesOnDisk() Get the number of bytes that have written to disk
HdfsServerConstants.ReplicaState	getState() Get the replica state
long	getVisibleLength() Get the number of bytes that are visible to readers
int	hashCode()
boolean	isUnlinked() check if this replica has already been unlinked.
void	setUnlinked() set that this replica is unlinked
String	toString()

Methods inherited from class org.apache.hadoop.hdfs.server.datanode.ReplicaInfo

getBlockFile, getMetaFile, getVolume, parseSubDirs, setDir, unlinkBlock

Methods inherited from class org.apache.hadoop.hdfs.protocol.Block

appendStringTo, compareTo, filename2id, getBlockId, getBlockId, getBlockName, getGenerationStamp, getGenerationStamp, getNumBytes, isBlockFilename, isMetaFilename, matchingIdAndGenStamp, readFields, readId, set, setBlockId, setGenerationStamp, setNumBytes, write, writeId

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hdfs.server.datanode.Replica

getBlockId, getGenerationStamp, getNumBytes

Constructor Detail

ReplicaWaitingToBeRecovered

public ReplicaWaitingToBeRecovered(long blockId,
                           long len,
                           long genStamp,
                           FsVolumeSpi vol,
                           File dir)

Constructor

Parameters:

blockId - block id

len - replica length

genStamp - replica generation stamp

vol - volume where replica is located

dir - directory path where block and meta files are located

ReplicaWaitingToBeRecovered

public ReplicaWaitingToBeRecovered(Block block,
                           FsVolumeSpi vol,
                           File dir)

Constructor

Parameters:

block - a block

vol - volume where replica is located

dir - directory path where block and meta files are located

ReplicaWaitingToBeRecovered

public ReplicaWaitingToBeRecovered(ReplicaWaitingToBeRecovered from)

Copy constructor.

Parameters:

from -

Method Detail

getState

public HdfsServerConstants.ReplicaState getState()

Description copied from interface: Replica

Get the replica state

Returns:

the replica state

isUnlinked

public boolean isUnlinked()

Description copied from class: ReplicaInfo

check if this replica has already been unlinked.

Overrides:

isUnlinked in class ReplicaInfo

Returns:

true if the replica has already been unlinked or no need to be detached; false otherwise

setUnlinked

public void setUnlinked()

Description copied from class: ReplicaInfo

set that this replica is unlinked

Overrides:

setUnlinked in class ReplicaInfo

getVisibleLength

public long getVisibleLength()

Description copied from interface: Replica

Get the number of bytes that are visible to readers

Returns:

the number of bytes that are visible to readers

getBytesOnDisk

public long getBytesOnDisk()

Description copied from interface: Replica

Get the number of bytes that have written to disk

Returns:

the number of bytes that have written to disk

equals

public boolean equals(Object o)

Overrides:

equals in class Block

hashCode

public int hashCode()

Overrides:

hashCode in class Block

toString

public String toString()

Overrides:

toString in class ReplicaInfo