alluxio.stress.cli

Class RpcBenchPreparationUtils

java.lang.Object

alluxio.stress.cli.RpcBenchPreparationUtils

public class RpcBenchPreparationUtils
extends Object

Utilities for the preparation step in RPC benchmark testing.

Field Summary

Fields

Modifier and Type	Field and Description
static BlockStoreLocation	BLOCK_LOCATION_MEM
static long	CAPACITY
static Map<String,Long>	CAPACITY_MEM
static List<ConfigProperty>	EMPTY_CONFIG
static Map<String,List<String>>	LOST_STORAGE
static Map<String,Long>	USED_MEM_EMPTY

Method Summary

Modifier and Type	Method and Description
static Map<BlockStoreLocation,List<Long>>	generateBlockIdOnTiers(Map<TierAlias,List<Integer>> tiersConfig) Generates block IDs according to the storage tier/dir setup.
static void	prepareBlocksInMaster(Map<BlockStoreLocation,List<Long>> locToBlocks) Prepare all relevant block IDs on the master side concurrently.

Methods inherited from class java.lang.Object

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

Field Detail

CAPACITY

public static final long CAPACITY

See Also:

Constant Field Values

CAPACITY_MEM

public static final Map<String,Long> CAPACITY_MEM

USED_MEM_EMPTY

public static final Map<String,Long> USED_MEM_EMPTY

BLOCK_LOCATION_MEM

public static final BlockStoreLocation BLOCK_LOCATION_MEM

LOST_STORAGE

public static final Map<String,List<String>> LOST_STORAGE

EMPTY_CONFIG

public static final List<ConfigProperty> EMPTY_CONFIG

Method Detail

prepareBlocksInMaster

public static void prepareBlocksInMaster(Map<BlockStoreLocation,List<Long>> locToBlocks)
                                  throws InterruptedException

Prepare all relevant block IDs on the master side concurrently.

Parameters:

locToBlocks - a map from block location to block IDs

Throws:

InterruptedException

generateBlockIdOnTiers

public static Map<BlockStoreLocation,List<Long>> generateBlockIdOnTiers(Map<TierAlias,List<Integer>> tiersConfig)

Generates block IDs according to the storage tier/dir setup. In order to avoid block ID colliding with existing blocks, this will generate IDs decreasingly from the Long.MAX_VALUE.

Parameters:

tiersConfig - the tier/dir block counts

Returns:

a map of location to generated block lists