public interface StreamReceiver<K,V> extends Serializable
IgniteDataStreamer.allowOverwrite(boolean)
property and appropriate internal cache receiver 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 the receiver instead of default one using
IgniteDataStreamer.receiver(StreamReceiver) method.
| Modifier and Type | Method and Description |
|---|---|
void |
receive(IgniteCache<K,V> cache,
Collection<Map.Entry<K,V>> entries)
Updates cache with batch of entries.
|
void receive(IgniteCache<K,V> cache, Collection<Map.Entry<K,V>> entries) throws IgniteException
cache - Cache.entries - Collection of entries.IgniteException - If failed.
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016