public abstract class StreamVisitor<K,V> extends Object implements StreamReceiver<K,V>, IgniteBiInClosure<IgniteCache<K,V>,Map.Entry<K,V>>
cache.put(...) should be called explicitly.| Constructor and Description |
|---|
StreamVisitor() |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> StreamVisitor<K,V> |
from(IgniteBiInClosure<IgniteCache<K,V>,Map.Entry<K,V>> c)
Creates a new visitor based on instance of
IgniteBiInClosure. |
void |
receive(IgniteCache<K,V> cache,
Collection<Map.Entry<K,V>> entries)
Updates cache with batch of entries.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitapplypublic void receive(IgniteCache<K,V> cache, Collection<Map.Entry<K,V>> entries) throws IgniteException
receive in interface StreamReceiver<K,V>cache - Cache.entries - Collection of entries.IgniteException - If failed.public static <K,V> StreamVisitor<K,V> from(IgniteBiInClosure<IgniteCache<K,V>,Map.Entry<K,V>> c)
IgniteBiInClosure.c - Closure.
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016