alluxio.worker.block.meta

Class DefaultTempBlockMeta

java.lang.Object

alluxio.worker.block.meta.DefaultTempBlockMeta

All Implemented Interfaces:

TempBlockMeta

@NotThreadSafe
public class DefaultTempBlockMeta
extends Object
implements TempBlockMeta

Represents the metadata of an uncommitted block in Alluxio managed storage.

Constructor Summary

Constructors

Constructor and Description
DefaultTempBlockMeta(long sessionId, long blockId, long initialBlockSize, StorageDir dir) Creates a new instance of DefaultTempBlockMeta.

Method Summary

Modifier and Type	Method and Description
long	getBlockId()
BlockStoreLocation	getBlockLocation()
long	getBlockSize()
String	getCommitPath()
StorageDir	getParentDir()
String	getPath()
long	getSessionId()
void	setBlockSize(long newSize)
static String	tempPath(StorageDir dir, long sessionId, long blockId) All blocks are created as temp blocks before committed.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultTempBlockMeta

public DefaultTempBlockMeta(long sessionId,
                            long blockId,
                            long initialBlockSize,
                            StorageDir dir)

Creates a new instance of DefaultTempBlockMeta.

Parameters:

sessionId - the session id

blockId - the block id

initialBlockSize - initial size of this block in bytes

dir - StorageDir of this temp block belonging to

Method Detail

tempPath

public static String tempPath(StorageDir dir,
                              long sessionId,
                              long blockId)

All blocks are created as temp blocks before committed. They are stored in BlockStore under a subdir of its StorageDir, the subdir is tmpFolder/sessionId % maxSubdirMax. tmpFolder is a property of PropertyKey.WORKER_DATA_TMP_FOLDER. maxSubdirMax is a property of PropertyKey.WORKER_DATA_TMP_SUBDIR_MAX. The block file name is "sessionId-blockId". e.g. sessionId 2 creates a temp Block 100 in StorageDir "/mnt/mem/0", this temp block has path:

/mnt/mem/0/.tmp_blocks/2/2-100

Parameters:

dir - the parent directory

sessionId - the session id

blockId - the block id

Returns:

temp file path

getBlockSize

public long getBlockSize()

Specified by:

getBlockSize in interface TempBlockMeta

Returns:

the block size

getPath

public String getPath()

Specified by:

getPath in interface TempBlockMeta

Returns:

the block path

getBlockId

public long getBlockId()

Specified by:

getBlockId in interface TempBlockMeta

Returns:

the block id

getBlockLocation

public BlockStoreLocation getBlockLocation()

Specified by:

getBlockLocation in interface TempBlockMeta

Returns:

location of the block

getParentDir

public StorageDir getParentDir()

Specified by:

getParentDir in interface TempBlockMeta

Returns:

the parent directory

getCommitPath

public String getCommitPath()

Specified by:

getCommitPath in interface TempBlockMeta

Returns:

the commit path

getSessionId

public long getSessionId()

Specified by:

getSessionId in interface TempBlockMeta

Returns:

the session id

setBlockSize

public void setBlockSize(long newSize)

Specified by:

setBlockSize in interface TempBlockMeta

Parameters:

newSize - block size to use