Interface IStreamReceiver<TK, TV>
Updates cache with batch of entries. Usually it is enough to configure AllowOverwrite property and appropriate internal cache receiver will be chosen automatically. But in some cases custom implementation may help to achieve better performance.
Namespace: Apache.Ignite.Core.Datastream
Assembly: Apache.Ignite.Core.dll
Syntax
public interface IStreamReceiver<TK, TV>Type Parameters
| Name | Description |
|---|---|
| TK | |
| TV |
Methods
Receive(ICache<TK, TV>, ICollection<ICacheEntry<TK, TV>>)
Updates cache with batch of entries.
Declaration
void Receive(ICache<TK, TV> cache, ICollection<ICacheEntry<TK, TV>> entries)Parameters
| Type | Name | Description |
|---|---|---|
| ICache<TK, TV> | cache | Cache. |
| ICollection<ICacheEntry<TK, TV>> | entries | Entries. |