Package org.apache.hadoop.hdfs.server.datanode

Class FinalizedProvidedReplica

java.lang.Object

org.apache.hadoop.hdfs.protocol.Block

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

org.apache.hadoop.hdfs.server.datanode.ProvidedReplica

org.apache.hadoop.hdfs.server.datanode.FinalizedProvidedReplica

All Implemented Interfaces:

Comparable<org.apache.hadoop.hdfs.protocol.Block>, Replica, org.apache.hadoop.io.Writable, org.apache.hadoop.util.LightWeightGSet.LinkedElement

@Private
@Unstable
public class FinalizedProvidedReplica
extends ProvidedReplica

This class is used for provided replicas that are finalized.

Field Summary

Fields inherited from class org.apache.hadoop.hdfs.server.datanode.ProvidedReplica

LOG

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

BLOCK_FILE_PREFIX, blockFilePattern, METADATA_EXTENSION, metaFilePattern, metaOrBlockFilePattern

Constructor Summary

Constructors

Constructor	Description
FinalizedProvidedReplica(long blockId, URI fileURI, long fileOffset, long blockLen, long genStamp, org.apache.hadoop.fs.PathHandle pathHandle, FsVolumeSpi volume, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem remoteFS)
FinalizedProvidedReplica(long blockId, org.apache.hadoop.fs.Path pathPrefix, String pathSuffix, long fileOffset, long blockLen, long genStamp, org.apache.hadoop.fs.PathHandle pathHandle, FsVolumeSpi volume, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem remoteFS)
FinalizedProvidedReplica(FileRegion fileRegion, FsVolumeSpi volume, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem remoteFS)

Method Summary

Modifier and Type	Method	Description
ReplicaRecoveryInfo	createInfo()
boolean	equals(Object o)
long	getBytesOnDisk()	Get the number of bytes that have written to disk
ReplicaInfo	getOriginalReplica()
long	getRecoveryID()	Get the recovery id.
HdfsServerConstants.ReplicaState	getState()	Get the replica state
long	getVisibleLength()	Get the number of bytes that are visible to readers
int	hashCode()
void	setRecoveryID(long recoveryId)	Set the recovery id.
String	toString()

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

blockDataExists, breakHardLinksIfNeeded, bumpReplicaGS, compareWith, copyBlockdata, copyMetadata, deleteBlockData, deleteMetadata, getBlockDataLength, getBlockURI, getDataInputStream, getDataOutputStream, getMetadataInputStream, getMetadataLength, getMetadataOutputStream, getMetadataURI, getPathPrefix, getPathSuffix, getPinning, metadataExists, renameData, renameMeta, setPathHandle, setPinning, truncateBlock, updateWithReplica

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

getBytesReserved, getFileIoProvider, getNext, getOriginalBytesReserved, getStorageUuid, getVolume, isOnTransientStorage, setNext

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

appendStringTo, compareTo, filename2id, getBlockId, getBlockId, getBlockName, getGenerationStamp, getGenerationStamp, getNumBytes, isBlockFilename, isMetaFilename, matchingIdAndGenStamp, metaToBlockFile, readFields, readId, set, setBlockId, setGenerationStamp, setNumBytes, toString, 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 Details

FinalizedProvidedReplica

public FinalizedProvidedReplica(long blockId,
 URI fileURI,
 long fileOffset,
 long blockLen,
 long genStamp,
 org.apache.hadoop.fs.PathHandle pathHandle,
 FsVolumeSpi volume,
 org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.fs.FileSystem remoteFS)

FinalizedProvidedReplica

public FinalizedProvidedReplica(FileRegion fileRegion,
 FsVolumeSpi volume,
 org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.fs.FileSystem remoteFS)

FinalizedProvidedReplica

public FinalizedProvidedReplica(long blockId,
 org.apache.hadoop.fs.Path pathPrefix,
 String pathSuffix,
 long fileOffset,
 long blockLen,
 long genStamp,
 org.apache.hadoop.fs.PathHandle pathHandle,
 FsVolumeSpi volume,
 org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.fs.FileSystem remoteFS)

Method Details

getState

public HdfsServerConstants.ReplicaState getState()

Description copied from interface: Replica

Get the replica state

Returns:

the replica state

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

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

equals

public boolean equals(Object o)

Overrides:

equals in class org.apache.hadoop.hdfs.protocol.Block

hashCode

public int hashCode()

Overrides:

hashCode in class org.apache.hadoop.hdfs.protocol.Block

toString

public String toString()

Overrides:

toString in class ReplicaInfo

getOriginalReplica

public ReplicaInfo getOriginalReplica()

Specified by:

getOriginalReplica in class ReplicaInfo

getRecoveryID

public long getRecoveryID()

Description copied from class: ReplicaInfo

Get the recovery id.

Specified by:

getRecoveryID in class ReplicaInfo

Returns:

the generation stamp that the replica will be bumped to

setRecoveryID

public void setRecoveryID(long recoveryId)

Description copied from class: ReplicaInfo

Set the recovery id.

Specified by:

setRecoveryID in class ReplicaInfo

Parameters:

recoveryId - the new recoveryId

createInfo

public ReplicaRecoveryInfo createInfo()

Overrides:

createInfo in class ProvidedReplica