Package org.apache.ignite.stream
Interface StreamReceiver<K,V>
-
- All Superinterfaces:
Serializable
- All Known Implementing Classes:
StreamTransformer,StreamVisitor
public interface StreamReceiver<K,V> extends Serializable
Updates cache with batch of entries. Usually it is enough to configureIgniteDataStreamer.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.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidreceive(IgniteCache<K,V> cache, Collection<Map.Entry<K,V>> entries)Updates cache with batch of entries.
-
-
-
Method Detail
-
receive
void receive(IgniteCache<K,V> cache, Collection<Map.Entry<K,V>> entries) throws IgniteException
Updates cache with batch of entries.- Parameters:
cache- Cache.entries- Collection of entries.- Throws:
IgniteException- If failed.
-
-