![]() |
Apache Ignite.NET
|
Convenience adapter to visit every key-value tuple in the stream. Note that the visitor does not update the cache. More...
Public Member Functions | |
| StreamVisitor (Action< ICache< TK, TV >, ICacheEntry< TK, TV >> action) | |
| Initializes a new instance of the StreamVisitor<K, V> class. More... | |
| void | Receive (ICache< TK, TV > cache, ICollection< ICacheEntry< TK, TV >> entries) |
| TK | The type of the cache key. |
| TV | The type of the cache value. |
| Apache.Ignite.Core.Datastream.StreamVisitor< TK, TV >.StreamVisitor | ( | Action< ICache< TK, TV >, ICacheEntry< TK, TV >> | action | ) |
| action | The action to be called on each stream entry. |
| void Apache.Ignite.Core.Datastream.StreamVisitor< TK, TV >.Receive | ( | ICache< TK, TV > | cache, |
| ICollection< ICacheEntry< TK, TV >> | entries | ||
| ) |
Updates cache with batch of entries.
| cache | Cache. |
| entries | Entries. |
Implements Apache.Ignite.Core.Datastream.IStreamReceiver< TK, TV >.