sumanth chinthagunta created NIFI-2299:
------------------------------------------
Summary: Add standard services API dependency to Scripting
Processors
Key: NIFI-2299
URL: https://issues.apache.org/jira/browse/NIFI-2299
Project: Apache NiFi
Issue Type: Bug
Components: Extensions
Affects Versions: 0.6.1, 0.7.0
Reporter: sumanth chinthagunta
Fix For: 0.8.0
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
{code}
<dependency>
<groupId>org.apache.nifi</groupId>
<artifactId>nifi-standard-services-api-nar</artifactId>
<type>nar</type>
</dependency>
{code}
Add this dependency to
nifi/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/pom.xml
{code}
<dependency>
<groupId>org.apache.nifi</groupId>
<artifactId>nifi-distributed-cache-client-service-api</artifactId>
</dependency>
{code}
Then we can create scripting processor like:
{code}
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 )
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
