![]() |
Apache Ignite.NET
|
Convenience adapter to transform update existing values in streaming cache based on the previously cached value. More...
Public Member Functions | |
| StreamTransformer (ICacheEntryProcessor< TK, TV, TArg, TRes > proc) | |
| Initializes a new instance of the StreamTransformer<K, V, A, R> class. More... | |
| void | Receive (ICache< TK, TV > cache, ICollection< ICacheEntry< TK, TV >> entries) |
| TK | Key type. |
| TV | Value type. |
| TArg | The type of the processor argument. |
| TRes | The type of the processor result. |
| Apache.Ignite.Core.Datastream.StreamTransformer< TK, TV, TArg, TRes >.StreamTransformer | ( | ICacheEntryProcessor< TK, TV, TArg, TRes > | proc | ) |
| proc | Entry processor. |
| void Apache.Ignite.Core.Datastream.StreamTransformer< TK, TV, TArg, TRes >.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 >.