Created
August 29, 2018 16:15
-
-
Save pvillard31/5b16813861d56987b60a92563649674b to your computer and use it in GitHub Desktop.
Template for Monitoring Driven Development in NiFi
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<?xml version="1.0" encoding="UTF-8" standalone="yes"?> | |
<template encoding-version="1.2"> | |
<description></description> | |
<groupId>8927f4c0-0160-1000-597a-ea764ccd81a7</groupId> | |
<name>MDD</name> | |
<snippet> | |
<connections> | |
<id>a2098494-cce9-3fa4-0000-000000000000</id> | |
<parentGroupId>a8352767-434f-3321-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>0b69ea51-7afb-32dd-0000-000000000000</groupId> | |
<id>ece7f336-0730-34f1-0000-000000000000</id> | |
<type>INPUT_PORT</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<source> | |
<groupId>a8352767-434f-3321-0000-000000000000</groupId> | |
<id>6cc0faed-3375-30ed-0000-000000000000</id> | |
<type>INPUT_PORT</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<inputPorts> | |
<id>6cc0faed-3375-30ed-0000-000000000000</id> | |
<parentGroupId>a8352767-434f-3321-0000-000000000000</parentGroupId> | |
<position> | |
<x>18.840023437500008</x> | |
<y>72.12799023437492</y> | |
</position> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<name>monitoring</name> | |
<state>RUNNING</state> | |
<transmitting>false</transmitting> | |
<type>INPUT_PORT</type> | |
</inputPorts> | |
<labels> | |
<id>7b719601-8387-3e66-0000-000000000000</id> | |
<parentGroupId>a8352767-434f-3321-0000-000000000000</parentGroupId> | |
<position> | |
<x>0.0</x> | |
<y>0.0</y> | |
</position> | |
<height>236.02401733398438</height> | |
<label>Monitoring</label> | |
<style> | |
<entry> | |
<key>font-size</key> | |
<value>12px</value> | |
</entry> | |
</style> | |
<width>1114.85595703125</width> | |
</labels> | |
<processGroups> | |
<id>0b69ea51-7afb-32dd-0000-000000000000</id> | |
<parentGroupId>a8352767-434f-3321-0000-000000000000</parentGroupId> | |
<position> | |
<x>708.3120859374998</x> | |
<y>30.112013671874934</y> | |
</position> | |
<comments></comments> | |
<contents> | |
<connections> | |
<id>50804efc-5bc2-327f-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>08502007-64bf-3e4d-0000-000000000000</groupId> | |
<id>2122a525-8179-33aa-0000-000000000000</id> | |
<type>INPUT_PORT</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<source> | |
<groupId>0b69ea51-7afb-32dd-0000-000000000000</groupId> | |
<id>ece7f336-0730-34f1-0000-000000000000</id> | |
<type>INPUT_PORT</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>50afd8ec-f965-3b2e-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<bends> | |
<x>141.70001220703125</x> | |
<y>-625.7999877929688</y> | |
</bends> | |
<destination> | |
<groupId>0b69ea51-7afb-32dd-0000-000000000000</groupId> | |
<id>d0258284-69ae-34f6-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>0</labelIndex> | |
<name></name> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>0b69ea51-7afb-32dd-0000-000000000000</groupId> | |
<id>9e38cb88-668a-3f52-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>5554bc8a-7641-3b6d-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<bends> | |
<x>-636.300048828125</x> | |
<y>-586.7999877929688</y> | |
</bends> | |
<destination> | |
<groupId>0b69ea51-7afb-32dd-0000-000000000000</groupId> | |
<id>3d9b79ad-00bc-3a00-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>0</labelIndex> | |
<name></name> | |
<source> | |
<groupId>0b69ea51-7afb-32dd-0000-000000000000</groupId> | |
<id>ece7f336-0730-34f1-0000-000000000000</id> | |
<type>INPUT_PORT</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>5bb57af4-206d-3818-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>17face53-7205-3533-0000-000000000000</groupId> | |
<id>86bd55f2-628d-3879-0000-000000000000</id> | |
<type>INPUT_PORT</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>PJA</selectedRelationships> | |
<source> | |
<groupId>0b69ea51-7afb-32dd-0000-000000000000</groupId> | |
<id>d0258284-69ae-34f6-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>696d02a6-6470-3735-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<bends> | |
<x>-250.29998779296875</x> | |
<y>-440.79998779296875</y> | |
</bends> | |
<destination> | |
<groupId>0b69ea51-7afb-32dd-0000-000000000000</groupId> | |
<id>b2227964-13f7-322e-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>0</labelIndex> | |
<name></name> | |
<selectedRelationships>status</selectedRelationships> | |
<source> | |
<groupId>0b69ea51-7afb-32dd-0000-000000000000</groupId> | |
<id>3d9b79ad-00bc-3a00-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>b393ce35-4fc1-3682-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<bends> | |
<x>141.70001220703125</x> | |
<y>-567.7999877929688</y> | |
</bends> | |
<destination> | |
<groupId>0b69ea51-7afb-32dd-0000-000000000000</groupId> | |
<id>d0258284-69ae-34f6-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>0</labelIndex> | |
<name></name> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>0b69ea51-7afb-32dd-0000-000000000000</groupId> | |
<id>b2227964-13f7-322e-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>b58e602b-7848-3bdc-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>b7eb8663-a8b2-3673-0000-000000000000</groupId> | |
<id>2bb343c1-b975-3a4b-0000-000000000000</id> | |
<type>INPUT_PORT</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>PJB</selectedRelationships> | |
<source> | |
<groupId>0b69ea51-7afb-32dd-0000-000000000000</groupId> | |
<id>d0258284-69ae-34f6-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>d3e56e0f-e0f6-34bc-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<bends> | |
<x>-262.29998779296875</x> | |
<y>-729.7999877929688</y> | |
</bends> | |
<destination> | |
<groupId>0b69ea51-7afb-32dd-0000-000000000000</groupId> | |
<id>9e38cb88-668a-3f52-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>0</labelIndex> | |
<name></name> | |
<selectedRelationships>bulletins</selectedRelationships> | |
<source> | |
<groupId>0b69ea51-7afb-32dd-0000-000000000000</groupId> | |
<id>3d9b79ad-00bc-3a00-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<controllerServices> | |
<id>16a0eed9-bc9c-341e-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-record-serialization-services-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<descriptors> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value> | |
<name>schema-access-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
<name>schema-registry</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value> | |
<name>schema-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
<value> | |
<name>schema-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
<value> | |
<name>schema-branch</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value> | |
<name>schema-text</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>AvroReader</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>schema-access-strategy</key> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.avro.AvroReader</type> | |
</controllerServices> | |
<controllerServices> | |
<id>64982b71-baeb-3574-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-registry-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<comments></comments> | |
<descriptors> | |
<entry> | |
<key>avro-reg-validated-field-names</key> | |
<value> | |
<name>avro-reg-validated-field-names</name> | |
</value> | |
</entry> | |
<entry> | |
<key>SiteToSiteBulletinReportingTask</key> | |
<value> | |
<name>SiteToSiteBulletinReportingTask</name> | |
</value> | |
</entry> | |
<entry> | |
<key>SiteToSiteStatusReportingTask</key> | |
<value> | |
<name>SiteToSiteStatusReportingTask</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>AvroSchemaRegistry</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>avro-reg-validated-field-names</key> | |
</entry> | |
<entry> | |
<key>SiteToSiteBulletinReportingTask</key> | |
<value>{ | |
"type" : "record", | |
"name" : "bulletins", | |
"namespace" : "bulletins", | |
"fields" : [ | |
{ "name" : "objectId", "type" : "string" }, | |
{ "name" : "platform", "type" : "string" }, | |
{ "name" : "project", "type" : "string" }, | |
{ "name" : "bulletinId", "type" : "long" }, | |
{ "name" : "bulletinCategory", "type" : ["string", "null"] }, | |
{ "name" : "bulletinGroupId", "type" : ["string", "null"] }, | |
{ "name" : "bulletinGroupName", "type" : ["string", "null"] }, | |
{ "name" : "bulletinLevel", "type" : ["string", "null"] }, | |
{ "name" : "bulletinMessage", "type" : ["string", "null"] }, | |
{ "name" : "bulletinNodeAddress", "type" : ["string", "null"] }, | |
{ "name" : "bulletinNodeId", "type" : ["string", "null"] }, | |
{ "name" : "bulletinSourceId", "type" : ["string", "null"] }, | |
{ "name" : "bulletinSourceName", "type" : ["string", "null"] }, | |
{ "name" : "bulletinSourceType", "type" : ["string", "null"] }, | |
{ "name" : "bulletinTimestamp", "type" : ["string", "null"], "doc" : "Format: yyyy-MM-dd'T'HH:mm:ss.SSS'Z'" } | |
] | |
}</value> | |
</entry> | |
<entry> | |
<key>SiteToSiteStatusReportingTask</key> | |
<value>{ | |
"type" : "record", | |
"name" : "status", | |
"namespace" : "status", | |
"fields" : [ | |
// common fields for all components | |
{ "name" : "statusId", "type" : "string"}, | |
{ "name" : "timestampMillis", "type": { "type": "long", "logicalType": "timestamp-millis" } }, | |
{ "name" : "timestamp", "type" : "string"}, | |
{ "name" : "actorHostname", "type" : "string"}, | |
{ "name" : "componentType", "type" : "string"}, | |
{ "name" : "componentName", "type" : "string"}, | |
{ "name" : "parentId", "type" : ["string", "null"]}, | |
{ "name" : "platform", "type" : "string"}, | |
{ "name" : "application", "type" : "string"}, | |
{ "name" : "componentId", "type" : "string"}, | |
{ "name" : "project", "type" : "string"}, | |
// PG + RPG + Ports + Processors | |
{ "name" : "activeThreadCount", "type" : ["long", "null"]}, | |
// PG + Ports + Processors | |
{ "name" : "flowFilesReceived", "type" : ["long", "null"]}, | |
{ "name" : "flowFilesSent", "type" : ["long", "null"]}, | |
// PG + Ports + Processors | |
{ "name" : "bytesReceived", "type" : ["long", "null"]}, | |
{ "name" : "bytesSent", "type" : ["long", "null"]}, | |
// PG + Connections | |
{ "name" : "queuedCount", "type" : ["long", "null"]}, | |
// PG + Processors | |
{ "name" : "bytesRead", "type" : ["long", "null"]}, | |
{ "name" : "bytesWritten", "type" : ["long", "null"]}, | |
// fields for process group status | |
{ "name" : "bytesTransferred", "type" : ["long", "null"]}, | |
{ "name" : "flowFilesTransferred", "type" : ["long", "null"]}, | |
{ "name" : "inputContentSize", "type" : ["long", "null"]}, | |
{ "name" : "outputContentSize", "type" : ["long", "null"]}, | |
{ "name" : "queuedContentSize", "type" : ["long", "null"]}, | |
// fields for remote process groups | |
{ "name" : "activeRemotePortCount", "type" : ["long", "null"]}, | |
{ "name" : "inactiveRemotePortCount", "type" : ["long", "null"]}, | |
{ "name" : "receivedContentSize", "type" : ["long", "null"]}, | |
{ "name" : "receivedCount", "type" : ["long", "null"]}, | |
{ "name" : "sentContentSize", "type" : ["long", "null"]}, | |
{ "name" : "sentCount", "type" : ["long", "null"]}, | |
{ "name" : "averageLineageDuration", "type" : ["long", "null"]}, | |
// fields for input/output ports + connections + PG | |
{ "name" : "inputBytes", "type" : ["long", "null"]}, | |
{ "name" : "inputCount", "type" : ["long", "null"]}, | |
{ "name" : "outputBytes", "type" : ["long", "null"]}, | |
{ "name" : "outputCount", "type" : ["long", "null"]}, | |
// fields for connections | |
{ "name" : "sourceId", "type" : ["string", "null"]}, | |
{ "name" : "sourceName", "type" : ["string", "null"]}, | |
{ "name" : "destinationId", "type" : ["string", "null"]}, | |
{ "name" : "destinationName", "type" : ["string", "null"]}, | |
{ "name" : "maxQueuedBytes", "type" : ["long", "null"]}, | |
{ "name" : "maxQueuedCount", "type" : ["long", "null"]}, | |
{ "name" : "queuedBytes", "type" : ["long", "null"]}, | |
{ "name" : "backPressureBytesThreshold", "type" : ["long", "null"]}, | |
{ "name" : "backPressureObjectThreshold", "type" : ["long", "null"]}, | |
{ "name" : "isBackPressureEnabled", "type" : ["string", "null"]}, | |
// fields for processors | |
{ "name" : "processorType", "type" : ["string", "null"]}, | |
{ "name" : "averageLineageDurationMS", "type" : ["long", "null"]}, | |
{ "name" : "flowFilesRemoved", "type" : ["long", "null"]}, | |
{ "name" : "invocations", "type" : ["long", "null"]}, | |
{ "name" : "processingNanos", "type" : ["long", "null"]} | |
] | |
}</value> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.schemaregistry.services.AvroSchemaRegistry</type> | |
</controllerServices> | |
<controllerServices> | |
<id>9ddcfcf0-272b-3de6-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-record-serialization-services-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<comments></comments> | |
<descriptors> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value> | |
<name>schema-access-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
<name>schema-registry</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value> | |
<name>schema-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
<value> | |
<name>schema-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
<value> | |
<name>schema-branch</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value> | |
<name>schema-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
<value> | |
<name>Date Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
<value> | |
<name>Time Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
<value> | |
<name>Timestamp Format</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>JsonTreeReader</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>schema-access-strategy</key> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value>64982b71-baeb-3574-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value>${reporting.task.type}</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.json.JsonTreeReader</type> | |
</controllerServices> | |
<controllerServices> | |
<id>c591e41d-4a92-3022-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-record-serialization-services-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<comments></comments> | |
<descriptors> | |
<entry> | |
<key>Schema Write Strategy</key> | |
<value> | |
<name>Schema Write Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value> | |
<name>schema-access-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
<name>schema-registry</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value> | |
<name>schema-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
<value> | |
<name>schema-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
<value> | |
<name>schema-branch</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value> | |
<name>schema-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
<value> | |
<name>Date Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
<value> | |
<name>Time Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
<value> | |
<name>Timestamp Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Pretty Print JSON</key> | |
<value> | |
<name>Pretty Print JSON</name> | |
</value> | |
</entry> | |
<entry> | |
<key>suppress-nulls</key> | |
<value> | |
<name>suppress-nulls</name> | |
</value> | |
</entry> | |
<entry> | |
<key>output-grouping</key> | |
<value> | |
<name>output-grouping</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>JsonRecordSetWriter</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>Schema Write Strategy</key> | |
<value>no-schema</value> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value>schema-name</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value>64982b71-baeb-3574-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value>${reporting.task.type}</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
</entry> | |
<entry> | |
<key>Pretty Print JSON</key> | |
</entry> | |
<entry> | |
<key>suppress-nulls</key> | |
</entry> | |
<entry> | |
<key>output-grouping</key> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.json.JsonRecordSetWriter</type> | |
</controllerServices> | |
<inputPorts> | |
<id>ece7f336-0730-34f1-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<position> | |
<x>-754.7839389648434</x> | |
<y>-454.08401831054675</y> | |
</position> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<name>monitoring</name> | |
<state>RUNNING</state> | |
<type>INPUT_PORT</type> | |
</inputPorts> | |
<processGroups> | |
<id>08502007-64bf-3e4d-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<position> | |
<x>-299.29998779296875</x> | |
<y>-278.8000030517578</y> | |
</position> | |
<comments></comments> | |
<contents> | |
<connections> | |
<id>b3a32ea2-5dab-3f38-0000-000000000000</id> | |
<parentGroupId>08502007-64bf-3e4d-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>08502007-64bf-3e4d-0000-000000000000</groupId> | |
<id>47308060-9956-3c32-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<source> | |
<groupId>08502007-64bf-3e4d-0000-000000000000</groupId> | |
<id>2122a525-8179-33aa-0000-000000000000</id> | |
<type>INPUT_PORT</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<inputPorts> | |
<id>2122a525-8179-33aa-0000-000000000000</id> | |
<parentGroupId>08502007-64bf-3e4d-0000-000000000000</parentGroupId> | |
<position> | |
<x>-719.2999877929688</x> | |
<y>-470.8000030517578</y> | |
</position> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<name>data</name> | |
<state>RUNNING</state> | |
<type>INPUT_PORT</type> | |
</inputPorts> | |
<processors> | |
<id>47308060-9956-3c32-0000-000000000000</id> | |
<parentGroupId>08502007-64bf-3e4d-0000-000000000000</parentGroupId> | |
<position> | |
<x>-131.29998779296875</x> | |
<y>-497.8000030517578</y> | |
</position> | |
<bundle> | |
<artifact>nifi-update-attribute-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Delete Attributes Expression</key> | |
<value> | |
<name>Delete Attributes Expression</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Store State</key> | |
<value> | |
<name>Store State</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Stateful Variables Initial Value</key> | |
<value> | |
<name>Stateful Variables Initial Value</name> | |
</value> | |
</entry> | |
<entry> | |
<key>update-attribute-failure-behavior</key> | |
<value> | |
<name>update-attribute-failure-behavior</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Delete Attributes Expression</key> | |
</entry> | |
<entry> | |
<key>Store State</key> | |
<value>Do not store state</value> | |
</entry> | |
<entry> | |
<key>Stateful Variables Initial Value</key> | |
</entry> | |
<entry> | |
<key>update-attribute-failure-behavior</key> | |
<value>penalize</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>UpdateAttribute</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>RUNNING</state> | |
<style/> | |
<type>org.apache.nifi.processors.attributes.UpdateAttribute</type> | |
</processors> | |
</contents> | |
<name>Technical Monitoring</name> | |
<variables/> | |
</processGroups> | |
<processGroups> | |
<id>17face53-7205-3533-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<position> | |
<x>930.7000732421875</x> | |
<y>-766.8000030517578</y> | |
</position> | |
<comments></comments> | |
<contents> | |
<inputPorts> | |
<id>86bd55f2-628d-3879-0000-000000000000</id> | |
<parentGroupId>17face53-7205-3533-0000-000000000000</parentGroupId> | |
<position> | |
<x>263.70001220703125</x> | |
<y>-770.8000030517578</y> | |
</position> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<name>monitoring</name> | |
<state>STOPPED</state> | |
<type>INPUT_PORT</type> | |
<validationErrors>'Port 'monitoring'' is invalid because Output connection for port 'monitoring' is not defined.</validationErrors> | |
</inputPorts> | |
</contents> | |
<name>PJA_Monitoring Workflow</name> | |
<variables/> | |
</processGroups> | |
<processGroups> | |
<id>b7eb8663-a8b2-3673-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<position> | |
<x>929.7000732421875</x> | |
<y>-568.8000030517578</y> | |
</position> | |
<comments></comments> | |
<contents> | |
<inputPorts> | |
<id>2bb343c1-b975-3a4b-0000-000000000000</id> | |
<parentGroupId>b7eb8663-a8b2-3673-0000-000000000000</parentGroupId> | |
<position> | |
<x>263.70001220703125</x> | |
<y>-770.8000030517578</y> | |
</position> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<name>monitoring</name> | |
<state>STOPPED</state> | |
<type>INPUT_PORT</type> | |
<validationErrors>'Port 'monitoring'' is invalid because Output connection for port 'monitoring' is not defined.</validationErrors> | |
</inputPorts> | |
</contents> | |
<name>PJB_Monitoring Workflow</name> | |
<variables/> | |
</processGroups> | |
<processors> | |
<id>3d9b79ad-00bc-3a00-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<position> | |
<x>-499.29998779296875</x> | |
<y>-653.8000030517578</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Routing Strategy</key> | |
<value> | |
<name>Routing Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>bulletins</key> | |
<value> | |
<name>bulletins</name> | |
</value> | |
</entry> | |
<entry> | |
<key>status</key> | |
<value> | |
<name>status</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Routing Strategy</key> | |
<value>Route to Property name</value> | |
</entry> | |
<entry> | |
<key>bulletins</key> | |
<value>${reporting.task.type:equals('SiteToSiteBulletinReportingTask')}</value> | |
</entry> | |
<entry> | |
<key>status</key> | |
<value>${reporting.task.type:equals('SiteToSiteStatusReportingTask')}</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>RouteOnAttribute</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>bulletins</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>status</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>unmatched</name> | |
</relationships> | |
<state>RUNNING</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.RouteOnAttribute</type> | |
</processors> | |
<processors> | |
<id>9e38cb88-668a-3f52-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<position> | |
<x>-108.29998779296875</x> | |
<y>-794.8000030517578</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>replacement-value-strategy</key> | |
<value> | |
<name>replacement-value-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>/project</key> | |
<value> | |
<name>/project</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>record-reader</key> | |
<value>16a0eed9-bc9c-341e-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>c591e41d-4a92-3022-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>replacement-value-strategy</key> | |
<value>record-path-value</value> | |
</entry> | |
<entry> | |
<key>/project</key> | |
<value>substringBefore(/bulletinSourceName, '_')</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>UpdateRecord</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.UpdateRecord</type> | |
</processors> | |
<processors> | |
<id>b2227964-13f7-322e-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<position> | |
<x>-109.29998779296875</x> | |
<y>-516.8000030517578</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>replacement-value-strategy</key> | |
<value> | |
<name>replacement-value-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>/project</key> | |
<value> | |
<name>/project</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>record-reader</key> | |
<value>16a0eed9-bc9c-341e-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>c591e41d-4a92-3022-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>replacement-value-strategy</key> | |
<value>record-path-value</value> | |
</entry> | |
<entry> | |
<key>/project</key> | |
<value>substringBefore(/componentName, '_')</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>UpdateRecord</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>RUNNING</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.UpdateRecord</type> | |
</processors> | |
<processors> | |
<id>d0258284-69ae-34f6-0000-000000000000</id> | |
<parentGroupId>0b69ea51-7afb-32dd-0000-000000000000</parentGroupId> | |
<position> | |
<x>340.70001220703125</x> | |
<y>-652.8000030517578</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>include-zero-record-flowfiles</key> | |
<value> | |
<name>include-zero-record-flowfiles</name> | |
</value> | |
</entry> | |
<entry> | |
<key>cache-schema</key> | |
<value> | |
<name>cache-schema</name> | |
</value> | |
</entry> | |
<entry> | |
<key>PJA</key> | |
<value> | |
<name>PJA</name> | |
</value> | |
</entry> | |
<entry> | |
<key>PJB</key> | |
<value> | |
<name>PJB</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>record-reader</key> | |
<value>9ddcfcf0-272b-3de6-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>c591e41d-4a92-3022-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>include-zero-record-flowfiles</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>cache-schema</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>PJA</key> | |
<value>SELECT * | |
FROM FLOWFILE | |
WHERE project = 'PJA'</value> | |
</entry> | |
<entry> | |
<key>PJB</key> | |
<value>SELECT * | |
FROM FLOWFILE | |
WHERE project = 'PJB'</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>QueryRecord</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>original</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>PJA</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>PJB</name> | |
</relationships> | |
<state>RUNNING</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.QueryRecord</type> | |
</processors> | |
</contents> | |
<name>Monitoring</name> | |
<variables/> | |
</processGroups> | |
<processGroups> | |
<id>577902c1-24ab-3e1c-0000-000000000000</id> | |
<parentGroupId>a8352767-434f-3321-0000-000000000000</parentGroupId> | |
<position> | |
<x>137.60604418945297</x> | |
<y>286.4846572265624</y> | |
</position> | |
<comments></comments> | |
<contents> | |
<connections> | |
<id>04e1965f-218d-3d0a-0000-000000000000</id> | |
<parentGroupId>577902c1-24ab-3e1c-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<bends> | |
<x>494.3499755859375</x> | |
<y>-475.38330078125</y> | |
</bends> | |
<destination> | |
<groupId>577902c1-24ab-3e1c-0000-000000000000</groupId> | |
<id>40c162e2-cc33-3327-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>0</labelIndex> | |
<name></name> | |
<selectedRelationships>failure</selectedRelationships> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>577902c1-24ab-3e1c-0000-000000000000</groupId> | |
<id>342d0fae-bff5-3c53-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>3f920364-3aa6-3735-0000-000000000000</id> | |
<parentGroupId>577902c1-24ab-3e1c-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>577902c1-24ab-3e1c-0000-000000000000</groupId> | |
<id>f9a7dcd4-4e69-3f60-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name>PJA_failure</name> | |
<selectedRelationships>failure</selectedRelationships> | |
<source> | |
<groupId>577902c1-24ab-3e1c-0000-000000000000</groupId> | |
<id>81a7ac67-e61c-3a70-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>52ce82bc-0c6c-3155-0000-000000000000</id> | |
<parentGroupId>577902c1-24ab-3e1c-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<bends> | |
<x>140.35000610351562</x> | |
<y>-68.88333129882812</y> | |
</bends> | |
<destination> | |
<groupId>577902c1-24ab-3e1c-0000-000000000000</groupId> | |
<id>f9a7dcd4-4e69-3f60-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name>PJA_valid</name> | |
<selectedRelationships>valid</selectedRelationships> | |
<source> | |
<groupId>577902c1-24ab-3e1c-0000-000000000000</groupId> | |
<id>81a7ac67-e61c-3a70-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>5cb43758-f987-3d62-0000-000000000000</id> | |
<parentGroupId>577902c1-24ab-3e1c-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<bends> | |
<x>192.35000610351562</x> | |
<y>-219.88333129882812</y> | |
</bends> | |
<destination> | |
<groupId>577902c1-24ab-3e1c-0000-000000000000</groupId> | |
<id>f9a7dcd4-4e69-3f60-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name>PJA_invalid</name> | |
<selectedRelationships>invalid</selectedRelationships> | |
<source> | |
<groupId>577902c1-24ab-3e1c-0000-000000000000</groupId> | |
<id>81a7ac67-e61c-3a70-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>6476c57f-016c-32b3-0000-000000000000</id> | |
<parentGroupId>577902c1-24ab-3e1c-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>577902c1-24ab-3e1c-0000-000000000000</groupId> | |
<id>81a7ac67-e61c-3a70-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>577902c1-24ab-3e1c-0000-000000000000</groupId> | |
<id>5772729b-f758-36bf-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>f9226622-3b2d-38be-0000-000000000000</id> | |
<parentGroupId>577902c1-24ab-3e1c-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>577902c1-24ab-3e1c-0000-000000000000</groupId> | |
<id>342d0fae-bff5-3c53-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>failure</selectedRelationships> | |
<selectedRelationships>invalid</selectedRelationships> | |
<selectedRelationships>valid</selectedRelationships> | |
<source> | |
<groupId>577902c1-24ab-3e1c-0000-000000000000</groupId> | |
<id>81a7ac67-e61c-3a70-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<processors> | |
<id>342d0fae-bff5-3c53-0000-000000000000</id> | |
<parentGroupId>577902c1-24ab-3e1c-0000-000000000000</parentGroupId> | |
<position> | |
<x>126.35000610351562</x> | |
<y>-436.3833312988281</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Regular Expression</key> | |
<value> | |
<name>Regular Expression</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Replacement Value</key> | |
<value> | |
<name>Replacement Value</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Character Set</key> | |
<value> | |
<name>Character Set</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Maximum Buffer Size</key> | |
<value> | |
<name>Maximum Buffer Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Replacement Strategy</key> | |
<value> | |
<name>Replacement Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Evaluation Mode</key> | |
<value> | |
<name>Evaluation Mode</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Regular Expression</key> | |
<value>(?s)(^.*$)</value> | |
</entry> | |
<entry> | |
<key>Replacement Value</key> | |
<value>$1</value> | |
</entry> | |
<entry> | |
<key>Character Set</key> | |
<value>UTF-8</value> | |
</entry> | |
<entry> | |
<key>Maximum Buffer Size</key> | |
<value>1 MB</value> | |
</entry> | |
<entry> | |
<key>Replacement Strategy</key> | |
<value>Regex Replace</value> | |
</entry> | |
<entry> | |
<key>Evaluation Mode</key> | |
<value>Entire text</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>PJA_Generate HTTP Response Content</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.ReplaceText</type> | |
</processors> | |
<processors> | |
<id>40c162e2-cc33-3327-0000-000000000000</id> | |
<parentGroupId>577902c1-24ab-3e1c-0000-000000000000</parentGroupId> | |
<position> | |
<x>504.3500061035156</x> | |
<y>-438.3833312988281</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>HTTP Status Code</key> | |
<value> | |
<name>HTTP Status Code</name> | |
</value> | |
</entry> | |
<entry> | |
<key>HTTP Context Map</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.http.HttpContextMap</identifiesControllerService> | |
<name>HTTP Context Map</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>HTTP Status Code</key> | |
</entry> | |
<entry> | |
<key>HTTP Context Map</key> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>PJA_HTTP Response</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.HandleHttpResponse</type> | |
</processors> | |
<processors> | |
<id>5772729b-f758-36bf-0000-000000000000</id> | |
<parentGroupId>577902c1-24ab-3e1c-0000-000000000000</parentGroupId> | |
<position> | |
<x>-458.6499938964844</x> | |
<y>-488.3833312988281</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Listening Port</key> | |
<value> | |
<name>Listening Port</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Hostname</key> | |
<value> | |
<name>Hostname</name> | |
</value> | |
</entry> | |
<entry> | |
<key>SSL Context Service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.ssl.RestrictedSSLContextService</identifiesControllerService> | |
<name>SSL Context Service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>HTTP Context Map</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.http.HttpContextMap</identifiesControllerService> | |
<name>HTTP Context Map</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Allowed Paths</key> | |
<value> | |
<name>Allowed Paths</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Default URL Character Set</key> | |
<value> | |
<name>Default URL Character Set</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Allow GET</key> | |
<value> | |
<name>Allow GET</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Allow POST</key> | |
<value> | |
<name>Allow POST</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Allow PUT</key> | |
<value> | |
<name>Allow PUT</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Allow DELETE</key> | |
<value> | |
<name>Allow DELETE</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Allow HEAD</key> | |
<value> | |
<name>Allow HEAD</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Allow OPTIONS</key> | |
<value> | |
<name>Allow OPTIONS</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Additional HTTP Methods</key> | |
<value> | |
<name>Additional HTTP Methods</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Client Authentication</key> | |
<value> | |
<name>Client Authentication</name> | |
</value> | |
</entry> | |
<entry> | |
<key>container-queue-size</key> | |
<value> | |
<name>container-queue-size</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Listening Port</key> | |
<value>80</value> | |
</entry> | |
<entry> | |
<key>Hostname</key> | |
</entry> | |
<entry> | |
<key>SSL Context Service</key> | |
</entry> | |
<entry> | |
<key>HTTP Context Map</key> | |
</entry> | |
<entry> | |
<key>Allowed Paths</key> | |
</entry> | |
<entry> | |
<key>Default URL Character Set</key> | |
<value>UTF-8</value> | |
</entry> | |
<entry> | |
<key>Allow GET</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Allow POST</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Allow PUT</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Allow DELETE</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Allow HEAD</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Allow OPTIONS</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Additional HTTP Methods</key> | |
</entry> | |
<entry> | |
<key>Client Authentication</key> | |
<value>No Authentication</value> | |
</entry> | |
<entry> | |
<key>container-queue-size</key> | |
<value>50</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>PJA_Receive HTTP requests</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.HandleHttpRequest</type> | |
</processors> | |
<processors> | |
<id>81a7ac67-e61c-3a70-0000-000000000000</id> | |
<parentGroupId>577902c1-24ab-3e1c-0000-000000000000</parentGroupId> | |
<position> | |
<x>-453.6499938964844</x> | |
<y>-290.3833312988281</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>invalid-record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>invalid-record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value> | |
<name>schema-access-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
<name>schema-registry</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value> | |
<name>schema-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value> | |
<name>schema-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>allow-extra-fields</key> | |
<value> | |
<name>allow-extra-fields</name> | |
</value> | |
</entry> | |
<entry> | |
<key>strict-type-checking</key> | |
<value> | |
<name>strict-type-checking</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>record-reader</key> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
</entry> | |
<entry> | |
<key>invalid-record-writer</key> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value>reader-schema</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value>${schema.name}</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value>${avro.schema}</value> | |
</entry> | |
<entry> | |
<key>allow-extra-fields</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>strict-type-checking</key> | |
<value>true</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>PJA_Validate XML Data</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>invalid</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>valid</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.ValidateRecord</type> | |
</processors> | |
<processors> | |
<id>f9a7dcd4-4e69-3f60-0000-000000000000</id> | |
<parentGroupId>577902c1-24ab-3e1c-0000-000000000000</parentGroupId> | |
<position> | |
<x>457.3500061035156</x> | |
<y>-129.38333129882812</y> | |
</position> | |
<bundle> | |
<artifact>nifi-hadoop-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Hadoop Configuration Resources</key> | |
<value> | |
<name>Hadoop Configuration Resources</name> | |
</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.kerberos.KerberosCredentialsService</identifiesControllerService> | |
<name>kerberos-credentials-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Kerberos Principal</key> | |
<value> | |
<name>Kerberos Principal</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Kerberos Keytab</key> | |
<value> | |
<name>Kerberos Keytab</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Kerberos Relogin Period</key> | |
<value> | |
<name>Kerberos Relogin Period</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Additional Classpath Resources</key> | |
<value> | |
<name>Additional Classpath Resources</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Directory</key> | |
<value> | |
<name>Directory</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Conflict Resolution Strategy</key> | |
<value> | |
<name>Conflict Resolution Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Block Size</key> | |
<value> | |
<name>Block Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>IO Buffer Size</key> | |
<value> | |
<name>IO Buffer Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Replication</key> | |
<value> | |
<name>Replication</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Permissions umask</key> | |
<value> | |
<name>Permissions umask</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Remote Owner</key> | |
<value> | |
<name>Remote Owner</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Remote Group</key> | |
<value> | |
<name>Remote Group</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Compression codec</key> | |
<value> | |
<name>Compression codec</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Hadoop Configuration Resources</key> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
</entry> | |
<entry> | |
<key>Kerberos Principal</key> | |
</entry> | |
<entry> | |
<key>Kerberos Keytab</key> | |
</entry> | |
<entry> | |
<key>Kerberos Relogin Period</key> | |
<value>4 hours</value> | |
</entry> | |
<entry> | |
<key>Additional Classpath Resources</key> | |
</entry> | |
<entry> | |
<key>Directory</key> | |
</entry> | |
<entry> | |
<key>Conflict Resolution Strategy</key> | |
<value>fail</value> | |
</entry> | |
<entry> | |
<key>Block Size</key> | |
</entry> | |
<entry> | |
<key>IO Buffer Size</key> | |
</entry> | |
<entry> | |
<key>Replication</key> | |
</entry> | |
<entry> | |
<key>Permissions umask</key> | |
</entry> | |
<entry> | |
<key>Remote Owner</key> | |
</entry> | |
<entry> | |
<key>Remote Group</key> | |
</entry> | |
<entry> | |
<key>Compression codec</key> | |
<value>NONE</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>PJA_Store Data into HDFS</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.hadoop.PutHDFS</type> | |
</processors> | |
</contents> | |
<name>PJA_Core workflow for my Project A</name> | |
<variables/> | |
</processGroups> | |
<processGroups> | |
<id>d0f36122-1977-360e-0000-000000000000</id> | |
<parentGroupId>a8352767-434f-3321-0000-000000000000</parentGroupId> | |
<position> | |
<x>582.606044189453</x> | |
<y>287.4846572265624</y> | |
</position> | |
<comments></comments> | |
<contents> | |
<connections> | |
<id>19b7ee21-ffdd-3366-0000-000000000000</id> | |
<parentGroupId>d0f36122-1977-360e-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>d0f36122-1977-360e-0000-000000000000</groupId> | |
<id>0e9aa985-c7c9-320a-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>failure</selectedRelationships> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>d0f36122-1977-360e-0000-000000000000</groupId> | |
<id>7cafd969-e4a6-3231-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>378cf2bb-4dc0-37a7-0000-000000000000</id> | |
<parentGroupId>d0f36122-1977-360e-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<bends> | |
<x>247.85000610351562</x> | |
<y>-453.3833312988281</y> | |
</bends> | |
<bends> | |
<x>303.8500061035156</x> | |
<y>-459.3833312988281</y> | |
</bends> | |
<destination> | |
<groupId>d0f36122-1977-360e-0000-000000000000</groupId> | |
<id>7cafd969-e4a6-3231-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>retry</selectedRelationships> | |
<source> | |
<groupId>d0f36122-1977-360e-0000-000000000000</groupId> | |
<id>7cafd969-e4a6-3231-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>72aa6d8e-293c-332c-0000-000000000000</id> | |
<parentGroupId>d0f36122-1977-360e-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>d0f36122-1977-360e-0000-000000000000</groupId> | |
<id>d9df3dca-31a8-3a52-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>d0f36122-1977-360e-0000-000000000000</groupId> | |
<id>259b40d0-ae30-3835-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>917c3bb6-53b1-390e-0000-000000000000</id> | |
<parentGroupId>d0f36122-1977-360e-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>d0f36122-1977-360e-0000-000000000000</groupId> | |
<id>7cafd969-e4a6-3231-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>merged</selectedRelationships> | |
<source> | |
<groupId>d0f36122-1977-360e-0000-000000000000</groupId> | |
<id>d9df3dca-31a8-3a52-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>d4f4e56e-af40-34e4-0000-000000000000</id> | |
<parentGroupId>d0f36122-1977-360e-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>d0f36122-1977-360e-0000-000000000000</groupId> | |
<id>0e9aa985-c7c9-320a-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>failure</selectedRelationships> | |
<source> | |
<groupId>d0f36122-1977-360e-0000-000000000000</groupId> | |
<id>d9df3dca-31a8-3a52-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<processors> | |
<id>0e9aa985-c7c9-320a-0000-000000000000</id> | |
<parentGroupId>d0f36122-1977-360e-0000-000000000000</parentGroupId> | |
<position> | |
<x>172.85000610351562</x> | |
<y>-127.38333129882812</y> | |
</position> | |
<bundle> | |
<artifact>nifi-hadoop-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Hadoop Configuration Resources</key> | |
<value> | |
<name>Hadoop Configuration Resources</name> | |
</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.kerberos.KerberosCredentialsService</identifiesControllerService> | |
<name>kerberos-credentials-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Kerberos Principal</key> | |
<value> | |
<name>Kerberos Principal</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Kerberos Keytab</key> | |
<value> | |
<name>Kerberos Keytab</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Kerberos Relogin Period</key> | |
<value> | |
<name>Kerberos Relogin Period</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Additional Classpath Resources</key> | |
<value> | |
<name>Additional Classpath Resources</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Directory</key> | |
<value> | |
<name>Directory</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Conflict Resolution Strategy</key> | |
<value> | |
<name>Conflict Resolution Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Block Size</key> | |
<value> | |
<name>Block Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>IO Buffer Size</key> | |
<value> | |
<name>IO Buffer Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Replication</key> | |
<value> | |
<name>Replication</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Permissions umask</key> | |
<value> | |
<name>Permissions umask</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Remote Owner</key> | |
<value> | |
<name>Remote Owner</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Remote Group</key> | |
<value> | |
<name>Remote Group</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Compression codec</key> | |
<value> | |
<name>Compression codec</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Hadoop Configuration Resources</key> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
</entry> | |
<entry> | |
<key>Kerberos Principal</key> | |
</entry> | |
<entry> | |
<key>Kerberos Keytab</key> | |
</entry> | |
<entry> | |
<key>Kerberos Relogin Period</key> | |
<value>4 hours</value> | |
</entry> | |
<entry> | |
<key>Additional Classpath Resources</key> | |
</entry> | |
<entry> | |
<key>Directory</key> | |
</entry> | |
<entry> | |
<key>Conflict Resolution Strategy</key> | |
<value>fail</value> | |
</entry> | |
<entry> | |
<key>Block Size</key> | |
</entry> | |
<entry> | |
<key>IO Buffer Size</key> | |
</entry> | |
<entry> | |
<key>Replication</key> | |
</entry> | |
<entry> | |
<key>Permissions umask</key> | |
</entry> | |
<entry> | |
<key>Remote Owner</key> | |
</entry> | |
<entry> | |
<key>Remote Group</key> | |
</entry> | |
<entry> | |
<key>Compression codec</key> | |
<value>NONE</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>PJA_HDFS long-term archiving</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.hadoop.PutHDFS</type> | |
</processors> | |
<processors> | |
<id>259b40d0-ae30-3835-0000-000000000000</id> | |
<parentGroupId>d0f36122-1977-360e-0000-000000000000</parentGroupId> | |
<position> | |
<x>-595.6499938964844</x> | |
<y>-457.3833312988281</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Local Network Interface</key> | |
<value> | |
<name>Local Network Interface</name> | |
</value> | |
</entry> | |
<entry> | |
<key>port</key> | |
<value> | |
<name>port</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-size-socket-buffer</key> | |
<value> | |
<name>max-size-socket-buffer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-number-tcp-connections</key> | |
<value> | |
<name>max-number-tcp-connections</name> | |
</value> | |
</entry> | |
<entry> | |
<key>read-timeout</key> | |
<value> | |
<name>read-timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>reader-error-handling-strategy</key> | |
<value> | |
<name>reader-error-handling-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-batch-size</key> | |
<value> | |
<name>record-batch-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ssl-context-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.ssl.RestrictedSSLContextService</identifiesControllerService> | |
<name>ssl-context-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>client-auth</key> | |
<value> | |
<name>client-auth</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Local Network Interface</key> | |
</entry> | |
<entry> | |
<key>port</key> | |
</entry> | |
<entry> | |
<key>max-size-socket-buffer</key> | |
<value>1 MB</value> | |
</entry> | |
<entry> | |
<key>max-number-tcp-connections</key> | |
<value>2</value> | |
</entry> | |
<entry> | |
<key>read-timeout</key> | |
<value>10 seconds</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
</entry> | |
<entry> | |
<key>reader-error-handling-strategy</key> | |
<value>Transfer</value> | |
</entry> | |
<entry> | |
<key>record-batch-size</key> | |
<value>1000</value> | |
</entry> | |
<entry> | |
<key>ssl-context-service</key> | |
</entry> | |
<entry> | |
<key>client-auth</key> | |
<value>REQUIRED</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>PJB_ListenTCPRecord Logs in JSON</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.ListenTCPRecord</type> | |
</processors> | |
<processors> | |
<id>7cafd969-e4a6-3231-0000-000000000000</id> | |
<parentGroupId>d0f36122-1977-360e-0000-000000000000</parentGroupId> | |
<position> | |
<x>163.85000610351562</x> | |
<y>-407.3833312988281</y> | |
</position> | |
<bundle> | |
<artifact>nifi-elasticsearch-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>elasticsearch-http-url</key> | |
<value> | |
<name>elasticsearch-http-url</name> | |
</value> | |
</entry> | |
<entry> | |
<key>SSL Context Service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService> | |
<name>SSL Context Service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Username</key> | |
<value> | |
<name>Username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Password</key> | |
<value> | |
<name>Password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>elasticsearch-http-connect-timeout</key> | |
<value> | |
<name>elasticsearch-http-connect-timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>elasticsearch-http-response-timeout</key> | |
<value> | |
<name>elasticsearch-http-response-timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.proxy.ProxyConfigurationService</identifiesControllerService> | |
<name>proxy-configuration-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>elasticsearch-http-proxy-host</key> | |
<value> | |
<name>elasticsearch-http-proxy-host</name> | |
</value> | |
</entry> | |
<entry> | |
<key>elasticsearch-http-proxy-port</key> | |
<value> | |
<name>elasticsearch-http-proxy-port</name> | |
</value> | |
</entry> | |
<entry> | |
<key>proxy-username</key> | |
<value> | |
<name>proxy-username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>proxy-password</key> | |
<value> | |
<name>proxy-password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>put-es-record-record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>put-es-record-record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>put-es-record-id-path</key> | |
<value> | |
<name>put-es-record-id-path</name> | |
</value> | |
</entry> | |
<entry> | |
<key>put-es-record-index</key> | |
<value> | |
<name>put-es-record-index</name> | |
</value> | |
</entry> | |
<entry> | |
<key>put-es-record-type</key> | |
<value> | |
<name>put-es-record-type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>put-es-record-index-op</key> | |
<value> | |
<name>put-es-record-index-op</name> | |
</value> | |
</entry> | |
<entry> | |
<key>suppress-nulls</key> | |
<value> | |
<name>suppress-nulls</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>elasticsearch-http-url</key> | |
</entry> | |
<entry> | |
<key>SSL Context Service</key> | |
</entry> | |
<entry> | |
<key>Username</key> | |
</entry> | |
<entry> | |
<key>Password</key> | |
</entry> | |
<entry> | |
<key>elasticsearch-http-connect-timeout</key> | |
<value>5 secs</value> | |
</entry> | |
<entry> | |
<key>elasticsearch-http-response-timeout</key> | |
<value>15 secs</value> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
</entry> | |
<entry> | |
<key>elasticsearch-http-proxy-host</key> | |
</entry> | |
<entry> | |
<key>elasticsearch-http-proxy-port</key> | |
</entry> | |
<entry> | |
<key>proxy-username</key> | |
</entry> | |
<entry> | |
<key>proxy-password</key> | |
</entry> | |
<entry> | |
<key>put-es-record-record-reader</key> | |
</entry> | |
<entry> | |
<key>put-es-record-id-path</key> | |
</entry> | |
<entry> | |
<key>put-es-record-index</key> | |
</entry> | |
<entry> | |
<key>put-es-record-type</key> | |
</entry> | |
<entry> | |
<key>put-es-record-index-op</key> | |
<value>index</value> | |
</entry> | |
<entry> | |
<key>suppress-nulls</key> | |
<value>never-suppress</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>PJA_ToElasticsearch</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>retry</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.elasticsearch.PutElasticsearchHttpRecord</type> | |
</processors> | |
<processors> | |
<id>d9df3dca-31a8-3a52-0000-000000000000</id> | |
<parentGroupId>d0f36122-1977-360e-0000-000000000000</parentGroupId> | |
<position> | |
<x>-595.6499938964844</x> | |
<y>-251.38333129882812</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.8.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>merge-strategy</key> | |
<value> | |
<name>merge-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>correlation-attribute-name</key> | |
<value> | |
<name>correlation-attribute-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Attribute Strategy</key> | |
<value> | |
<name>Attribute Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>min-records</key> | |
<value> | |
<name>min-records</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-records</key> | |
<value> | |
<name>max-records</name> | |
</value> | |
</entry> | |
<entry> | |
<key>min-bin-size</key> | |
<value> | |
<name>min-bin-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-bin-size</key> | |
<value> | |
<name>max-bin-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-bin-age</key> | |
<value> | |
<name>max-bin-age</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.bin.count</key> | |
<value> | |
<name>max.bin.count</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>record-reader</key> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
</entry> | |
<entry> | |
<key>merge-strategy</key> | |
<value>Bin-Packing Algorithm</value> | |
</entry> | |
<entry> | |
<key>correlation-attribute-name</key> | |
</entry> | |
<entry> | |
<key>Attribute Strategy</key> | |
<value>Keep Only Common Attributes</value> | |
</entry> | |
<entry> | |
<key>min-records</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>max-records</key> | |
<value>1000</value> | |
</entry> | |
<entry> | |
<key>min-bin-size</key> | |
<value>0 B</value> | |
</entry> | |
<entry> | |
<key>max-bin-size</key> | |
</entry> | |
<entry> | |
<key>max-bin-age</key> | |
</entry> | |
<entry> | |
<key>max.bin.count</key> | |
<value>10</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>PJA_MergeRecord</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>merged</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>original</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.MergeRecord</type> | |
</processors> | |
</contents> | |
<name>PJB_Core workflow for my Project B</name> | |
<variables/> | |
</processGroups> | |
</snippet> | |
<timestamp>08/29/2018 18:15:00 CEST</timestamp> | |
</template> |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment