org.apache.ignite.internal.processors.hadoop.impl.fs

Class HadoopLazyConcurrentMap<K,V extends Closeable>

java.lang.Object

org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopLazyConcurrentMap<K,V>

public class HadoopLazyConcurrentMap<K,V extends Closeable>
extends Object

Maps values by keys. Values are created lazily using HadoopLazyConcurrentMap.ValueFactory. Despite of the name, does not depend on any Hadoop classes.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	HadoopLazyConcurrentMap.ValueFactory<K,V> Interface representing the factory that creates map values.

Constructor Summary

Constructors

Constructor and Description
HadoopLazyConcurrentMap(HadoopLazyConcurrentMap.ValueFactory<K,V> factory) Constructor.

Method Summary

Modifier and Type	Method and Description
void	close() Clears the map and closes all the values.
V	getOrCreate(K k) Gets cached or creates a new value of V.

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopLazyConcurrentMap

public HadoopLazyConcurrentMap(HadoopLazyConcurrentMap.ValueFactory<K,V> factory)

Constructor.

Parameters:

factory - the factory to create new values lazily.

Method Detail

getOrCreate

public V getOrCreate(K k)

Gets cached or creates a new value of V. Never returns null.

Parameters:

k - the key to associate the value with.

Returns:

the cached or newly created value, never null.

Throws:

IgniteException - on error

close

public void close()
           throws IgniteCheckedException

Clears the map and closes all the values.

Throws:

IgniteCheckedException