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	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

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

Modifier and Type	Class	Description
protected static class	DataStreamerImpl.IsolatedUpdater	Isolated receiver which only loads entry initial value.

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

Modifier and Type	Method	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	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	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	Description
interface	PlatformStreamReceiver	Platform data streamer filter marker interface.

Classes in org.apache.ignite.internal.processors.platform.datastreamer that implement StreamReceiver

Modifier and Type	Class	Description
class	PlatformStreamReceiverImpl	Interop receiver.

Uses of StreamReceiver in org.apache.ignite.stream

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

Modifier and Type	Class	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.