Class StreamTransformer<TK, TV, TArg, TRes>

Convenience adapter to transform update existing values in streaming cache based on the previously cached value.

Inheritance

object

StreamTransformer<TK, TV, TArg, TRes>

Implements

IStreamReceiver<TK, TV>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Apache.Ignite.Core.Datastream

Assembly: Apache.Ignite.Core.dll

Syntax

public sealed class StreamTransformer<TK, TV, TArg, TRes> : IStreamReceiver<TK, TV>

Type Parameters

Name	Description
TK	Key type.
TV	Value type.
TArg	The type of the processor argument.
TRes	The type of the processor result.

Constructors

StreamTransformer(ICacheEntryProcessor<TK, TV, TArg, TRes>)

Initializes a new instance of the StreamTransformer<TK, TV, TArg, TRes> class.

Declaration

public StreamTransformer(ICacheEntryProcessor<TK, TV, TArg, TRes> proc)

Parameters

Type	Name	Description
ICacheEntryProcessor<TK, TV, TArg, TRes>	proc	Entry processor.

Methods

Receive(ICache<TK, TV>, ICollection<ICacheEntry<TK, TV>>)

Updates cache with batch of entries.

Declaration

[SuppressMessage("Microsoft.Design", "CA1062:Validate arguments of public methods")]
public 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.

Implements

IStreamReceiver<TK, TV>