org.apache.reef.io.network.naming

Class NameCache

java.lang.Object

org.apache.reef.io.network.naming.NameCache

All Implemented Interfaces:

Cache<Identifier,InetSocketAddress>

public class NameCache
extends Object
implements Cache<Identifier,InetSocketAddress>

Naming cache implementation.

Constructor Summary

Constructors

Constructor and Description
NameCache(long timeout) Constructs a naming cache.

Method Summary

Methods

Modifier and Type	Method and Description
InetSocketAddress	get(Identifier key, Callable<InetSocketAddress> valueFetcher) Gets an address for an identifier.
void	invalidate(Identifier key) Invalidates the entry for an identifier.

Methods inherited from class java.lang.Object

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

Constructor Detail

NameCache

public NameCache(long timeout)

Constructs a naming cache.

Parameters:

timeout - a cache entry timeout after write

Method Detail

get

public InetSocketAddress get(Identifier key,
                    Callable<InetSocketAddress> valueFetcher)
                      throws ExecutionException

Gets an address for an identifier.

Specified by:

get in interface Cache<Identifier,InetSocketAddress>

Parameters:

key - an identifier

valueFetcher - a callable to load a value for the corresponding identifier

Returns:

an Internet socket address

Throws:

ExecutionException

invalidate

public void invalidate(Identifier key)

Invalidates the entry for an identifier.

Specified by:

invalidate in interface Cache<Identifier,InetSocketAddress>

Parameters:

key - an identifier