org.apache.hadoop.hdfs.server.namenode

Class INodeFileUnderConstruction

java.lang.Object

org.apache.hadoop.hdfs.server.namenode.INode

org.apache.hadoop.hdfs.server.namenode.INodeWithAdditionalFields

org.apache.hadoop.hdfs.server.namenode.INodeFile

org.apache.hadoop.hdfs.server.namenode.INodeFileUnderConstruction

All Implemented Interfaces:

Comparable<byte[]>, BlockCollection, MutableBlockCollection, INodeAttributes, INodeFileAttributes, Diff.Element<byte[]>, LightWeightGSet.LinkedElement

Direct Known Subclasses:

INodeFileUnderConstructionWithSnapshot

@InterfaceAudience.Private
public class INodeFileUnderConstruction
extends INodeFile
implements MutableBlockCollection

I-node for file being written.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hdfs.server.namenode.INode

INode.BlocksMapUpdateInfo

Nested classes/interfaces inherited from interface org.apache.hadoop.hdfs.server.namenode.INodeFileAttributes

INodeFileAttributes.SnapshotCopy

Field Summary

Fields inherited from class org.apache.hadoop.hdfs.server.namenode.INode

LOG

Constructor Summary

Constructors

Constructor and Description
INodeFileUnderConstruction(INodeFile that, String clientName, String clientMachine, DatanodeDescriptor clientNode)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	assertAllBlocksComplete() Assert all blocks are complete.
String	getClientMachine()
String	getClientName()
DatanodeDescriptor	getClientNode()
boolean	isUnderConstruction() Is this file under construction?
INodeFileUnderConstruction	recordModification(Snapshot latest, INodeMap inodeMap) This inode is being modified.
BlockInfoUnderConstruction	setLastBlock(BlockInfo lastBlock, DatanodeDescriptor[] targets) Convert the last block of the file to an under-construction block.
protected INodeFile	toINodeFile(long mtime) Converts an INodeFileUnderConstruction to an INodeFile.
static INodeFileUnderConstruction	valueOf(INode inode, String path) Cast INode to INodeFileUnderConstruction.

Methods inherited from class org.apache.hadoop.hdfs.server.namenode.INodeFile

asFile, cleanSubtree, computeContentSummary, computeFileSize, computeFileSize, computeFileSize, computeFileSizeNotIncludingLastUcBlock, computeQuotaUsage, destroyAndCollectBlocks, diskspaceConsumed, diskspaceConsumed, dumpTreeRecursively, getBlockReplication, getBlocks, getFileReplication, getFileReplication, getHeaderLong, getLastBlock, getName, getPreferredBlockSize, getSnapshotINode, isFile, numBlocks, setBlock, setBlocks, setFileReplication, setFileReplication, toUnderConstruction, valueOf

Methods inherited from class org.apache.hadoop.hdfs.server.namenode.INodeWithAdditionalFields

getFsPermissionShort, getId, getLocalNameBytes, getNext, getPermissionLong, setAccessTime, setLocalName, setModificationTime, setNext, updateModificationTime

Methods inherited from class org.apache.hadoop.hdfs.server.namenode.INode

addSpaceConsumed, asDirectory, asReference, asSymlink, clear, compareTo, computeContentSummary, computeQuotaUsage, computeQuotaUsage, dumpTreeRecursively, dumpTreeRecursively, equals, getAccessTime, getDsQuota, getFsPermission, getFullPathName, getGroupName, getKey, getLocalName, getModificationTime, getNsQuota, getObjectString, getParent, getParentReference, getParentString, getUserName, hashCode, isAncestorDirectory, isDirectory, isInLatestSnapshot, isQuotaSet, isReference, isSymlink, setAccessTime, setModificationTime, setParent, setParentReference, shouldRecordInSrcSnapshot, toDetailString, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hdfs.server.blockmanagement.MutableBlockCollection

setBlock

Methods inherited from interface org.apache.hadoop.hdfs.server.blockmanagement.BlockCollection

computeContentSummary, getBlockReplication, getBlocks, getLastBlock, getName, getPreferredBlockSize, numBlocks

Methods inherited from interface org.apache.hadoop.hdfs.server.namenode.INodeAttributes

getAccessTime, getFsPermission, getFsPermissionShort, getGroupName, getLocalNameBytes, getModificationTime, getPermissionLong, getUserName

Constructor Detail

INodeFileUnderConstruction

public INodeFileUnderConstruction(INodeFile that,
                          String clientName,
                          String clientMachine,
                          DatanodeDescriptor clientNode)

Method Detail

valueOf

public static INodeFileUnderConstruction valueOf(INode inode,
                                 String path)
                                          throws FileNotFoundException

Cast INode to INodeFileUnderConstruction.

Throws:

FileNotFoundException

getClientName

public String getClientName()

getClientMachine

public String getClientMachine()

getClientNode

public DatanodeDescriptor getClientNode()

isUnderConstruction

public final boolean isUnderConstruction()

Description copied from class: INodeFile

Is this file under construction?

Overrides:

isUnderConstruction in class INodeFile

Returns:

true unconditionally.

toINodeFile

protected INodeFile toINodeFile(long mtime)

Converts an INodeFileUnderConstruction to an INodeFile. The original modification time is used as the access time. The new modification is the specified mtime.

recordModification

public INodeFileUnderConstruction recordModification(Snapshot latest,
                                            INodeMap inodeMap)
                                              throws QuotaExceededException

Description copied from class: INode

This inode is being modified. The previous version of the inode needs to be recorded in the latest snapshot.

Overrides:

recordModification in class INodeFile

Parameters:

latest - the latest snapshot that has been taken. Note that it is null if no snapshots have been taken.

inodeMap - while recording modification, the inode or its parent may get replaced, and the inodeMap needs to be updated.

Returns:

The current inode, which usually is the same object of this inode. However, in some cases, this inode may be replaced with a new inode for maintaining snapshots. The current inode is then the new inode.

Throws:

QuotaExceededException

assertAllBlocksComplete

protected void assertAllBlocksComplete()

Assert all blocks are complete.

setLastBlock

public BlockInfoUnderConstruction setLastBlock(BlockInfo lastBlock,
                                      DatanodeDescriptor[] targets)
                                        throws IOException

Convert the last block of the file to an under-construction block. Set its locations.

Specified by:

setLastBlock in interface MutableBlockCollection

Throws:

IOException