|
<?xml version="1.0" ?> |
|
<template encoding-version="1.1"> |
|
<description></description> |
|
<groupId>e13efe89-015b-1000-9a4c-10881ee259c9</groupId> |
|
<name>Join CSV files 1.2.0</name> |
|
<snippet> |
|
<processGroups> |
|
<id>64c9eaeb-a756-303d-0000-000000000000</id> |
|
<parentGroupId>8925b4b3-f0af-3a75-0000-000000000000</parentGroupId> |
|
<position> |
|
<x>0.0</x> |
|
<y>0.0</y> |
|
</position> |
|
<comments></comments> |
|
<contents> |
|
<connections> |
|
<id>84cc86ff-2c8f-390d-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> |
|
<backPressureObjectThreshold>10000</backPressureObjectThreshold> |
|
<bends> |
|
<x>1657.5494384765625</x> |
|
<y>888.0894775390625</y> |
|
</bends> |
|
<destination> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>a0c07048-fb08-36a5-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</destination> |
|
<flowFileExpiration>0 sec</flowFileExpiration> |
|
<labelIndex>1</labelIndex> |
|
<name></name> |
|
<selectedRelationships>merged</selectedRelationships> |
|
<source> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>34a0052c-8338-3594-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</source> |
|
<zIndex>0</zIndex> |
|
</connections> |
|
<connections> |
|
<id>8565e2bc-113c-37f5-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> |
|
<backPressureObjectThreshold>10000</backPressureObjectThreshold> |
|
<bends> |
|
<x>1654.4066162109375</x> |
|
<y>1031.087646484375</y> |
|
</bends> |
|
<destination> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>197fc2db-5230-3f72-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</destination> |
|
<flowFileExpiration>0 sec</flowFileExpiration> |
|
<labelIndex>1</labelIndex> |
|
<name></name> |
|
<selectedRelationships>query</selectedRelationships> |
|
<source> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>a0c07048-fb08-36a5-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</source> |
|
<zIndex>0</zIndex> |
|
</connections> |
|
<connections> |
|
<id>b9b08c10-c99e-384d-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> |
|
<backPressureObjectThreshold>10000</backPressureObjectThreshold> |
|
<destination> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>dd5c4f43-317e-3d15-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</destination> |
|
<flowFileExpiration>0 sec</flowFileExpiration> |
|
<labelIndex>1</labelIndex> |
|
<name></name> |
|
<selectedRelationships>success</selectedRelationships> |
|
<source> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>ab86545e-dcbe-3fdb-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</source> |
|
<zIndex>0</zIndex> |
|
</connections> |
|
<connections> |
|
<id>d625e42d-6bec-3fc3-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> |
|
<backPressureObjectThreshold>10000</backPressureObjectThreshold> |
|
<destination> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>71455cb0-1cbc-380b-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</destination> |
|
<flowFileExpiration>0 sec</flowFileExpiration> |
|
<labelIndex>1</labelIndex> |
|
<name></name> |
|
<selectedRelationships>failure</selectedRelationships> |
|
<source> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>a0c07048-fb08-36a5-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</source> |
|
<zIndex>0</zIndex> |
|
</connections> |
|
<connections> |
|
<id>e381cba4-7ab1-313c-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> |
|
<backPressureObjectThreshold>10000</backPressureObjectThreshold> |
|
<destination> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>71455cb0-1cbc-380b-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</destination> |
|
<flowFileExpiration>0 sec</flowFileExpiration> |
|
<labelIndex>1</labelIndex> |
|
<name></name> |
|
<selectedRelationships>failure</selectedRelationships> |
|
<source> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>b154f3db-02fa-33ee-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</source> |
|
<zIndex>0</zIndex> |
|
</connections> |
|
<connections> |
|
<id>eb4c6b26-8dd8-3c00-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> |
|
<backPressureObjectThreshold>10000</backPressureObjectThreshold> |
|
<bends> |
|
<x>1676.4063720703125</x> |
|
<y>548.665283203125</y> |
|
</bends> |
|
<destination> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>b154f3db-02fa-33ee-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</destination> |
|
<flowFileExpiration>0 sec</flowFileExpiration> |
|
<labelIndex>0</labelIndex> |
|
<name></name> |
|
<selectedRelationships>success</selectedRelationships> |
|
<source> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>8d922698-4e84-3a5d-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</source> |
|
<zIndex>0</zIndex> |
|
</connections> |
|
<connections> |
|
<id>0dd0506a-2758-30c8-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> |
|
<backPressureObjectThreshold>10000</backPressureObjectThreshold> |
|
<destination> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>71455cb0-1cbc-380b-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</destination> |
|
<flowFileExpiration>0 sec</flowFileExpiration> |
|
<labelIndex>1</labelIndex> |
|
<name></name> |
|
<selectedRelationships>failure</selectedRelationships> |
|
<source> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>8d922698-4e84-3a5d-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</source> |
|
<zIndex>0</zIndex> |
|
</connections> |
|
<connections> |
|
<id>1dca0ea7-fccb-39cd-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> |
|
<backPressureObjectThreshold>10000</backPressureObjectThreshold> |
|
<destination> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>71455cb0-1cbc-380b-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</destination> |
|
<flowFileExpiration>0 sec</flowFileExpiration> |
|
<labelIndex>1</labelIndex> |
|
<name></name> |
|
<selectedRelationships>failure</selectedRelationships> |
|
<source> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>34a0052c-8338-3594-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</source> |
|
<zIndex>0</zIndex> |
|
</connections> |
|
<connections> |
|
<id>361001bb-2be4-3edb-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> |
|
<backPressureObjectThreshold>10000</backPressureObjectThreshold> |
|
<bends> |
|
<x>1659.120849609375</x> |
|
<y>721.5202026367188</y> |
|
</bends> |
|
<destination> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>34a0052c-8338-3594-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</destination> |
|
<flowFileExpiration>0 sec</flowFileExpiration> |
|
<labelIndex>0</labelIndex> |
|
<name></name> |
|
<selectedRelationships>query</selectedRelationships> |
|
<source> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>b154f3db-02fa-33ee-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</source> |
|
<zIndex>0</zIndex> |
|
</connections> |
|
<connections> |
|
<id>58f7424a-766a-316f-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> |
|
<backPressureObjectThreshold>10000</backPressureObjectThreshold> |
|
<destination> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>dd5c4f43-317e-3d15-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</destination> |
|
<flowFileExpiration>0 sec</flowFileExpiration> |
|
<labelIndex>1</labelIndex> |
|
<name></name> |
|
<selectedRelationships>success</selectedRelationships> |
|
<source> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>77323d5e-6914-34c9-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</source> |
|
<zIndex>0</zIndex> |
|
</connections> |
|
<connections> |
|
<id>5aeff59c-fe81-3f12-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> |
|
<backPressureObjectThreshold>10000</backPressureObjectThreshold> |
|
<bends> |
|
<x>1662.263671875</x> |
|
<y>366.38189697265625</y> |
|
</bends> |
|
<destination> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>8d922698-4e84-3a5d-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</destination> |
|
<flowFileExpiration>0 sec</flowFileExpiration> |
|
<labelIndex>1</labelIndex> |
|
<name></name> |
|
<selectedRelationships>success</selectedRelationships> |
|
<source> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>dd5c4f43-317e-3d15-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</source> |
|
<zIndex>0</zIndex> |
|
</connections> |
|
<connections> |
|
<id>6dcb2fde-ac49-3c26-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> |
|
<backPressureObjectThreshold>10000</backPressureObjectThreshold> |
|
<destination> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>dd5c4f43-317e-3d15-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</destination> |
|
<flowFileExpiration>0 sec</flowFileExpiration> |
|
<labelIndex>1</labelIndex> |
|
<name></name> |
|
<selectedRelationships>success</selectedRelationships> |
|
<source> |
|
<groupId>64c9eaeb-a756-303d-0000-000000000000</groupId> |
|
<id>e6bb12d8-4d40-3ab9-0000-000000000000</id> |
|
<type>PROCESSOR</type> |
|
</source> |
|
<zIndex>0</zIndex> |
|
</connections> |
|
<controllerServices> |
|
<id>cfd892a0-06cc-350e-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<bundle> |
|
<artifact>nifi-record-serialization-services-nar</artifact> |
|
<group>org.apache.nifi</group> |
|
<version>1.2.0</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-text</key> |
|
<value> |
|
<name>schema-text</name> |
|
</value> |
|
</entry> |
|
</descriptors> |
|
<name>AvroReader</name> |
|
<persistsState>false</persistsState> |
|
<properties> |
|
<entry> |
|
<key>schema-access-strategy</key> |
|
<value>schema-name</value> |
|
</entry> |
|
<entry> |
|
<key>schema-registry</key> |
|
<value>dfe2a21d-c1db-346e-0000-000000000000</value> |
|
</entry> |
|
<entry> |
|
<key>schema-name</key> |
|
</entry> |
|
<entry> |
|
<key>schema-text</key> |
|
</entry> |
|
</properties> |
|
<state>ENABLED</state> |
|
<type>org.apache.nifi.avro.AvroReader</type> |
|
</controllerServices> |
|
<controllerServices> |
|
<id>dfe2a21d-c1db-346e-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<bundle> |
|
<artifact>nifi-registry-nar</artifact> |
|
<group>org.apache.nifi</group> |
|
<version>1.2.0</version> |
|
</bundle> |
|
<comments></comments> |
|
<descriptors> |
|
<entry> |
|
<key>metric</key> |
|
<value> |
|
<name>metric</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>metrics</key> |
|
<value> |
|
<name>metrics</name> |
|
</value> |
|
</entry> |
|
</descriptors> |
|
<name>AvroSchemaRegistry</name> |
|
<persistsState>false</persistsState> |
|
<properties> |
|
<entry> |
|
<key>metric</key> |
|
<value>{ |
|
"name": "Parent", |
|
"type": "record", |
|
"fields": [ |
|
{ |
|
"name": "t", |
|
"type": "long" |
|
}, |
|
{ |
|
"name": "m", |
|
"type": ["null", "string"] |
|
}, |
|
{ |
|
"name": "v", |
|
"type": ["null", "string"] |
|
} |
|
] |
|
}</value> |
|
</entry> |
|
<entry> |
|
<key>metrics</key> |
|
<value>{ |
|
"name": "Parent", |
|
"type": "record", |
|
"fields": [ |
|
{ |
|
"name": "t", |
|
"type": "long" |
|
}, |
|
{ |
|
"name": "a", |
|
"type": ["null", "string"] |
|
}, |
|
{ |
|
"name": "b", |
|
"type": ["null", "string"] |
|
}, |
|
{ |
|
"name": "c", |
|
"type": ["null", "string"] |
|
} |
|
] |
|
}</value> |
|
</entry> |
|
</properties> |
|
<state>ENABLED</state> |
|
<type>org.apache.nifi.schemaregistry.services.AvroSchemaRegistry</type> |
|
</controllerServices> |
|
<controllerServices> |
|
<id>5e5f5489-42c0-3735-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<bundle> |
|
<artifact>nifi-record-serialization-services-nar</artifact> |
|
<group>org.apache.nifi</group> |
|
<version>1.2.0</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-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>CSV Format</key> |
|
<value> |
|
<name>CSV Format</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Value Separator</key> |
|
<value> |
|
<name>Value Separator</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Skip Header Line</key> |
|
<value> |
|
<name>Skip Header Line</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Quote Character</key> |
|
<value> |
|
<name>Quote Character</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Escape Character</key> |
|
<value> |
|
<name>Escape Character</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Comment Marker</key> |
|
<value> |
|
<name>Comment Marker</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Null String</key> |
|
<value> |
|
<name>Null String</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Trim Fields</key> |
|
<value> |
|
<name>Trim Fields</name> |
|
</value> |
|
</entry> |
|
</descriptors> |
|
<name>CSVReader</name> |
|
<persistsState>false</persistsState> |
|
<properties> |
|
<entry> |
|
<key>schema-access-strategy</key> |
|
<value>csv-header-derived</value> |
|
</entry> |
|
<entry> |
|
<key>schema-registry</key> |
|
<value>dfe2a21d-c1db-346e-0000-000000000000</value> |
|
</entry> |
|
<entry> |
|
<key>schema-name</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>CSV Format</key> |
|
</entry> |
|
<entry> |
|
<key>Value Separator</key> |
|
</entry> |
|
<entry> |
|
<key>Skip Header Line</key> |
|
<value>true</value> |
|
</entry> |
|
<entry> |
|
<key>Quote Character</key> |
|
</entry> |
|
<entry> |
|
<key>Escape Character</key> |
|
</entry> |
|
<entry> |
|
<key>Comment Marker</key> |
|
</entry> |
|
<entry> |
|
<key>Null String</key> |
|
</entry> |
|
<entry> |
|
<key>Trim Fields</key> |
|
</entry> |
|
</properties> |
|
<state>ENABLED</state> |
|
<type>org.apache.nifi.csv.CSVReader</type> |
|
</controllerServices> |
|
<controllerServices> |
|
<id>643f5ca7-858d-3fd0-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<bundle> |
|
<artifact>nifi-record-serialization-services-nar</artifact> |
|
<group>org.apache.nifi</group> |
|
<version>1.2.0</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-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>CSV Format</key> |
|
<value> |
|
<name>CSV Format</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Value Separator</key> |
|
<value> |
|
<name>Value Separator</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Include Header Line</key> |
|
<value> |
|
<name>Include Header Line</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Quote Character</key> |
|
<value> |
|
<name>Quote Character</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Escape Character</key> |
|
<value> |
|
<name>Escape Character</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Comment Marker</key> |
|
<value> |
|
<name>Comment Marker</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Null String</key> |
|
<value> |
|
<name>Null String</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Trim Fields</key> |
|
<value> |
|
<name>Trim Fields</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Quote Mode</key> |
|
<value> |
|
<name>Quote Mode</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Record Separator</key> |
|
<value> |
|
<name>Record Separator</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Include Trailing Delimiter</key> |
|
<value> |
|
<name>Include Trailing Delimiter</name> |
|
</value> |
|
</entry> |
|
</descriptors> |
|
<name>Metrics CSVWriter</name> |
|
<persistsState>false</persistsState> |
|
<properties> |
|
<entry> |
|
<key>Schema Write Strategy</key> |
|
</entry> |
|
<entry> |
|
<key>schema-access-strategy</key> |
|
</entry> |
|
<entry> |
|
<key>schema-registry</key> |
|
<value>dfe2a21d-c1db-346e-0000-000000000000</value> |
|
</entry> |
|
<entry> |
|
<key>schema-name</key> |
|
<value>metrics</value> |
|
</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>CSV Format</key> |
|
</entry> |
|
<entry> |
|
<key>Value Separator</key> |
|
</entry> |
|
<entry> |
|
<key>Include Header Line</key> |
|
</entry> |
|
<entry> |
|
<key>Quote Character</key> |
|
</entry> |
|
<entry> |
|
<key>Escape Character</key> |
|
</entry> |
|
<entry> |
|
<key>Comment Marker</key> |
|
</entry> |
|
<entry> |
|
<key>Null String</key> |
|
</entry> |
|
<entry> |
|
<key>Trim Fields</key> |
|
</entry> |
|
<entry> |
|
<key>Quote Mode</key> |
|
</entry> |
|
<entry> |
|
<key>Record Separator</key> |
|
</entry> |
|
<entry> |
|
<key>Include Trailing Delimiter</key> |
|
</entry> |
|
</properties> |
|
<state>ENABLED</state> |
|
<type>org.apache.nifi.csv.CSVRecordSetWriter</type> |
|
</controllerServices> |
|
<controllerServices> |
|
<id>6b02de95-b6c6-3271-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<bundle> |
|
<artifact>nifi-record-serialization-services-nar</artifact> |
|
<group>org.apache.nifi</group> |
|
<version>1.2.0</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-text</key> |
|
<value> |
|
<name>schema-text</name> |
|
</value> |
|
</entry> |
|
</descriptors> |
|
<name>AvroRecordSetWriter</name> |
|
<persistsState>false</persistsState> |
|
<properties> |
|
<entry> |
|
<key>Schema Write Strategy</key> |
|
<value>schema-name</value> |
|
</entry> |
|
<entry> |
|
<key>schema-access-strategy</key> |
|
</entry> |
|
<entry> |
|
<key>schema-registry</key> |
|
<value>dfe2a21d-c1db-346e-0000-000000000000</value> |
|
</entry> |
|
<entry> |
|
<key>schema-name</key> |
|
</entry> |
|
<entry> |
|
<key>schema-text</key> |
|
</entry> |
|
</properties> |
|
<state>ENABLED</state> |
|
<type>org.apache.nifi.avro.AvroRecordSetWriter</type> |
|
</controllerServices> |
|
<processors> |
|
<id>8d922698-4e84-3a5d-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<position> |
|
<x>1188.5547092168395</x> |
|
<y>412.524068325562</y> |
|
</position> |
|
<bundle> |
|
<artifact>nifi-standard-nar</artifact> |
|
<group>org.apache.nifi</group> |
|
<version>1.2.0</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> |
|
</descriptors> |
|
<executionNode>ALL</executionNode> |
|
<lossTolerant>false</lossTolerant> |
|
<penaltyDuration>30 sec</penaltyDuration> |
|
<properties> |
|
<entry> |
|
<key>record-reader</key> |
|
<value>5e5f5489-42c0-3735-0000-000000000000</value> |
|
</entry> |
|
<entry> |
|
<key>record-writer</key> |
|
<value>6b02de95-b6c6-3271-0000-000000000000</value> |
|
</entry> |
|
</properties> |
|
<runDurationMillis>0</runDurationMillis> |
|
<schedulingPeriod>0 sec</schedulingPeriod> |
|
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> |
|
<yieldDuration>1 sec</yieldDuration> |
|
</config> |
|
<name>ConvertRecord</name> |
|
<relationships> |
|
<autoTerminate>false</autoTerminate> |
|
<name>failure</name> |
|
</relationships> |
|
<relationships> |
|
<autoTerminate>false</autoTerminate> |
|
<name>success</name> |
|
</relationships> |
|
<style></style> |
|
<type>org.apache.nifi.processors.standard.ConvertRecord</type> |
|
</processors> |
|
<processors> |
|
<id>a0c07048-fb08-36a5-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<position> |
|
<x>1188.5547092168395</x> |
|
<y>891.7445867683687</y> |
|
</position> |
|
<bundle> |
|
<artifact>nifi-standard-nar</artifact> |
|
<group>org.apache.nifi</group> |
|
<version>1.2.0</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>query</key> |
|
<value> |
|
<name>query</name> |
|
</value> |
|
</entry> |
|
</descriptors> |
|
<executionNode>ALL</executionNode> |
|
<lossTolerant>false</lossTolerant> |
|
<penaltyDuration>30 sec</penaltyDuration> |
|
<properties> |
|
<entry> |
|
<key>record-reader</key> |
|
<value>cfd892a0-06cc-350e-0000-000000000000</value> |
|
</entry> |
|
<entry> |
|
<key>record-writer</key> |
|
<value>643f5ca7-858d-3fd0-0000-000000000000</value> |
|
</entry> |
|
<entry> |
|
<key>include-zero-record-flowfiles</key> |
|
<value>true</value> |
|
</entry> |
|
<entry> |
|
<key>cache-schema</key> |
|
<value>true</value> |
|
</entry> |
|
<entry> |
|
<key>query</key> |
|
<value>select fa.t, fa.v a, fb.v b, fc.v c |
|
from ( |
|
select t, v from FLOWFILE where m = 'a' |
|
) fa |
|
left join ( |
|
select t, v from FLOWFILE where m = 'b' |
|
) fb on fa.t = fb.t |
|
left join ( |
|
select t, v from FLOWFILE where m = 'c' |
|
) fc on fa.t = fc.t |
|
</value> |
|
</entry> |
|
</properties> |
|
<runDurationMillis>0</runDurationMillis> |
|
<schedulingPeriod>0 sec</schedulingPeriod> |
|
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> |
|
<yieldDuration>1 sec</yieldDuration> |
|
</config> |
|
<name>QueryRecord</name> |
|
<relationships> |
|
<autoTerminate>false</autoTerminate> |
|
<name>failure</name> |
|
</relationships> |
|
<relationships> |
|
<autoTerminate>true</autoTerminate> |
|
<name>original</name> |
|
</relationships> |
|
<relationships> |
|
<autoTerminate>false</autoTerminate> |
|
<name>query</name> |
|
</relationships> |
|
<style></style> |
|
<type>org.apache.nifi.processors.standard.QueryRecord</type> |
|
</processors> |
|
<processors> |
|
<id>ab86545e-dcbe-3fdb-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<position> |
|
<x>779.1306915224957</x> |
|
<y>-1.8002225730620012</y> |
|
</position> |
|
<bundle> |
|
<artifact>nifi-standard-nar</artifact> |
|
<group>org.apache.nifi</group> |
|
<version>1.2.0</version> |
|
</bundle> |
|
<config> |
|
<bulletinLevel>WARN</bulletinLevel> |
|
<comments></comments> |
|
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> |
|
<descriptors> |
|
<entry> |
|
<key>File Size</key> |
|
<value> |
|
<name>File Size</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Batch Size</key> |
|
<value> |
|
<name>Batch Size</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Data Format</key> |
|
<value> |
|
<name>Data Format</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Unique FlowFiles</key> |
|
<value> |
|
<name>Unique FlowFiles</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>generate-ff-custom-text</key> |
|
<value> |
|
<name>generate-ff-custom-text</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>fragment.index</key> |
|
<value> |
|
<name>fragment.index</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>metric</key> |
|
<value> |
|
<name>metric</name> |
|
</value> |
|
</entry> |
|
</descriptors> |
|
<executionNode>ALL</executionNode> |
|
<lossTolerant>false</lossTolerant> |
|
<penaltyDuration>30 sec</penaltyDuration> |
|
<properties> |
|
<entry> |
|
<key>File Size</key> |
|
<value>0B</value> |
|
</entry> |
|
<entry> |
|
<key>Batch Size</key> |
|
<value>1</value> |
|
</entry> |
|
<entry> |
|
<key>Data Format</key> |
|
<value>Text</value> |
|
</entry> |
|
<entry> |
|
<key>Unique FlowFiles</key> |
|
<value>false</value> |
|
</entry> |
|
<entry> |
|
<key>generate-ff-custom-text</key> |
|
<value>t, v |
|
1, 10 |
|
2, 20 |
|
3, 30 |
|
4, 40 |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>fragment.index</key> |
|
<value>0</value> |
|
</entry> |
|
<entry> |
|
<key>metric</key> |
|
<value>a</value> |
|
</entry> |
|
</properties> |
|
<runDurationMillis>0</runDurationMillis> |
|
<schedulingPeriod>1d</schedulingPeriod> |
|
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> |
|
<yieldDuration>1 sec</yieldDuration> |
|
</config> |
|
<name>Generate metrics A</name> |
|
<relationships> |
|
<autoTerminate>false</autoTerminate> |
|
<name>success</name> |
|
</relationships> |
|
<style></style> |
|
<type>org.apache.nifi.processors.standard.GenerateFlowFile</type> |
|
</processors> |
|
<processors> |
|
<id>b154f3db-02fa-33ee-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<position> |
|
<x>1188.5547092168395</x> |
|
<y>575.749072852353</y> |
|
</position> |
|
<bundle> |
|
<artifact>nifi-standard-nar</artifact> |
|
<group>org.apache.nifi</group> |
|
<version>1.2.0</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>query</key> |
|
<value> |
|
<name>query</name> |
|
</value> |
|
</entry> |
|
</descriptors> |
|
<executionNode>ALL</executionNode> |
|
<lossTolerant>false</lossTolerant> |
|
<penaltyDuration>30 sec</penaltyDuration> |
|
<properties> |
|
<entry> |
|
<key>record-reader</key> |
|
<value>cfd892a0-06cc-350e-0000-000000000000</value> |
|
</entry> |
|
<entry> |
|
<key>record-writer</key> |
|
<value>6b02de95-b6c6-3271-0000-000000000000</value> |
|
</entry> |
|
<entry> |
|
<key>include-zero-record-flowfiles</key> |
|
<value>true</value> |
|
</entry> |
|
<entry> |
|
<key>cache-schema</key> |
|
<value>false</value> |
|
</entry> |
|
<entry> |
|
<key>query</key> |
|
<value>select t, '${metric}' as m, v from FLOWFILE</value> |
|
</entry> |
|
</properties> |
|
<runDurationMillis>0</runDurationMillis> |
|
<schedulingPeriod>0 sec</schedulingPeriod> |
|
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> |
|
<yieldDuration>1 sec</yieldDuration> |
|
</config> |
|
<name>QueryRecord</name> |
|
<relationships> |
|
<autoTerminate>false</autoTerminate> |
|
<name>failure</name> |
|
</relationships> |
|
<relationships> |
|
<autoTerminate>true</autoTerminate> |
|
<name>original</name> |
|
</relationships> |
|
<relationships> |
|
<autoTerminate>false</autoTerminate> |
|
<name>query</name> |
|
</relationships> |
|
<style></style> |
|
<type>org.apache.nifi.processors.standard.QueryRecord</type> |
|
</processors> |
|
<processors> |
|
<id>dd5c4f43-317e-3d15-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<position> |
|
<x>1188.5547092168395</x> |
|
<y>222.10936543821504</y> |
|
</position> |
|
<bundle> |
|
<artifact>nifi-update-attribute-nar</artifact> |
|
<group>org.apache.nifi</group> |
|
<version>1.2.0</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>fragment.count</key> |
|
<value> |
|
<name>fragment.count</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>fragment.identifier</key> |
|
<value> |
|
<name>fragment.identifier</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>schema.name</key> |
|
<value> |
|
<name>schema.name</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>fragment.count</key> |
|
<value>3</value> |
|
</entry> |
|
<entry> |
|
<key>fragment.identifier</key> |
|
<value>20170605</value> |
|
</entry> |
|
<entry> |
|
<key>schema.name</key> |
|
<value>metric</value> |
|
</entry> |
|
</properties> |
|
<runDurationMillis>0</runDurationMillis> |
|
<schedulingPeriod>0 sec</schedulingPeriod> |
|
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> |
|
<yieldDuration>1 sec</yieldDuration> |
|
</config> |
|
<name>UpdateAttribute</name> |
|
<relationships> |
|
<autoTerminate>false</autoTerminate> |
|
<name>success</name> |
|
</relationships> |
|
<style></style> |
|
<type>org.apache.nifi.processors.attributes.UpdateAttribute</type> |
|
</processors> |
|
<processors> |
|
<id>e6bb12d8-4d40-3ab9-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<position> |
|
<x>1188.5547092168395</x> |
|
<y>-1.8002225730620012</y> |
|
</position> |
|
<bundle> |
|
<artifact>nifi-standard-nar</artifact> |
|
<group>org.apache.nifi</group> |
|
<version>1.2.0</version> |
|
</bundle> |
|
<config> |
|
<bulletinLevel>WARN</bulletinLevel> |
|
<comments></comments> |
|
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> |
|
<descriptors> |
|
<entry> |
|
<key>File Size</key> |
|
<value> |
|
<name>File Size</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Batch Size</key> |
|
<value> |
|
<name>Batch Size</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Data Format</key> |
|
<value> |
|
<name>Data Format</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Unique FlowFiles</key> |
|
<value> |
|
<name>Unique FlowFiles</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>generate-ff-custom-text</key> |
|
<value> |
|
<name>generate-ff-custom-text</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>fragment.index</key> |
|
<value> |
|
<name>fragment.index</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>metric</key> |
|
<value> |
|
<name>metric</name> |
|
</value> |
|
</entry> |
|
</descriptors> |
|
<executionNode>ALL</executionNode> |
|
<lossTolerant>false</lossTolerant> |
|
<penaltyDuration>30 sec</penaltyDuration> |
|
<properties> |
|
<entry> |
|
<key>File Size</key> |
|
<value>0B</value> |
|
</entry> |
|
<entry> |
|
<key>Batch Size</key> |
|
<value>1</value> |
|
</entry> |
|
<entry> |
|
<key>Data Format</key> |
|
<value>Text</value> |
|
</entry> |
|
<entry> |
|
<key>Unique FlowFiles</key> |
|
<value>false</value> |
|
</entry> |
|
<entry> |
|
<key>generate-ff-custom-text</key> |
|
<value>t, v |
|
1, a |
|
2, b |
|
3, c |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>fragment.index</key> |
|
<value>1</value> |
|
</entry> |
|
<entry> |
|
<key>metric</key> |
|
<value>b</value> |
|
</entry> |
|
</properties> |
|
<runDurationMillis>0</runDurationMillis> |
|
<schedulingPeriod>1d</schedulingPeriod> |
|
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> |
|
<yieldDuration>1 sec</yieldDuration> |
|
</config> |
|
<name>Generate metrics B</name> |
|
<relationships> |
|
<autoTerminate>false</autoTerminate> |
|
<name>success</name> |
|
</relationships> |
|
<style></style> |
|
<type>org.apache.nifi.processors.standard.GenerateFlowFile</type> |
|
</processors> |
|
<processors> |
|
<id>197fc2db-5230-3f72-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<position> |
|
<x>1188.5547092168395</x> |
|
<y>1043.4440541735553</y> |
|
</position> |
|
<bundle> |
|
<artifact>nifi-update-attribute-nar</artifact> |
|
<group>org.apache.nifi</group> |
|
<version>1.2.0</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> |
|
</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> |
|
</properties> |
|
<runDurationMillis>0</runDurationMillis> |
|
<schedulingPeriod>0 sec</schedulingPeriod> |
|
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> |
|
<yieldDuration>1 sec</yieldDuration> |
|
</config> |
|
<name>UpdateAttribute</name> |
|
<relationships> |
|
<autoTerminate>false</autoTerminate> |
|
<name>success</name> |
|
</relationships> |
|
<style></style> |
|
<type>org.apache.nifi.processors.attributes.UpdateAttribute</type> |
|
</processors> |
|
<processors> |
|
<id>34a0052c-8338-3594-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<position> |
|
<x>1188.5547092168395</x> |
|
<y>744.034654164718</y> |
|
</position> |
|
<bundle> |
|
<artifact>nifi-standard-nar</artifact> |
|
<group>org.apache.nifi</group> |
|
<version>1.2.0</version> |
|
</bundle> |
|
<config> |
|
<bulletinLevel>WARN</bulletinLevel> |
|
<comments></comments> |
|
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> |
|
<descriptors> |
|
<entry> |
|
<key>Merge Strategy</key> |
|
<value> |
|
<name>Merge Strategy</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Merge Format</key> |
|
<value> |
|
<name>Merge Format</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Attribute Strategy</key> |
|
<value> |
|
<name>Attribute Strategy</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Correlation Attribute Name</key> |
|
<value> |
|
<name>Correlation Attribute Name</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Minimum Number of Entries</key> |
|
<value> |
|
<name>Minimum Number of Entries</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Maximum Number of Entries</key> |
|
<value> |
|
<name>Maximum Number of Entries</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Minimum Group Size</key> |
|
<value> |
|
<name>Minimum Group Size</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Maximum Group Size</key> |
|
<value> |
|
<name>Maximum Group Size</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Max Bin Age</key> |
|
<value> |
|
<name>Max Bin Age</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Maximum number of Bins</key> |
|
<value> |
|
<name>Maximum number of Bins</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Delimiter Strategy</key> |
|
<value> |
|
<name>Delimiter Strategy</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Header File</key> |
|
<value> |
|
<name>Header File</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Footer File</key> |
|
<value> |
|
<name>Footer File</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Demarcator File</key> |
|
<value> |
|
<name>Demarcator File</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Compression Level</key> |
|
<value> |
|
<name>Compression Level</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Keep Path</key> |
|
<value> |
|
<name>Keep Path</name> |
|
</value> |
|
</entry> |
|
</descriptors> |
|
<executionNode>ALL</executionNode> |
|
<lossTolerant>false</lossTolerant> |
|
<penaltyDuration>30 sec</penaltyDuration> |
|
<properties> |
|
<entry> |
|
<key>Merge Strategy</key> |
|
<value>Defragment</value> |
|
</entry> |
|
<entry> |
|
<key>Merge Format</key> |
|
<value>Binary Concatenation</value> |
|
</entry> |
|
<entry> |
|
<key>Attribute Strategy</key> |
|
<value>Keep Only Common Attributes</value> |
|
</entry> |
|
<entry> |
|
<key>Correlation Attribute Name</key> |
|
</entry> |
|
<entry> |
|
<key>Minimum Number of Entries</key> |
|
<value>1</value> |
|
</entry> |
|
<entry> |
|
<key>Maximum Number of Entries</key> |
|
<value>1000</value> |
|
</entry> |
|
<entry> |
|
<key>Minimum Group Size</key> |
|
<value>0 B</value> |
|
</entry> |
|
<entry> |
|
<key>Maximum Group Size</key> |
|
</entry> |
|
<entry> |
|
<key>Max Bin Age</key> |
|
</entry> |
|
<entry> |
|
<key>Maximum number of Bins</key> |
|
<value>5</value> |
|
</entry> |
|
<entry> |
|
<key>Delimiter Strategy</key> |
|
<value>Filename</value> |
|
</entry> |
|
<entry> |
|
<key>Header File</key> |
|
</entry> |
|
<entry> |
|
<key>Footer File</key> |
|
</entry> |
|
<entry> |
|
<key>Demarcator File</key> |
|
</entry> |
|
<entry> |
|
<key>Compression Level</key> |
|
<value>1</value> |
|
</entry> |
|
<entry> |
|
<key>Keep Path</key> |
|
<value>false</value> |
|
</entry> |
|
</properties> |
|
<runDurationMillis>0</runDurationMillis> |
|
<schedulingPeriod>0 sec</schedulingPeriod> |
|
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> |
|
<yieldDuration>1 sec</yieldDuration> |
|
</config> |
|
<name>MergeContent</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> |
|
<style></style> |
|
<type>org.apache.nifi.processors.standard.MergeContent</type> |
|
</processors> |
|
<processors> |
|
<id>71455cb0-1cbc-380b-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<position> |
|
<x>571.4675007903224</x> |
|
<y>586.0560512292307</y> |
|
</position> |
|
<bundle> |
|
<artifact>nifi-update-attribute-nar</artifact> |
|
<group>org.apache.nifi</group> |
|
<version>1.2.0</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>fragment.identifier</key> |
|
<value> |
|
<name>fragment.identifier</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>fragment.size</key> |
|
<value> |
|
<name>fragment.size</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>fragment.identifier</key> |
|
<value>20170605</value> |
|
</entry> |
|
<entry> |
|
<key>fragment.size</key> |
|
<value>2</value> |
|
</entry> |
|
</properties> |
|
<runDurationMillis>0</runDurationMillis> |
|
<schedulingPeriod>0 sec</schedulingPeriod> |
|
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> |
|
<yieldDuration>1 sec</yieldDuration> |
|
</config> |
|
<name>UpdateAttribute</name> |
|
<relationships> |
|
<autoTerminate>false</autoTerminate> |
|
<name>success</name> |
|
</relationships> |
|
<style></style> |
|
<type>org.apache.nifi.processors.attributes.UpdateAttribute</type> |
|
</processors> |
|
<processors> |
|
<id>77323d5e-6914-34c9-0000-000000000000</id> |
|
<parentGroupId>64c9eaeb-a756-303d-0000-000000000000</parentGroupId> |
|
<position> |
|
<x>1587.8314971865582</x> |
|
<y>-1.8002225730620012</y> |
|
</position> |
|
<bundle> |
|
<artifact>nifi-standard-nar</artifact> |
|
<group>org.apache.nifi</group> |
|
<version>1.2.0</version> |
|
</bundle> |
|
<config> |
|
<bulletinLevel>WARN</bulletinLevel> |
|
<comments></comments> |
|
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> |
|
<descriptors> |
|
<entry> |
|
<key>File Size</key> |
|
<value> |
|
<name>File Size</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Batch Size</key> |
|
<value> |
|
<name>Batch Size</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Data Format</key> |
|
<value> |
|
<name>Data Format</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>Unique FlowFiles</key> |
|
<value> |
|
<name>Unique FlowFiles</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>generate-ff-custom-text</key> |
|
<value> |
|
<name>generate-ff-custom-text</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>fragment.index</key> |
|
<value> |
|
<name>fragment.index</name> |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>metric</key> |
|
<value> |
|
<name>metric</name> |
|
</value> |
|
</entry> |
|
</descriptors> |
|
<executionNode>ALL</executionNode> |
|
<lossTolerant>false</lossTolerant> |
|
<penaltyDuration>30 sec</penaltyDuration> |
|
<properties> |
|
<entry> |
|
<key>File Size</key> |
|
<value>0B</value> |
|
</entry> |
|
<entry> |
|
<key>Batch Size</key> |
|
<value>1</value> |
|
</entry> |
|
<entry> |
|
<key>Data Format</key> |
|
<value>Text</value> |
|
</entry> |
|
<entry> |
|
<key>Unique FlowFiles</key> |
|
<value>false</value> |
|
</entry> |
|
<entry> |
|
<key>generate-ff-custom-text</key> |
|
<value>t, v |
|
1, 1.1 |
|
3, 3.3 |
|
4, 4.4 |
|
</value> |
|
</entry> |
|
<entry> |
|
<key>fragment.index</key> |
|
<value>2</value> |
|
</entry> |
|
<entry> |
|
<key>metric</key> |
|
<value>c</value> |
|
</entry> |
|
</properties> |
|
<runDurationMillis>0</runDurationMillis> |
|
<schedulingPeriod>1d</schedulingPeriod> |
|
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> |
|
<yieldDuration>1 sec</yieldDuration> |
|
</config> |
|
<name>Generate metrics C</name> |
|
<relationships> |
|
<autoTerminate>false</autoTerminate> |
|
<name>success</name> |
|
</relationships> |
|
<style></style> |
|
<type>org.apache.nifi.processors.standard.GenerateFlowFile</type> |
|
</processors> |
|
</contents> |
|
<name>Join CSV files 1.2.0</name> |
|
</processGroups> |
|
</snippet> |
|
<timestamp>06/06/2017 08:47:16 JST</timestamp> |
|
</template> |