public class RpcBenchPreparationUtils extends Object
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 |
Modifier and Type | Method and Description |
---|---|
static void |
prepareBlocksInMaster(Map<BlockStoreLocation,List<Long>> locToBlocks,
ExecutorService pool,
int concurrency)
Prepare all relevant block IDs on the master side concurrently.
|
public static final long CAPACITY
public static final BlockStoreLocation BLOCK_LOCATION_MEM
public static final List<ConfigProperty> EMPTY_CONFIG
public static void prepareBlocksInMaster(Map<BlockStoreLocation,List<Long>> locToBlocks, ExecutorService pool, int concurrency)
locToBlocks
- a map from block location to block IDspool
- the thread pool to submit toconcurrency
- number of threads/concurrent clientsCopyright © 2023. All Rights Reserved.