org.thales.punch.libraries.punchlang.operator

Class NifiOperator

java.lang.Object

org.thales.punch.libraries.punchlang.operator.NifiOperator

public class NifiOperator
extends Object

The Nifi operator allows to interact with Nifi when using a Nifi Processor.

Say you want to transfer the result tuple to relationships "success" :

 
 nifi().addOutputRoute("success").into(root);
 print();
 
 

You'll get :

 
 { "nifi_output_relationships": ["success"] }
 
 

Field Summary

Fields

Modifier and Type	Field and Description
static String	OUTPUT_ROUTES_KEY

Constructor Summary

Constructors

Constructor and Description
NifiOperator() Ctor

Method Summary

Modifier and Type	Method and Description
NifiOperator	addOutputRoute(String route) Add route to output routes
NifiOperator	addOutputRoute(Tuple tuple) Add route to output routes
static Set<String>	getRoutesFromTuple(Tuple tuple) Extract list of routes as string from tuple
void	into(Tuple into) Apply the operator an put the result into the provided tuple.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

OUTPUT_ROUTES_KEY

public static final String OUTPUT_ROUTES_KEY

See Also:

Constant Field Values

Constructor Detail

NifiOperator

public NifiOperator()

Ctor

Method Detail

addOutputRoute

public NifiOperator addOutputRoute(String route)

Add route to output routes

Parameters:

route - the output route

Returns:

true for success

addOutputRoute

public NifiOperator addOutputRoute(Tuple tuple)

Add route to output routes

Parameters:

tuple - the output route

Returns:

true for success

into

public void into(Tuple into)

Apply the operator an put the result into the provided tuple.

Parameters:

into - the output tuple

getRoutesFromTuple

public static Set<String> getRoutesFromTuple(Tuple tuple)

Extract list of routes as string from tuple

Parameters:

tuple - tuple containing routes

Returns:

list of routes as string