Apache's Nifi processor for Infinispan cache
Below are the custom processors For Fetching and Inserting in Infinispan cache
Prerequisite:
1. Nifi Instance up and running
2. Infinispan server up and running
I) GetFromInfinispanCache :
This processor will get the value from Infinispan cache for the given Cache Name and Cache Key.
Relationships:
- It has two relationships Success and Failure
Properties:
- Infinispan Host
- Infinispan Port
- Cache Name
- Cache Key
- Put Cache Value In Attribute - Fill this only if the Cache value should be set as a FlowFile Attribute else it will set the Cache value in FlowFile content. This supports expression language of Variable registry and FlowFile Attribute
II) PutInInfinispanCache
This processor will put the value in Infinispan cache for the given Cache Name and Cache Key and Cache Value.
Relationships:
- It has two relationships Success and Failure
Properties:
- Infinispan Host
- Infinispan Port
- Cache Name
- Cache Key
- Cache Value - This supports expression language of Variable registry and FlowFile Attribute
Steps to add these processors in any Nifi setup:
- Build the application from root application's pom.xml
- This will generate a nar file `nifi-infinispanCache-nar-1.0.nar` in ``{nifi-infinispan-processor}\nifi-putInInfinispanCache-nar\target\ folder``
- Copy this nar file in nifi instance lib folder `{nifi-home}\lib`
- Restart Nifi
- Processor will be available in the repository
Comments
Post a Comment