NiFi example on how to join CSV files to create a merged result.

0.NIFI_Example_CSV_JOIN.md

NiFi example on how to join CSV files to create a merged result

Let's say there're following 3 CSV files (a, b and c):

t, v
1, 10
2, 20
3, 30
4, 40

t, v
1, a
2, b
3, c

t, v
1, 1.1
3, 3.3
4, 4.4

Then you'd like to get a joined result as follows:

t,a,b,c
1,10,a,1.1
2,20,b,
3,30,c,3.3
4,40,,4.4

This can be done by using new functionalities available since 1.2.0 such as SchemaRegistry and QueryRecord. For details, please refer following flow screenshot and template.

The basic idea is using MergeContent to create a single FlowFile, containing all CSV files, when doing so, add a column specifying which attribute (I used 'm' column in my example).

Then use QueryRecord processor to join records and produce a row having different attributes in it:

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

1.flow.png

Join_CSV_Files.xml

<?xml version="1.0" ?>
<template encoding-version="1.1">
  <description></description>
  <groupId>1e8778a8-015c-1000-c747-8273276bab45</groupId>
  <name>Join CSV Files</name>
  <snippet>
    <processGroups>
      <id>57f3f6b7-ede0-3e38-0000-000000000000</id>
      <parentGroupId>5454b790-94fe-3e28-0000-000000000000</parentGroupId>
      <position>
        <x>0.0</x>
        <y>0.0</y>
      </position>
      <comments></comments>
      <contents>
        <connections>
          <id>96ea7f00-5478-3aca-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
          <backPressureObjectThreshold>10000</backPressureObjectThreshold>
          <destination>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>ea7ae4cd-a3ad-3226-0000-000000000000</id>
            <type>PROCESSOR</type>
          </destination>
          <flowFileExpiration>0 sec</flowFileExpiration>
          <labelIndex>1</labelIndex>
          <name></name>
          <selectedRelationships>success</selectedRelationships>
          <source>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>862ea893-e7c7-3a0c-0000-000000000000</id>
            <type>PROCESSOR</type>
          </source>
          <zIndex>0</zIndex>
        </connections>
        <connections>
          <id>c29c40d6-416c-361b-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
          <backPressureObjectThreshold>10000</backPressureObjectThreshold>
          <destination>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>c8653039-5d30-3276-0000-000000000000</id>
            <type>PROCESSOR</type>
          </destination>
          <flowFileExpiration>0 sec</flowFileExpiration>
          <labelIndex>1</labelIndex>
          <name></name>
          <selectedRelationships>failure</selectedRelationships>
          <source>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>db0b9829-ffa1-3f4f-0000-000000000000</id>
            <type>PROCESSOR</type>
          </source>
          <zIndex>0</zIndex>
        </connections>
        <connections>
          <id>c5484cf1-5aa1-3090-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
          <backPressureObjectThreshold>10000</backPressureObjectThreshold>
          <destination>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>ea7ae4cd-a3ad-3226-0000-000000000000</id>
            <type>PROCESSOR</type>
          </destination>
          <flowFileExpiration>0 sec</flowFileExpiration>
          <labelIndex>1</labelIndex>
          <name></name>
          <selectedRelationships>success</selectedRelationships>
          <source>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>90ef331a-7ffa-3e0d-0000-000000000000</id>
            <type>PROCESSOR</type>
          </source>
          <zIndex>0</zIndex>
        </connections>
        <connections>
          <id>dc752d0d-fd63-301d-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
          <backPressureObjectThreshold>10000</backPressureObjectThreshold>
          <destination>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>c8653039-5d30-3276-0000-000000000000</id>
            <type>PROCESSOR</type>
          </destination>
          <flowFileExpiration>0 sec</flowFileExpiration>
          <labelIndex>1</labelIndex>
          <name></name>
          <selectedRelationships>failure</selectedRelationships>
          <source>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>efec7be2-d703-31e4-0000-000000000000</id>
            <type>PROCESSOR</type>
          </source>
          <zIndex>0</zIndex>
        </connections>
        <connections>
          <id>e0823611-5497-3458-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
          <backPressureObjectThreshold>10000</backPressureObjectThreshold>
          <destination>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>ea7ae4cd-a3ad-3226-0000-000000000000</id>
            <type>PROCESSOR</type>
          </destination>
          <flowFileExpiration>0 sec</flowFileExpiration>
          <labelIndex>1</labelIndex>
          <name></name>
          <selectedRelationships>success</selectedRelationships>
          <source>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>7f3071b9-d653-3e27-0000-000000000000</id>
            <type>PROCESSOR</type>
          </source>
          <zIndex>0</zIndex>
        </connections>
        <connections>
          <id>f375aecf-f2c7-3458-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
          <backPressureObjectThreshold>10000</backPressureObjectThreshold>
          <bends>
            <x>1698.4876708984375</x>
            <y>797.5947875976562</y>
          </bends>
          <destination>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>d4a02a62-8aa7-3af5-0000-000000000000</id>
            <type>PROCESSOR</type>
          </destination>
          <flowFileExpiration>0 sec</flowFileExpiration>
          <labelIndex>1</labelIndex>
          <name></name>
          <selectedRelationships>query</selectedRelationships>
          <source>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>db0b9829-ffa1-3f4f-0000-000000000000</id>
            <type>PROCESSOR</type>
          </source>
          <zIndex>0</zIndex>
        </connections>
        <connections>
          <id>fd4b31a1-dd9d-3385-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
          <backPressureObjectThreshold>10000</backPressureObjectThreshold>
          <bends>
            <x>1666.98291015625</x>
            <y>356.52740478515625</y>
          </bends>
          <destination>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>ff7d1584-b37c-380c-0000-000000000000</id>
            <type>PROCESSOR</type>
          </destination>
          <flowFileExpiration>0 sec</flowFileExpiration>
          <labelIndex>0</labelIndex>
          <name></name>
          <selectedRelationships>success</selectedRelationships>
          <source>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>ea7ae4cd-a3ad-3226-0000-000000000000</id>
            <type>PROCESSOR</type>
          </source>
          <zIndex>0</zIndex>
        </connections>
        <connections>
          <id>1948d101-5ee8-34f9-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
          <backPressureObjectThreshold>10000</backPressureObjectThreshold>
          <bends>
            <x>1691.3275146484375</x>
            <y>652.9590454101562</y>
          </bends>
          <destination>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>db0b9829-ffa1-3f4f-0000-000000000000</id>
            <type>PROCESSOR</type>
          </destination>
          <flowFileExpiration>0 sec</flowFileExpiration>
          <labelIndex>0</labelIndex>
          <name></name>
          <selectedRelationships>merged</selectedRelationships>
          <source>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>efec7be2-d703-31e4-0000-000000000000</id>
            <type>PROCESSOR</type>
          </source>
          <zIndex>0</zIndex>
        </connections>
        <connections>
          <id>395a2fe8-a684-3a3b-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
          <backPressureObjectThreshold>10000</backPressureObjectThreshold>
          <bends>
            <x>1697.9278564453125</x>
            <y>495.5318908691406</y>
          </bends>
          <destination>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>efec7be2-d703-31e4-0000-000000000000</id>
            <type>PROCESSOR</type>
          </destination>
          <flowFileExpiration>0 sec</flowFileExpiration>
          <labelIndex>0</labelIndex>
          <name></name>
          <selectedRelationships>success</selectedRelationships>
          <source>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>ff7d1584-b37c-380c-0000-000000000000</id>
            <type>PROCESSOR</type>
          </source>
          <zIndex>0</zIndex>
        </connections>
        <connections>
          <id>4c980407-824b-3aed-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
          <backPressureObjectThreshold>10000</backPressureObjectThreshold>
          <destination>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>c8653039-5d30-3276-0000-000000000000</id>
            <type>PROCESSOR</type>
          </destination>
          <flowFileExpiration>0 sec</flowFileExpiration>
          <labelIndex>1</labelIndex>
          <name></name>
          <selectedRelationships>failure</selectedRelationships>
          <source>
            <groupId>57f3f6b7-ede0-3e38-0000-000000000000</groupId>
            <id>ff7d1584-b37c-380c-0000-000000000000</id>
            <type>PROCESSOR</type>
          </source>
          <zIndex>0</zIndex>
        </connections>
        <controllerServices>
          <id>9c95d206-79ea-3192-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <bundle>
            <artifact>nifi-registry-nar</artifact>
            <group>org.apache.nifi</group>
            <version>1.3.0-SNAPSHOT</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": "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>08d3322c-fb23-3c66-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <bundle>
            <artifact>nifi-record-serialization-services-nar</artifact>
            <group>org.apache.nifi</group>
            <version>1.3.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-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>9c95d206-79ea-3192-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>1279262a-efb5-300c-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <bundle>
            <artifact>nifi-record-serialization-services-nar</artifact>
            <group>org.apache.nifi</group>
            <version>1.3.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-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>9c95d206-79ea-3192-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>2c3d0888-3e3a-3b3f-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <bundle>
            <artifact>nifi-record-serialization-services-nar</artifact>
            <group>org.apache.nifi</group>
            <version>1.3.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-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>
              <value>schema-name</value>
            </entry>
            <entry>
              <key>schema-registry</key>
              <value>9c95d206-79ea-3192-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>
        <controllerServices>
          <id>69c0d0d5-d85f-3723-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <bundle>
            <artifact>nifi-record-serialization-services-nar</artifact>
            <group>org.apache.nifi</group>
            <version>1.3.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-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>9c95d206-79ea-3192-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>
        <processors>
          <id>862ea893-e7c7-3a0c-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <position>
            <x>830.7232208193707</x>
            <y>0.29859906695264726</y>
          </position>
          <bundle>
            <artifact>nifi-standard-nar</artifact>
            <group>org.apache.nifi</group>
            <version>1.3.0-SNAPSHOT</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>90ef331a-7ffa-3e0d-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <position>
            <x>1204.8223419131207</x>
            <y>-3.8990442130766496</y>
          </position>
          <bundle>
            <artifact>nifi-standard-nar</artifact>
            <group>org.apache.nifi</group>
            <version>1.3.0-SNAPSHOT</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>c8653039-5d30-3276-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <position>
            <x>582.4673176848537</x>
            <y>461.91481587766816</y>
          </position>
          <bundle>
            <artifact>nifi-update-attribute-nar</artifact>
            <group>org.apache.nifi</group>
            <version>1.3.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>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>d4a02a62-8aa7-3af5-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <position>
            <x>1184.858365583058</x>
            <y>807.7328725329303</y>
          </position>
          <bundle>
            <artifact>nifi-update-attribute-nar</artifact>
            <group>org.apache.nifi</group>
            <version>1.3.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>
            </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>db0b9829-ffa1-3f4f-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <position>
            <x>1185.7709503115582</x>
            <y>656.0334051277437</y>
          </position>
          <bundle>
            <artifact>nifi-standard-nar</artifact>
            <group>org.apache.nifi</group>
            <version>1.3.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>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>08d3322c-fb23-3c66-0000-000000000000</value>
              </entry>
              <entry>
                <key>record-writer</key>
                <value>69c0d0d5-d85f-3723-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>ea7ae4cd-a3ad-3226-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <position>
            <x>1186.1315022551662</x>
            <y>222.10936543821504</y>
          </position>
          <bundle>
            <artifact>nifi-update-attribute-nar</artifact>
            <group>org.apache.nifi</group>
            <version>1.3.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>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>efec7be2-d703-31e4-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <position>
            <x>1185.818571081014</x>
            <y>508.32347252409295</y>
          </position>
          <bundle>
            <artifact>nifi-standard-nar</artifact>
            <group>org.apache.nifi</group>
            <version>1.3.0-SNAPSHOT</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>ff7d1584-b37c-380c-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <position>
            <x>1185.7667765187398</x>
            <y>368.4565217517179</y>
          </position>
          <bundle>
            <artifact>nifi-standard-nar</artifact>
            <group>org.apache.nifi</group>
            <version>1.3.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>/m</key>
                <value>
                  <name>/m</name>
                </value>
              </entry>
            </descriptors>
            <executionNode>ALL</executionNode>
            <lossTolerant>false</lossTolerant>
            <penaltyDuration>30 sec</penaltyDuration>
            <properties>
              <entry>
                <key>record-reader</key>
                <value>1279262a-efb5-300c-0000-000000000000</value>
              </entry>
              <entry>
                <key>record-writer</key>
                <value>2c3d0888-3e3a-3b3f-0000-000000000000</value>
              </entry>
              <entry>
                <key>replacement-value-strategy</key>
                <value>literal-value</value>
              </entry>
              <entry>
                <key>/m</key>
                <value>${metric}</value>
              </entry>
            </properties>
            <runDurationMillis>0</runDurationMillis>
            <schedulingPeriod>0 sec</schedulingPeriod>
            <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
            <yieldDuration>1 sec</yieldDuration>
          </config>
          <name>UpdateRecord</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.UpdateRecord</type>
        </processors>
        <processors>
          <id>7f3071b9-d653-3e27-0000-000000000000</id>
          <parentGroupId>57f3f6b7-ede0-3e38-0000-000000000000</parentGroupId>
          <position>
            <x>1587.8314971865582</x>
            <y>-0.37959688641649336</y>
          </position>
          <bundle>
            <artifact>nifi-standard-nar</artifact>
            <group>org.apache.nifi</group>
            <version>1.3.0-SNAPSHOT</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</name>
    </processGroups>
  </snippet>
  <timestamp>06/05/2017 15:02:20 JST</timestamp>
</template>

Join_CSV_Files_1.2.0.xml

<?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>
              <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.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>

Hi there,

I cannot run your template because i got this error on UpdateRecord processor:
could not determine the avro schema to use for writing the content

I enabled in the template configuration AvroSchemaRegistry to make UpdateRecord run. I googled the error but found nothing.

Is it possible to get some help ?

Thanks a lot !

@JujuElk thanks for reporting that. It seems the default schema access strategy value has been changed. Please update AvroRecordSetWriter's 'Schema Access Strategy' to 'Use Schema Name Property'.

It works !

Thanks !

This will fail if the CSV have structure like this

t v a b c
t e d e
t f

hey why did you use the updateAttribute? what's the use?