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

Inheritance diagram for Apache.Ignite.Core.Datastream.StreamTransformer< TK, TV, TArg, TRes >:

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)

Detailed Description

Template Parameters

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

Constructor & Destructor Documentation

Apache.Ignite.Core.Datastream.StreamTransformer< TK, TV, TArg, TRes >.StreamTransformer ( ICacheEntryProcessor< TK, TV, TArg, TRes > proc )

Parameters

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.

Parameters

cache	Cache.
entries	Entries.