org.gridgain.grid.kernal.processors.dataload

Class GridDataLoadCacheUpdaters

java.lang.Object

org.gridgain.grid.kernal.processors.dataload.GridDataLoadCacheUpdaters

public class GridDataLoadCacheUpdaters
extends Object

Bundled factory for cache updaters.

Constructor Summary

Constructors

Constructor and Description
GridDataLoadCacheUpdaters()

Method Summary

Methods

Modifier and Type	Method and Description
static <K,V> GridDataLoadCacheUpdater<K,V>	batched() Updates cache using batched methods GridCacheProjection.putAll(Map, GridPredicate[]) and GridCacheProjection.removeAll(Collection, GridPredicate[]).
static <K extends Comparable<?>,V> GridDataLoadCacheUpdater<K,V>	batchedSorted() Updates cache using batched methods GridCacheProjection.putAll(Map, GridPredicate[]) and GridCacheProjection.removeAll(Collection, GridPredicate[]).
static <K,V> GridDataLoadCacheUpdater<K,V>	groupLocked() Updates cache using batched methods GridCacheProjection.putAll(Map, GridPredicate[]) and GridCacheProjection.removeAll(Collection, GridPredicate[]) in group lock transaction.
static <K,V> GridDataLoadCacheUpdater<K,V>	individual() Updates cache using independent GridCacheProjection.put(Object, Object, GridPredicate[]) and GridCacheProjection.remove(Object, GridPredicate[]) operations.
protected static <K,V> void	updateAll(GridCacheProjection<K,V> cache, Collection<K> rmvCol, Map<K,V> putMap) Updates cache.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridDataLoadCacheUpdaters

public GridDataLoadCacheUpdaters()

Method Detail

individual

public static <K,V> GridDataLoadCacheUpdater<K,V> individual()

Updates cache using independent GridCacheProjection.put(Object, Object, GridPredicate[]) and GridCacheProjection.remove(Object, GridPredicate[]) operations. Thus it is safe from deadlocks but performance is not the best.

Returns:

Single updater.

batched

public static <K,V> GridDataLoadCacheUpdater<K,V> batched()

Updates cache using batched methods GridCacheProjection.putAll(Map, GridPredicate[]) and GridCacheProjection.removeAll(Collection, GridPredicate[]). Can cause deadlocks if the same keys are getting updated concurrently. Performance is generally better than in individual().

Returns:

Batched updater.

batchedSorted

public static <K extends Comparable<?>,V> GridDataLoadCacheUpdater<K,V> batchedSorted()

Updates cache using batched methods GridCacheProjection.putAll(Map, GridPredicate[]) and GridCacheProjection.removeAll(Collection, GridPredicate[]). Keys are sorted in natural order and if all updates use the same rule deadlock can not happen. Performance is generally better than in individual().

Returns:

Batched sorted updater.

groupLocked

public static <K,V> GridDataLoadCacheUpdater<K,V> groupLocked()

Updates cache using batched methods GridCacheProjection.putAll(Map, GridPredicate[]) and GridCacheProjection.removeAll(Collection, GridPredicate[]) in group lock transaction. Requires that there are no concurrent updates other than in group lock.

Returns:

Updater with group lock.

updateAll

protected static <K,V> void updateAll(GridCacheProjection<K,V> cache,
                   @Nullable
                   Collection<K> rmvCol,
                   Map<K,V> putMap)
                         throws GridException

Updates cache.

Parameters:

cache - Cache.

rmvCol - Keys to remove.

putMap - Entries to put.

Throws:

GridException - If failed.