Package org.apache.ignite.stream
Class StreamVisitor<K,V>
- java.lang.Object
- 
- org.apache.ignite.stream.StreamVisitor<K,V>
 
- 
- All Implemented Interfaces:
- Serializable,- IgniteBiInClosure<IgniteCache<K,V>,Map.Entry<K,V>>,- StreamReceiver<K,V>
 
 public abstract class StreamVisitor<K,V> extends Object implements StreamReceiver<K,V>, IgniteBiInClosure<IgniteCache<K,V>,Map.Entry<K,V>> Convenience adapter to visit every key-value tuple in the stream. Note, that the visitor does not update the cache. If the tuple needs to be stored in the cache, thencache.put(...)should be called explicitly.- See Also:
- Serialized Form
 
- 
- 
Constructor SummaryConstructors Constructor Description StreamVisitor()
 - 
Method SummaryAll Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <K,V>
 StreamVisitor<K,V>from(IgniteBiInClosure<IgniteCache<K,V>,Map.Entry<K,V>> c)Creates a new visitor based on instance ofIgniteBiInClosure.voidreceive(IgniteCache<K,V> cache, Collection<Map.Entry<K,V>> entries)Updates cache with batch of entries.- 
Methods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 - 
Methods inherited from interface org.apache.ignite.lang.IgniteBiInClosureapply
 
- 
 
- 
- 
- 
Method Detail- 
receivepublic void receive(IgniteCache<K,V> cache, Collection<Map.Entry<K,V>> entries) throws IgniteException Updates cache with batch of entries.- Specified by:
- receivein interface- StreamReceiver<K,V>
- Parameters:
- cache- Cache.
- entries- Collection of entries.
- Throws:
- IgniteException- If failed.
 
 - 
frompublic static <K,V> StreamVisitor<K,V> from(IgniteBiInClosure<IgniteCache<K,V>,Map.Entry<K,V>> c) Creates a new visitor based on instance ofIgniteBiInClosure.- Type Parameters:
- K- Ignite cache key type.
- V- Ignite cache value type.
- Parameters:
- c- Closure.
- Returns:
- Stream visitor.
 
 
- 
 
-