[NIFI-988] PutDistributedMapCache processor

• Type: New Feature
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 0.4.0
• Component/s: Core Framework
• Labels: cache distributed feature new put
• Assignee: Unassigned
• Reporter: Joe Mészáros
• Created: 23/Sep/15 11:12
• Updated: 21/Oct/15 21:26
• Resolved: 21/Oct/15 14:52

Description

There is a standard controller service, called DistributedMapCacheServer, which provides a distributed cache, and an associated DistributedMapCacheClientService to interact with the cache. But there is not any standard processor, which puts data into the cache, and helps the user to leverage the distributed cache capabilities.

The purpose of PutDistributedMapCache is very similar to the egress processors: it gets the content of a FlowFile and puts it to a distributed map cache, using a cache key computed from FlowFile attributes. If the cache already contains the entry and the cache update strategy is 'keep original' the entry is not replaced.