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 SummaryAll 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- 
receivevoid 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.
 
 
- 
 
-