org.apache.ignite.internal.processors.dr

Class IgniteDrDataStreamerCacheUpdater

java.lang.Object

org.apache.ignite.internal.processors.dr.IgniteDrDataStreamerCacheUpdater

All Implemented Interfaces:

Serializable, IgniteDataStreamer.Updater<KeyCacheObject,CacheObject>, DataStreamerCacheUpdaters.InternalUpdater

public class IgniteDrDataStreamerCacheUpdater
extends Object
implements IgniteDataStreamer.Updater<KeyCacheObject,CacheObject>, DataStreamerCacheUpdaters.InternalUpdater

Data center replication cache updater for data streamer.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
IgniteDrDataStreamerCacheUpdater()

Method Summary

Methods

Modifier and Type	Method and Description
void	update(IgniteCache<KeyCacheObject,CacheObject> cache0, Collection<Map.Entry<KeyCacheObject,CacheObject>> col) Updates cache with batch of entries.

Methods inherited from class java.lang.Object

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

Constructor Detail

IgniteDrDataStreamerCacheUpdater

public IgniteDrDataStreamerCacheUpdater()

Method Detail

update

public void update(IgniteCache<KeyCacheObject,CacheObject> cache0,
          Collection<Map.Entry<KeyCacheObject,CacheObject>> col)

Updates cache with batch of entries.

Specified by:

update in interface IgniteDataStreamer.Updater<KeyCacheObject,CacheObject>

Parameters:

cache0 - Cache.

col - Collection of entries.