[NIFI-2299] Add standard services API dependency to Scripting Processors

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.7.0, 0.6.1
• Fix Version/s: 1.0.0
• Component/s: Extensions
• Labels: Scripts groovy
• External issue URL: https://github.com/xmlking/mapr-nifi-hadoop-libraries-bundle/blob/master/nifi-mapr-build.md#add-optional
• Assignee: Joe Witt
• Reporter: sumanth chinthagunta
• Created: 18/Jul/16 04:00
• Updated: 25/Aug/16 01:02
• Resolved: 09/Aug/16 21:16

Description

Scripting Processors cannot used Controller Services such as DistributedMapCacheClientService etc, as required dependencies are missing for ExecuteScript Nar. By adding following dependencies we can open new possibilities for Scripting Processors.

Add this dependency to nifi/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-nar/pom.xml

<dependency>
    <groupId>org.apache.nifi</groupId>
    <artifactId>nifi-standard-services-api-nar</artifactId>
    <type>nar</type>
</dependency>

Add this dependency to nifi/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/pom.xml

<dependency>
    <groupId>org.apache.nifi</groupId>
    <artifactId>nifi-distributed-cache-client-service-api</artifactId>
</dependency>

Then we can create scripting processor like:

import org.apache.nifi.controller.ControllerService
import com.crossbusiness.nifi.processors.StringSerDe

final StringSerDe stringSerDe = new StringSerDe();

def lookup = context.controllerServiceLookup
def cacheServiceName = DistributedMapCacheClientServiceName.value

log.error  "cacheServiceName: ${cacheServiceName}"

def cacheServiceId = lookup.getControllerServiceIdentifiers(ControllerService).find {
    cs -> lookup.getControllerServiceName(cs) == cacheServiceName
}

log.error  "cacheServiceId:  ${cacheServiceId}"

def cache = lookup.getControllerService(cacheServiceId)
log.error cache.get("aaa", stringSerDe, stringSerDe )

Issue Links

• links to: GitHub Pull Request #753