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.internal.processors.platform.datastreamer
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 IgniteCache.putAll(Map)and IgniteCache.removeAll().
static <K extends Comparable<?>,V> StreamReceiver<K,V>	DataStreamerCacheUpdaters.batchedSorted() Updates cache using batched methods IgniteCache.putAll(Map) and IgniteCache.removeAll(Set).
static <K,V> StreamReceiver<K,V>	DataStreamerCacheUpdaters.individual() Updates cache using independent IgniteCache.put(Object, Object)and IgniteCache.remove(Object) 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.internal.processors.platform.datastreamer

Subinterfaces of StreamReceiver in org.apache.ignite.internal.processors.platform.datastreamer

Modifier and Type	Interface and Description
interface	PlatformStreamReceiver Platform data streamer filter marker interface.

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.