Uses of Interface
org.apache.ignite.stream.StreamReceiver

Packages that use StreamReceiver

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.
org.apache.ignite.stream	Contains Ignite Streamer classes.

Uses of StreamReceiver in org.apache.ignite

Methods in org.apache.ignite with parameters of type StreamReceiver

Modifier and Type	Method and Description
void	IgniteDataStreamer.receiver(StreamReceiver<K,V> rcvr) Sets custom stream receiver to this data streamer.

Uses of StreamReceiver in org.apache.ignite.internal.processors.datastreamer

Methods in org.apache.ignite.internal.processors.datastreamer that return StreamReceiver

Modifier and Type	Method and Description
static <K,V> StreamReceiver<K,V>	DataStreamerCacheUpdaters.batched() Updates cache using batched methods CacheProjection.putAll(Map, CacheEntryPredicate[]) and CacheProjection.removeAll(Collection, CacheEntryPredicate[]).
static <K extends Comparable<?>,V> StreamReceiver<K,V>	DataStreamerCacheUpdaters.batchedSorted() Updates cache using batched methods CacheProjection.putAll(Map, CacheEntryPredicate[]) and CacheProjection.removeAll(Collection, CacheEntryPredicate[]).
static <K,V> StreamReceiver<K,V>	DataStreamerCacheUpdaters.individual() Updates cache using independent CacheProjection.put(Object, Object, CacheEntryPredicate[]) and CacheProjection.remove(Object, CacheEntryPredicate[]) operations.

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

Modifier and Type	Method and Description
void	DataStreamerImpl.receiver(StreamReceiver<K,V> rcvr) Sets custom stream receiver to this data streamer.

Uses of StreamReceiver in org.apache.ignite.internal.processors.dr

Classes in org.apache.ignite.internal.processors.dr that implement StreamReceiver

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

Uses of StreamReceiver in org.apache.ignite.stream

Classes in org.apache.ignite.stream that implement StreamReceiver

Modifier and Type	Class and Description
class	StreamTransformer<K,V> Convenience adapter to transform update existing values in streaming cache based on the previously cached value.
class	StreamVisitor<K,V> Convenience adapter to visit every key-value tuple in the stream.