alluxio.util.proto

Class BlockLocationUtils

java.lang.Object

alluxio.util.proto.BlockLocationUtils

public class BlockLocationUtils
extends Object

An util class to create cached grpc block locations.

Constructor Summary

Constructors

Constructor and Description
BlockLocationUtils()

Method Summary

Modifier and Type	Method and Description
static void	evictByWorkerId(long workerId) Evict cache entries by worker id.
static Block.BlockLocation	getCached(Block.BlockLocation blockLocation) Get a shared grpc block location object.
static Block.BlockLocation	getCached(long workerId, String tierAlias, String mediumType) Get a shared grpc block location object.
static int	getCachedBlockLocationSize() Gets the cached block location size.

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockLocationUtils

public BlockLocationUtils()

Method Detail

getCached

public static Block.BlockLocation getCached(long workerId,
                                            String tierAlias,
                                            String mediumType)

Get a shared grpc block location object. If it does not exist, create and cache it. Because the valid values of tierAlias and mediumType are only MEM, SSD and HDD, The size of the cache map is limited.

Parameters:

workerId - the worker id

tierAlias - the tier alias

mediumType - the medium type

Returns:

a shared block location object from the cache

getCached

public static Block.BlockLocation getCached(Block.BlockLocation blockLocation)

Get a shared grpc block location object. If it does not exist, create and cache it. Because the valid values of tierAlias and mediumType are only MEM, SSD and HDD, The size of the cache map is limited.

Parameters:

blockLocation - the block location to cache

Returns:

a shared block location object from the cache

evictByWorkerId

public static void evictByWorkerId(long workerId)

Evict cache entries by worker id.

Parameters:

workerId - the worker id

getCachedBlockLocationSize

public static int getCachedBlockLocationSize()

Gets the cached block location size.

Returns:

the cached block location size