Convenience adapter to visit every key-value tuple in the stream. Note that the visitor does not update the cache. More...

Inheritance diagram for Apache.Ignite.Core.Datastream.StreamVisitor< TK, TV >:

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)

Detailed Description

Template Parameters

TK	The type of the cache key.
TV	The type of the cache value.

Constructor & Destructor Documentation

Apache.Ignite.Core.Datastream.StreamVisitor< TK, TV >.StreamVisitor ( Action< ICache< TK, TV >, ICacheEntry< TK, TV >> action )

Parameters

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.

Parameters

cache	Cache.
entries	Entries.