public static interface IgniteDataStreamer.Updater<K,V> extends Serializable
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.
Modifier and Type | Method and Description |
---|---|
void |
update(IgniteCache<K,V> cache,
Collection<Map.Entry<K,V>> entries)
Updates cache with batch of entries.
|
void update(IgniteCache<K,V> cache, Collection<Map.Entry<K,V>> entries) throws IgniteException
cache
- Cache.entries
- Collection of entries.IgniteException
- If failed.
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015