Uses of Interface
org.apache.ignite.IgniteDataStreamer.Updater

Packages that use IgniteDataStreamer.Updater

Package	Description
org.apache.ignite	Contains entry-point Ignite & HPC APIs.
org.apache.ignite.internal.processors.datastreamer	Data streamer processor.
org.apache.ignite.internal.processors.dr	Data center replication processor.

Uses of IgniteDataStreamer.Updater in org.apache.ignite

Methods in org.apache.ignite with parameters of type IgniteDataStreamer.Updater

Modifier and Type	Method and Description
void	IgniteDataStreamer.updater(IgniteDataStreamer.Updater<K,V> updater) Sets custom cache updater to this data streamer.

Uses of IgniteDataStreamer.Updater in org.apache.ignite.internal.processors.datastreamer

Methods in org.apache.ignite.internal.processors.datastreamer that return IgniteDataStreamer.Updater

Modifier and Type	Method and Description
static <K,V> IgniteDataStreamer.Updater<K,V>	DataStreamerCacheUpdaters.batched() Updates cache using batched methods org.apache.ignite.cache.GridCache#putAll(Map, org.apache.ignite.lang.IgnitePredicate[]) and org.apache.ignite.cache.GridCache#removeAll(Collection, org.apache.ignite.lang.IgnitePredicate[]).
static <K extends Comparable<?>,V> IgniteDataStreamer.Updater<K,V>	DataStreamerCacheUpdaters.batchedSorted() Updates cache using batched methods org.apache.ignite.cache.GridCache#putAll(Map, org.apache.ignite.lang.IgnitePredicate[]) and org.apache.ignite.cache.GridCache#removeAll(Collection, org.apache.ignite.lang.IgnitePredicate[]).
static <K,V> IgniteDataStreamer.Updater<K,V>	DataStreamerCacheUpdaters.individual() Updates cache using independent org.apache.ignite.cache.GridCache#put(Object, Object, org.apache.ignite.lang.IgnitePredicate[]) and org.apache.ignite.cache.GridCache#remove(Object, org.apache.ignite.lang.IgnitePredicate[]) operations.

Methods in org.apache.ignite.internal.processors.datastreamer with parameters of type IgniteDataStreamer.Updater

Modifier and Type	Method and Description
void	DataStreamerImpl.updater(IgniteDataStreamer.Updater<K,V> updater) Sets custom cache updater to this data streamer.

Uses of IgniteDataStreamer.Updater in org.apache.ignite.internal.processors.dr

Classes in org.apache.ignite.internal.processors.dr that implement IgniteDataStreamer.Updater

Modifier and Type	Class and Description
class	IgniteDrDataStreamerCacheUpdater Data center replication cache updater for data streamer.