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 Summary
Constructors Constructor Description StreamVisitor()
-
Method Summary
All 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
.void
receive(IgniteCache<K,V> cache, Collection<Map.Entry<K,V>> entries)
Updates cache with batch of entries.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.ignite.lang.IgniteBiInClosure
apply
-
-
-
-
Method Detail
-
receive
public void receive(IgniteCache<K,V> cache, Collection<Map.Entry<K,V>> entries) throws IgniteException
Updates cache with batch of entries.- Specified by:
receive
in interfaceStreamReceiver<K,V>
- Parameters:
cache
- Cache.entries
- Collection of entries.- Throws:
IgniteException
- If failed.
-
from
public 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.
-
-