View SplitRecord_w_Conversion.xml
<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<template encoding-version="1.2">
<description></description>
<groupId>89f8c6b8-0164-1000-d937-82c55b6fdffd</groupId>
<name>SplitRecord_w_Conversion</name>
<snippet>
<controllerServices>
<id>350009ab-3f44-32bf-0000-000000000000</id>
<parentGroupId>fa0118f1-ff03-3030-0000-000000000000</parentGroupId>
<bundle>
View ISP_template.py
#////////////////////////////////////////////////////////////
#// imports go here
#////////////////////////////////////////////////////////////
from org.apache.nifi.processor import Processor,Relationship
from java.lang import Throwable
class E():
def __init__(self):
pass
def executeScript(self,session, context, log, REL_SUCCESS, REL_FAILURE):
View testEL.groovy
@Grab(group='org.apache.nifi', module='nifi-expression-language', version='1.4.0')
import org.apache.nifi.attribute.expression.language.*
def cli = new CliBuilder(usage:'groovy testEL.groovy [options] [expressions]',
header:'Options:')
cli.help('print this message')
cli.D(args:2, valueSeparator:'=', argName:'attribute=value',
'set value for given attribute')
def options = cli.parse(args)
if(!options.arguments()) {
View csv_to_avroschema.groovy
import groovy.json.*
def flowFile = session.get()
if(!flowFile) return
def delim = ','
try {
delim = delimiter?.value ?: ','
} catch (MissingPropertyException mpe) { }
View ScriptedReaderTest.xml
<?xml version="1.0" ?>
<template encoding-version="1.1">
<description></description>
<groupId>a5a9dae4-015b-1000-7a1c-eaf2db85b188</groupId>
<name>ScriptedReaderTest</name>
<snippet>
<controllerServices>
<id>bb8e2ece-1712-3f89-0000-000000000000</id>
<parentGroupId>f3e4227c-c306-3c57-0000-000000000000</parentGroupId>
<bundle>
View ConvertRecord_examples.xml
<?xml version="1.0" ?>
<template encoding-version="1.1">
<description></description>
<groupId>7ebaf566-015b-1000-b416-922a420ea741</groupId>
<name>ConvertRecord_examples</name>
<snippet>
<connections>
<id>81dd9a51-07c4-39f0-0000-000000000000</id>
<parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
View CDC_MySQL_Replication.xml
<?xml version="1.0" ?>
<template encoding-version="1.1">
<description>This template shows an end-to-end example of how to replicate table(s)
from a source MySQL database to a target MySQL database</description>
<groupId>68961054-015b-1000-2c21-01b42e84dbe0</groupId>
<name>CDC_MySQL_Replication</name>
<snippet>
<connections>
<id>9a0f0bca-5c0c-3f1e-0000-000000000000</id>
<parentGroupId>23d80cd0-6e6e-31c9-0000-000000000000</parentGroupId>
View EnforceOrder_Examples.xml
<?xml version="1.0" ?>
<template encoding-version="1.1">
<description>This template contains two use cases for the EnforceOrder processor:
1) Random Delay: FlowFiles are routed to two separate paths and delayed by a random amount of time (0-100 millis)
2) MultipleSplits: FlowFiles are split twice with SplitText, the attributes must be updated to keep the original order
</description>
<groupId>48313cf9-015b-1000-cf31-bc9709ad2638</groupId>
<name>EnforceOrder_Examples</name>
<snippet>
View CDC_Replication.xml
<?xml version="1.0" ?>
<template encoding-version="1.0">
<description></description>
<groupId>faf788c5-015a-1000-f344-de24ceb9d7e7</groupId>
<name>CDC_Replication</name>
<snippet>
<connections>
<id>d21bc8ee-015a-1000-0000-000000000000</id>
<parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
View binlog_connector.groovy
@Grab('com.github.shyiko:mysql-binlog-connector-java:0.8.1')
import com.github.shyiko.mysql.binlog.event.*
import com.github.shyiko.mysql.binlog.*
args = ['192.168.99.100', '32768', 'root', 'K3sdchkm'] as String[]
if(!args || args.length < 3) {
println 'Usage: groovy binlog_connector.groovy <host> <port> <username> [<password>]'
return 1
}
def client = new BinaryLogClient(args[0], Integer.parseInt(args[1]), args[2], args.length == 4 ? args[3] : '')
def recordCount = 0