alluxio.worker

Class BlockStoreBase

java.lang.Object

alluxio.worker.BlockStoreBase

All Implemented Interfaces:

AutoCloseable

public class BlockStoreBase
extends Object
implements AutoCloseable

The class contains necessary objects to perform benchmarks on BlockStore. It is intended for use case of comparing performance of different BlockStore implementations, where only one of the stores will be actually used. For this reason, UFS is shared among all the objects. Users should be careful about this for different kinds of use cases.

Field Summary

Fields

Modifier and Type	Field and Description
MonoBlockStore	mMonoBlockStore MonoBlockStore backed by TieredBlockStore as local storage.
PagedBlockStore	mPagedBlockStore PagedBlockStore that uses page cache as local storage.
UfsManager	mUfsManager The shared UfsManager used for block stores.

Constructor Summary

Constructors

Constructor and Description
BlockStoreBase(MonoBlockStore monoBlockStore, PagedBlockStore pagedBlockStore, UfsManager ufs)

Method Summary

Modifier and Type	Method and Description
void	close()
static BlockStoreBase	create() Create a new instance with initialized block store objects.
void	mountUfs(long mountId, String rootDir) Mount an ufs to UfsManager, which is shared for both stores.
void	prepareLocalBlock(long blockId, long blockSize, byte[] data) Create a local block to both Mono and Paged block store.
void	prepareUfsFile(String ufsFilePath, byte[] data) Flush some data to the local file located at ufsFilePath.

Methods inherited from class java.lang.Object

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

Field Detail

mMonoBlockStore

public MonoBlockStore mMonoBlockStore

MonoBlockStore backed by TieredBlockStore as local storage.

mPagedBlockStore

public PagedBlockStore mPagedBlockStore

PagedBlockStore that uses page cache as local storage.

mUfsManager

public UfsManager mUfsManager

The shared UfsManager used for block stores.

Constructor Detail

BlockStoreBase

public BlockStoreBase(MonoBlockStore monoBlockStore,
                      PagedBlockStore pagedBlockStore,
                      UfsManager ufs)

Method Detail

create

public static BlockStoreBase create()

Create a new instance with initialized block store objects.

Returns:

the BlockStoreBase

prepareLocalBlock

public void prepareLocalBlock(long blockId,
                              long blockSize,
                              byte[] data)
                       throws Exception

Create a local block to both Mono and Paged block store. Flush some data to the block and commit it for later use.

Parameters:

blockId - block id

blockSize - size of block

data - read-only data to flush to block

Throws:

Exception - if I/O error happens

mountUfs

public void mountUfs(long mountId,
                     String rootDir)

Mount an ufs to UfsManager, which is shared for both stores.

Parameters:

mountId - mount id

rootDir - directory path of ufs

prepareUfsFile

public void prepareUfsFile(String ufsFilePath,
                           byte[] data)
                    throws Exception

Flush some data to the local file located at ufsFilePath.

Parameters:

ufsFilePath - file path

data - ufs file data

Throws:

Exception - if error occurs

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception