org.apache.ignite

Interface IgniteDataStreamer.Updater<K,V>

All Superinterfaces:

Serializable

All Known Implementing Classes:

IgniteDrDataStreamerCacheUpdater

Enclosing interface:

IgniteDataStreamer<K,V>

public static interface IgniteDataStreamer.Updater<K,V>
extends Serializable

Updates cache with batch of entries. Usually it is enough to configure IgniteDataStreamer.allowOverwrite(boolean) property and appropriate internal cache updater will be chosen automatically. But in some cases to achieve best performance custom user-defined implementation may help.

Data streamer can be configured to use custom implementation of updater instead of default one using IgniteDataStreamer.updater(IgniteDataStreamer.Updater) method.

Method Summary

Methods

Modifier and Type	Method and Description
void	update(IgniteCache<K,V> cache, Collection<Map.Entry<K,V>> entries) Updates cache with batch of entries.

Method Detail

update

void update(IgniteCache<K,V> cache,
          Collection<Map.Entry<K,V>> entries)
            throws IgniteException

Updates cache with batch of entries.

Parameters:

cache - Cache.

entries - Collection of entries.

Throws:

IgniteException - If failed.