tachyon.master

Class InodeFile

java.lang.Object

tachyon.master.ImageWriter

tachyon.master.Inode

tachyon.master.InodeFile

All Implemented Interfaces:

Comparable<Inode>

public class InodeFile
extends Inode

Tachyon file system's file representation in master.

Field Summary

Fields inherited from class tachyon.master.Inode

IS_FOLDER

Constructor Summary

Constructors

Constructor and Description
InodeFile(String name, int id, int parentId, long blockSizeByte, long creationTimeMs)

Method Summary

Modifier and Type	Method and Description
void	addBlock(BlockInfo blockInfo)
void	addLocation(int blockIndex, long workerId, NetAddress workerAddress)
ClientFileInfo	generateClientFileInfo(String path)
long	getBlockIdBasedOnOffset(long offset)
List<Long>	getBlockIds()
List<Pair<Long,Long>>	getBlockIdWorkerIdPairs()
List<BlockInfo>	getBlockList()
List<NetAddress>	getBlockLocations(int blockIndex)
long	getBlockSizeByte()
ClientBlockInfo	getClientBlockInfo(int blockIndex)
List<ClientBlockInfo>	getClientBlockInfos() Get file's all blocks' ClientBlockInfo information.
int	getDependencyId()
long	getLength()
long	getNewBlockId()
int	getNumberOfBlocks()
String	getUfsPath()
boolean	hasCheckpointed()
boolean	isCache()
boolean	isComplete()
boolean	isFullyInMemory()
void	removeLocation(int blockIndex, long workerId)
void	setCache(boolean cache)
void	setComplete()
void	setComplete(boolean complete)
void	setDependencyId(int dependencyId)
void	setLength(long length)
void	setUfsPath(String ufsPath)
String	toString()
void	writeImage(com.fasterxml.jackson.databind.ObjectWriter objWriter, DataOutputStream dos)

Methods inherited from class tachyon.master.Inode

compareTo, equals, getCreationTimeMs, getId, getName, getParentId, hashCode, isDirectory, isFile, isPinned, reverseId, setName, setParentId, setPinned

Methods inherited from class tachyon.master.ImageWriter

writeElement

Methods inherited from class java.lang.Object

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

Constructor Detail

InodeFile

public InodeFile(String name,
                 int id,
                 int parentId,
                 long blockSizeByte,
                 long creationTimeMs)

Method Detail

addBlock

public void addBlock(BlockInfo blockInfo)
              throws BlockInfoException

Throws:

BlockInfoException

addLocation

public void addLocation(int blockIndex,
                        long workerId,
                        NetAddress workerAddress)
                 throws BlockInfoException

Throws:

BlockInfoException

generateClientFileInfo

public ClientFileInfo generateClientFileInfo(String path)

Specified by:

generateClientFileInfo in class Inode

getBlockIdBasedOnOffset

public long getBlockIdBasedOnOffset(long offset)

getBlockIds

public List<Long> getBlockIds()

getBlockIdWorkerIdPairs

public List<Pair<Long,Long>> getBlockIdWorkerIdPairs()

getBlockList

public List<BlockInfo> getBlockList()

getBlockLocations

public List<NetAddress> getBlockLocations(int blockIndex)
                                   throws BlockInfoException

Throws:

BlockInfoException

getBlockSizeByte

public long getBlockSizeByte()

getUfsPath

public String getUfsPath()

getClientBlockInfo

public ClientBlockInfo getClientBlockInfo(int blockIndex)
                                   throws BlockInfoException

Throws:

BlockInfoException

getClientBlockInfos

public List<ClientBlockInfo> getClientBlockInfos()

Get file's all blocks' ClientBlockInfo information.

Returns:

all blocks ClientBlockInfo

getDependencyId

public int getDependencyId()

getLength

public long getLength()

getNewBlockId

public long getNewBlockId()

getNumberOfBlocks

public int getNumberOfBlocks()

hasCheckpointed

public boolean hasCheckpointed()

isCache

public boolean isCache()

isComplete

public boolean isComplete()

isFullyInMemory

public boolean isFullyInMemory()

removeLocation

public void removeLocation(int blockIndex,
                           long workerId)
                    throws BlockInfoException

Throws:

BlockInfoException

setCache

public void setCache(boolean cache)

setUfsPath

public void setUfsPath(String ufsPath)

setComplete

public void setComplete()

setComplete

public void setComplete(boolean complete)

setDependencyId

public void setDependencyId(int dependencyId)

setLength

public void setLength(long length)
               throws SuspectedFileSizeException,
                      BlockInfoException

Throws:

SuspectedFileSizeException

BlockInfoException

toString

public String toString()

Overrides:

toString in class Inode

writeImage

public void writeImage(com.fasterxml.jackson.databind.ObjectWriter objWriter,
                       DataOutputStream dos)
                throws IOException

Throws:

IOException