Created
June 27, 2018 12:26
-
-
Save pvillard31/eeea8a462992e034ffeefc87dd7e4731 to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| <?xml version="1.0" encoding="UTF-8" standalone="yes"?> | |
| <template encoding-version="1.2"> | |
| <description></description> | |
| <groupId>01621000-4fe2-1d05-8b0e-7111cb416310</groupId> | |
| <name>post-xml-reader-writer-fork</name> | |
| <snippet> | |
| <connections> | |
| <id>13c3b3c1-3610-3a1c-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <bends> | |
| <x>937.8566284179688</x> | |
| <y>640.2774915682445</y> | |
| </bends> | |
| <bends> | |
| <x>1129.2074584960938</x> | |
| <y>641.3900098787914</y> | |
| </bends> | |
| <destination> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>521608e4-e544-3b6f-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>0</labelIndex> | |
| <name></name> | |
| <selectedRelationships>success</selectedRelationships> | |
| <source> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>1d6c2092-fc79-3daa-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>4a1050c2-1c75-3166-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <bends> | |
| <x>1480.7587280273438</x> | |
| <y>207.51336192957262</y> | |
| </bends> | |
| <destination> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>b5f920bd-734b-3ad7-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>0</labelIndex> | |
| <name></name> | |
| <selectedRelationships>success</selectedRelationships> | |
| <source> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>797afee1-7e8d-3b95-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>72db9cc2-df88-32cc-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <bends> | |
| <x>180.241455078125</x> | |
| <y>62.8878431307445</y> | |
| </bends> | |
| <destination> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>ef3aacaa-9160-3540-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>0</labelIndex> | |
| <name></name> | |
| <selectedRelationships>success</selectedRelationships> | |
| <source> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>fbe1fa13-ea6d-38f1-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>b6394b9a-1455-3e2b-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <bends> | |
| <x>940.0817260742188</x> | |
| <y>776.002955435432</y> | |
| </bends> | |
| <bends> | |
| <x>1130.3199462890625</x> | |
| <y>774.8904676424632</y> | |
| </bends> | |
| <destination> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>521608e4-e544-3b6f-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>0</labelIndex> | |
| <name></name> | |
| <selectedRelationships>success</selectedRelationships> | |
| <source> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>f613a418-60ba-3daa-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>b6ba3483-6e0e-3df3-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <bends> | |
| <x>1320.0286254882812</x> | |
| <y>453.8277540194164</y> | |
| </bends> | |
| <destination> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>b5f920bd-734b-3ad7-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>0</labelIndex> | |
| <name></name> | |
| <selectedRelationships>fork</selectedRelationships> | |
| <source> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>521608e4-e544-3b6f-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>c5421750-1513-35dd-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <bends> | |
| <x>171.34124755859375</x> | |
| <y>781.5653944002757</y> | |
| </bends> | |
| <bends> | |
| <x>338.21697998046875</x> | |
| <y>781.5655164705882</y> | |
| </bends> | |
| <destination> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>f613a418-60ba-3daa-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>1</labelIndex> | |
| <name></name> | |
| <selectedRelationships>success</selectedRelationships> | |
| <source> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>fbe1fa13-ea6d-38f1-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>cde5dac4-3621-3de1-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <destination> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>797afee1-7e8d-3b95-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>0</labelIndex> | |
| <name></name> | |
| <selectedRelationships>success</selectedRelationships> | |
| <source> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>c4e6251a-72fd-322e-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>d468d34a-6243-3aaa-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <bends> | |
| <x>173.56640625</x> | |
| <y>498.98946666590075</y> | |
| </bends> | |
| <bends> | |
| <x>341.02490234375</x> | |
| <y>498.3279371248851</y> | |
| </bends> | |
| <destination> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>588b53d3-2d5c-3b96-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>1</labelIndex> | |
| <name></name> | |
| <selectedRelationships>success</selectedRelationships> | |
| <source> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>fbe1fa13-ea6d-38f1-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>d824fe22-a5c6-3af0-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <bends> | |
| <x>1477.4212036132812</x> | |
| <y>67.3377943026195</y> | |
| </bends> | |
| <destination> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>b5f920bd-734b-3ad7-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>0</labelIndex> | |
| <name></name> | |
| <selectedRelationships>success</selectedRelationships> | |
| <source> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>ef3aacaa-9160-3540-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>f498bd5b-9a94-3934-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <bends> | |
| <x>172.45391845703125</x> | |
| <y>638.0524854647289</y> | |
| </bends> | |
| <bends> | |
| <x>334.8794860839844</x> | |
| <y>638.0524854647289</y> | |
| </bends> | |
| <destination> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>1d6c2092-fc79-3daa-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>1</labelIndex> | |
| <name></name> | |
| <selectedRelationships>success</selectedRelationships> | |
| <source> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>fbe1fa13-ea6d-38f1-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>f7d31b39-997e-3de6-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <bends> | |
| <x>935.6317138671875</x> | |
| <y>492.3144483553539</y> | |
| </bends> | |
| <bends> | |
| <x>1128.0950317382812</x> | |
| <y>491.201930044807</y> | |
| </bends> | |
| <destination> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>521608e4-e544-3b6f-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>0</labelIndex> | |
| <name></name> | |
| <selectedRelationships>success</selectedRelationships> | |
| <source> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>588b53d3-2d5c-3b96-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>fce0e8ec-b823-33f1-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <bends> | |
| <x>285.92938232421875</x> | |
| <y>206.40084361902575</y> | |
| </bends> | |
| <destination> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>c4e6251a-72fd-322e-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>0</labelIndex> | |
| <name></name> | |
| <selectedRelationships>success</selectedRelationships> | |
| <source> | |
| <groupId>8f7c4f43-5305-36c8-0000-000000000000</groupId> | |
| <id>fbe1fa13-ea6d-38f1-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <controllerServices> | |
| <id>2f3c05a3-8a59-3c53-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <bundle> | |
| <artifact>nifi-registry-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.7.0-SNAPSHOT</version> | |
| </bundle> | |
| <comments></comments> | |
| <descriptors> | |
| <entry> | |
| <key>avro-reg-validated-field-names</key> | |
| <value> | |
| <name>avro-reg-validated-field-names</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>account</key> | |
| <value> | |
| <name>account</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>address</key> | |
| <value> | |
| <name>address</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>bank-full-schema</key> | |
| <value> | |
| <name>bank-full-schema</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>customer</key> | |
| <value> | |
| <name>customer</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>transaction</key> | |
| <value> | |
| <name>transaction</name> | |
| </value> | |
| </entry> | |
| </descriptors> | |
| <name>AvroSchemaRegistry</name> | |
| <persistsState>false</persistsState> | |
| <properties> | |
| <entry> | |
| <key>avro-reg-validated-field-names</key> | |
| <value>true</value> | |
| </entry> | |
| <entry> | |
| <key>account</key> | |
| <value>{ | |
| "type" : "record", | |
| "name" : "account", | |
| "namespace" : "account", | |
| "fields" : [ { | |
| "name" : "customer_id", "type" : "long" | |
| }, { | |
| "name" : "name", "type" : "string" | |
| }, { | |
| "name" : "account_id", "type" : "long" | |
| }, { | |
| "name" : "shortname", "type" : "string" | |
| }, { | |
| "name" : "balance", "type" : "double" | |
| } ] | |
| }</value> | |
| </entry> | |
| <entry> | |
| <key>address</key> | |
| <value>{ | |
| "type" : "record", | |
| "name" : "address", | |
| "namespace" : "address", | |
| "fields" : [ { | |
| "name" : "customer_id", "type" : "long" | |
| }, { | |
| "name" : "name", "type" : "string" | |
| }, { | |
| "name" : "type", "type" : "string" | |
| }, { | |
| "name" : "value", "type" : "string" | |
| } ] | |
| }</value> | |
| </entry> | |
| <entry> | |
| <key>bank-full-schema</key> | |
| <value>{ | |
| "type" : "record", | |
| "name" : "customers", | |
| "namespace" : "customer", | |
| "fields" : [ { | |
| "name" : "customer_id", "type" : "long" | |
| }, { | |
| "name" : "name", "type" : "string" | |
| }, { | |
| "name" : "addresses", | |
| "type" : { | |
| "type" : "record", | |
| "name" : "customers", | |
| "namespace" : "addresses.customer", | |
| "fields" : [ { | |
| "name" : "address", | |
| "type" : { | |
| "type" : "array", | |
| "items" : { | |
| "type" : "record", | |
| "name" : "customers", | |
| "namespace" : "address.addresses.customer", | |
| "fields" : [ { | |
| "name" : "type", "type" : "string" | |
| }, { | |
| "name" : "value", "type" : "string" | |
| } ] | |
| } | |
| } | |
| } ] | |
| } | |
| }, { | |
| "name" : "accounts", | |
| "type" : { | |
| "type" : "record", | |
| "name" : "customers", | |
| "namespace" : "accounts.customer", | |
| "fields" : [ { | |
| "name" : "account", | |
| "type" : { | |
| "type" : "array", | |
| "items" : { | |
| "type" : "record", | |
| "name" : "customers", | |
| "namespace" : "account.accounts.customer", | |
| "fields" : [ { | |
| "name" : "account_id", "type" : "long" | |
| }, { | |
| "name" : "shortname", "type" : "string" | |
| }, { | |
| "name" : "balance", "type" : "double" | |
| }, { | |
| "name" : "transactions", | |
| "type" : [ "null", { | |
| "type" : "record", | |
| "name" : "customers", | |
| "namespace" : "transactions.account.accounts.customer", | |
| "fields" : [ { | |
| "name" : "transaction", | |
| "type" : { | |
| "type" : "array", | |
| "items" : { | |
| "type" : "record", | |
| "name" : "customers", | |
| "namespace" : "transaction.transactions.account.accounts.customer", | |
| "fields" : [ { | |
| "name" : "transaction_id", "type" : "long" | |
| }, { | |
| "name" : "source_account_id", "type" : "long" | |
| }, { | |
| "name" : "destination_account_id", "type" : "long" | |
| }, { | |
| "name" : "amount", "type" : "double" | |
| } ] | |
| } | |
| } | |
| } ] | |
| } ] | |
| } ] | |
| } | |
| } | |
| } ] | |
| } | |
| } ] | |
| }</value> | |
| </entry> | |
| <entry> | |
| <key>customer</key> | |
| <value>{ | |
| "type" : "record", | |
| "name" : "customers", | |
| "namespace" : "customer", | |
| "fields" : [ { | |
| "name" : "customer_id", "type" : "long" | |
| }, { | |
| "name" : "name", "type" : "string" | |
| } ] | |
| }</value> | |
| </entry> | |
| <entry> | |
| <key>transaction</key> | |
| <value>{ | |
| "type" : "record", | |
| "name" : "transaction", | |
| "namespace" : "transaction", | |
| "fields" : [ { | |
| "name" : "customer_id", "type" : "long" | |
| }, { | |
| "name" : "name", "type" : "string" | |
| }, { | |
| "name" : "transaction_id", "type" : "long" | |
| }, { | |
| "name" : "source_account_id", "type" : "long" | |
| }, { | |
| "name" : "destination_account_id", "type" : "long" | |
| }, { | |
| "name" : "amount", "type" : "double" | |
| }, { | |
| "name" : "account_id", "type" : "long" | |
| } ] | |
| }</value> | |
| </entry> | |
| </properties> | |
| <state>ENABLED</state> | |
| <type>org.apache.nifi.schemaregistry.services.AvroSchemaRegistry</type> | |
| </controllerServices> | |
| <controllerServices> | |
| <id>47f4f2a4-649e-322d-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <bundle> | |
| <artifact>nifi-record-serialization-services-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.7.0-SNAPSHOT</version> | |
| </bundle> | |
| <comments></comments> | |
| <descriptors> | |
| <entry> | |
| <key>Schema Write Strategy</key> | |
| <value> | |
| <name>Schema Write Strategy</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-access-strategy</key> | |
| <value> | |
| <name>schema-access-strategy</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-registry</key> | |
| <value> | |
| <identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
| <name>schema-registry</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-name</key> | |
| <value> | |
| <name>schema-name</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-version</key> | |
| <value> | |
| <name>schema-version</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-branch</key> | |
| <value> | |
| <name>schema-branch</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-text</key> | |
| <value> | |
| <name>schema-text</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Date Format</key> | |
| <value> | |
| <name>Date Format</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Time Format</key> | |
| <value> | |
| <name>Time Format</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Timestamp Format</key> | |
| <value> | |
| <name>Timestamp Format</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Pretty Print JSON</key> | |
| <value> | |
| <name>Pretty Print JSON</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>suppress-nulls</key> | |
| <value> | |
| <name>suppress-nulls</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>output-grouping</key> | |
| <value> | |
| <name>output-grouping</name> | |
| </value> | |
| </entry> | |
| </descriptors> | |
| <name>JsonRecordSetWriter</name> | |
| <persistsState>false</persistsState> | |
| <properties> | |
| <entry> | |
| <key>Schema Write Strategy</key> | |
| <value>no-schema</value> | |
| </entry> | |
| <entry> | |
| <key>schema-access-strategy</key> | |
| </entry> | |
| <entry> | |
| <key>schema-registry</key> | |
| </entry> | |
| <entry> | |
| <key>schema-name</key> | |
| </entry> | |
| <entry> | |
| <key>schema-version</key> | |
| </entry> | |
| <entry> | |
| <key>schema-branch</key> | |
| </entry> | |
| <entry> | |
| <key>schema-text</key> | |
| </entry> | |
| <entry> | |
| <key>Date Format</key> | |
| </entry> | |
| <entry> | |
| <key>Time Format</key> | |
| </entry> | |
| <entry> | |
| <key>Timestamp Format</key> | |
| </entry> | |
| <entry> | |
| <key>Pretty Print JSON</key> | |
| </entry> | |
| <entry> | |
| <key>suppress-nulls</key> | |
| </entry> | |
| <entry> | |
| <key>output-grouping</key> | |
| </entry> | |
| </properties> | |
| <state>ENABLED</state> | |
| <type>org.apache.nifi.json.JsonRecordSetWriter</type> | |
| </controllerServices> | |
| <controllerServices> | |
| <id>506505cc-9b39-33f8-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <bundle> | |
| <artifact>nifi-record-serialization-services-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.7.0-SNAPSHOT</version> | |
| </bundle> | |
| <comments></comments> | |
| <descriptors> | |
| <entry> | |
| <key>Schema Write Strategy</key> | |
| <value> | |
| <name>Schema Write Strategy</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-access-strategy</key> | |
| <value> | |
| <name>schema-access-strategy</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-registry</key> | |
| <value> | |
| <identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
| <name>schema-registry</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-name</key> | |
| <value> | |
| <name>schema-name</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-version</key> | |
| <value> | |
| <name>schema-version</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-branch</key> | |
| <value> | |
| <name>schema-branch</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-text</key> | |
| <value> | |
| <name>schema-text</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Date Format</key> | |
| <value> | |
| <name>Date Format</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Time Format</key> | |
| <value> | |
| <name>Time Format</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Timestamp Format</key> | |
| <value> | |
| <name>Timestamp Format</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>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> | |
| <entry> | |
| <key>csvutils-character-set</key> | |
| <value> | |
| <name>csvutils-character-set</name> | |
| </value> | |
| </entry> | |
| </descriptors> | |
| <name>CSVRecordSetWriter</name> | |
| <persistsState>false</persistsState> | |
| <properties> | |
| <entry> | |
| <key>Schema Write Strategy</key> | |
| <value>no-schema</value> | |
| </entry> | |
| <entry> | |
| <key>schema-access-strategy</key> | |
| <value>schema-name</value> | |
| </entry> | |
| <entry> | |
| <key>schema-registry</key> | |
| <value>2f3c05a3-8a59-3c53-0000-000000000000</value> | |
| </entry> | |
| <entry> | |
| <key>schema-name</key> | |
| <value>${output.schema}</value> | |
| </entry> | |
| <entry> | |
| <key>schema-version</key> | |
| </entry> | |
| <entry> | |
| <key>schema-branch</key> | |
| </entry> | |
| <entry> | |
| <key>schema-text</key> | |
| </entry> | |
| <entry> | |
| <key>Date Format</key> | |
| </entry> | |
| <entry> | |
| <key>Time Format</key> | |
| </entry> | |
| <entry> | |
| <key>Timestamp Format</key> | |
| </entry> | |
| <entry> | |
| <key>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> | |
| <entry> | |
| <key>csvutils-character-set</key> | |
| </entry> | |
| </properties> | |
| <state>ENABLED</state> | |
| <type>org.apache.nifi.csv.CSVRecordSetWriter</type> | |
| </controllerServices> | |
| <controllerServices> | |
| <id>c8a845e5-7857-3bb6-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <bundle> | |
| <artifact>nifi-record-serialization-services-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.7.0-SNAPSHOT</version> | |
| </bundle> | |
| <comments></comments> | |
| <descriptors> | |
| <entry> | |
| <key>schema-access-strategy</key> | |
| <value> | |
| <name>schema-access-strategy</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-registry</key> | |
| <value> | |
| <identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
| <name>schema-registry</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-name</key> | |
| <value> | |
| <name>schema-name</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-version</key> | |
| <value> | |
| <name>schema-version</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-branch</key> | |
| <value> | |
| <name>schema-branch</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>schema-text</key> | |
| <value> | |
| <name>schema-text</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>record_format</key> | |
| <value> | |
| <name>record_format</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>attribute_prefix</key> | |
| <value> | |
| <name>attribute_prefix</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>content_field_name</key> | |
| <value> | |
| <name>content_field_name</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Date Format</key> | |
| <value> | |
| <name>Date Format</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Time Format</key> | |
| <value> | |
| <name>Time Format</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Timestamp Format</key> | |
| <value> | |
| <name>Timestamp Format</name> | |
| </value> | |
| </entry> | |
| </descriptors> | |
| <name>XMLReader</name> | |
| <persistsState>false</persistsState> | |
| <properties> | |
| <entry> | |
| <key>schema-access-strategy</key> | |
| <value>schema-name</value> | |
| </entry> | |
| <entry> | |
| <key>schema-registry</key> | |
| <value>2f3c05a3-8a59-3c53-0000-000000000000</value> | |
| </entry> | |
| <entry> | |
| <key>schema-name</key> | |
| <value>${schema.name}</value> | |
| </entry> | |
| <entry> | |
| <key>schema-version</key> | |
| </entry> | |
| <entry> | |
| <key>schema-branch</key> | |
| </entry> | |
| <entry> | |
| <key>schema-text</key> | |
| <value>${avro.schema}</value> | |
| </entry> | |
| <entry> | |
| <key>record_format</key> | |
| <value>true</value> | |
| </entry> | |
| <entry> | |
| <key>attribute_prefix</key> | |
| </entry> | |
| <entry> | |
| <key>content_field_name</key> | |
| </entry> | |
| <entry> | |
| <key>Date Format</key> | |
| </entry> | |
| <entry> | |
| <key>Time Format</key> | |
| </entry> | |
| <entry> | |
| <key>Timestamp Format</key> | |
| </entry> | |
| </properties> | |
| <state>ENABLED</state> | |
| <type>org.apache.nifi.xml.XMLReader</type> | |
| </controllerServices> | |
| <processors> | |
| <id>1d6c2092-fc79-3daa-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>472.1637262230397</x> | |
| <y>571.9308743612924</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-update-attribute-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.7.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>fork.path</key> | |
| <value> | |
| <name>fork.path</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>output.schema</key> | |
| <value> | |
| <name>output.schema</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>fork.path</key> | |
| <value>/addresses/address</value> | |
| </entry> | |
| <entry> | |
| <key>output.schema</key> | |
| <value>address</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>0 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>Schema attribute - address</name> | |
| <relationships> | |
| <autoTerminate>false</autoTerminate> | |
| <name>success</name> | |
| </relationships> | |
| <state>STOPPED</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.attributes.UpdateAttribute</type> | |
| </processors> | |
| <processors> | |
| <id>521608e4-e544-3b6f-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>951.7899012944195</x> | |
| <y>279.16462262834784</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-standard-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.7.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>fork-mode</key> | |
| <value> | |
| <name>fork-mode</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>include-parent-fields</key> | |
| <value> | |
| <name>include-parent-fields</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>path</key> | |
| <value> | |
| <name>path</name> | |
| </value> | |
| </entry> | |
| </descriptors> | |
| <executionNode>ALL</executionNode> | |
| <lossTolerant>false</lossTolerant> | |
| <penaltyDuration>30 sec</penaltyDuration> | |
| <properties> | |
| <entry> | |
| <key>record-reader</key> | |
| <value>c8a845e5-7857-3bb6-0000-000000000000</value> | |
| </entry> | |
| <entry> | |
| <key>record-writer</key> | |
| <value>506505cc-9b39-33f8-0000-000000000000</value> | |
| </entry> | |
| <entry> | |
| <key>fork-mode</key> | |
| <value>extract</value> | |
| </entry> | |
| <entry> | |
| <key>include-parent-fields</key> | |
| <value>true</value> | |
| </entry> | |
| <entry> | |
| <key>path</key> | |
| <value>${fork.path}</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>0 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>ForkRecord</name> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>failure</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>false</autoTerminate> | |
| <name>fork</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>original</name> | |
| </relationships> | |
| <state>STOPPED</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.standard.ForkRecord</type> | |
| </processors> | |
| <processors> | |
| <id>588b53d3-2d5c-3b96-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>471.6388238792897</x> | |
| <y>429.00542880465173</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-update-attribute-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.7.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>fork.path</key> | |
| <value> | |
| <name>fork.path</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>output.schema</key> | |
| <value> | |
| <name>output.schema</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>fork.path</key> | |
| <value>/accounts/account</value> | |
| </entry> | |
| <entry> | |
| <key>output.schema</key> | |
| <value>account</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>0 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>Schema attribute - account</name> | |
| <relationships> | |
| <autoTerminate>false</autoTerminate> | |
| <name>success</name> | |
| </relationships> | |
| <state>STOPPED</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.attributes.UpdateAttribute</type> | |
| </processors> | |
| <processors> | |
| <id>797afee1-7e8d-3b95-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>953.4317222347099</x> | |
| <y>139.650634765625</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-standard-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.7.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> | |
| </descriptors> | |
| <executionNode>ALL</executionNode> | |
| <lossTolerant>false</lossTolerant> | |
| <penaltyDuration>30 sec</penaltyDuration> | |
| <properties> | |
| <entry> | |
| <key>record-reader</key> | |
| <value>c8a845e5-7857-3bb6-0000-000000000000</value> | |
| </entry> | |
| <entry> | |
| <key>record-writer</key> | |
| <value>506505cc-9b39-33f8-0000-000000000000</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>0 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>ConvertRecord - XML to CSV - customers</name> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>failure</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>false</autoTerminate> | |
| <name>success</name> | |
| </relationships> | |
| <state>STOPPED</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.standard.ConvertRecord</type> | |
| </processors> | |
| <processors> | |
| <id>b5f920bd-734b-3ad7-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>1309.9420465355397</x> | |
| <y>279.4049801962533</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-update-attribute-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.7.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> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>UpdateAttribute</name> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>success</name> | |
| </relationships> | |
| <state>STOPPED</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.attributes.UpdateAttribute</type> | |
| </processors> | |
| <processors> | |
| <id>c4e6251a-72fd-322e-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>392.06344546132095</x> | |
| <y>140.27935458590173</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-update-attribute-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.7.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>output.schema</key> | |
| <value> | |
| <name>output.schema</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>output.schema</key> | |
| <value>customer</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>0 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>Schema attribute - customer</name> | |
| <relationships> | |
| <autoTerminate>false</autoTerminate> | |
| <name>success</name> | |
| </relationships> | |
| <state>STOPPED</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.attributes.UpdateAttribute</type> | |
| </processors> | |
| <processors> | |
| <id>ef3aacaa-9160-3540-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>951.7315269222099</x> | |
| <y>0.0</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-standard-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.7.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> | |
| </descriptors> | |
| <executionNode>ALL</executionNode> | |
| <lossTolerant>false</lossTolerant> | |
| <penaltyDuration>30 sec</penaltyDuration> | |
| <properties> | |
| <entry> | |
| <key>record-reader</key> | |
| <value>c8a845e5-7857-3bb6-0000-000000000000</value> | |
| </entry> | |
| <entry> | |
| <key>record-writer</key> | |
| <value>47f4f2a4-649e-322d-0000-000000000000</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>0 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>ConvertRecord - XML to JSON full</name> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>failure</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>false</autoTerminate> | |
| <name>success</name> | |
| </relationships> | |
| <state>STOPPED</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.standard.ConvertRecord</type> | |
| </processors> | |
| <processors> | |
| <id>f613a418-60ba-3daa-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>472.1009820824147</x> | |
| <y>714.2687039511361</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-update-attribute-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.7.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>fork.path</key> | |
| <value> | |
| <name>fork.path</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>output.schema</key> | |
| <value> | |
| <name>output.schema</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>fork.path</key> | |
| <value>/accounts/account[*]/transactions/transaction</value> | |
| </entry> | |
| <entry> | |
| <key>output.schema</key> | |
| <value>transaction</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>0 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>Schema attribute - transaction</name> | |
| <relationships> | |
| <autoTerminate>false</autoTerminate> | |
| <name>success</name> | |
| </relationships> | |
| <state>STOPPED</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.attributes.UpdateAttribute</type> | |
| </processors> | |
| <processors> | |
| <id>fbe1fa13-ea6d-38f1-0000-000000000000</id> | |
| <parentGroupId>8f7c4f43-5305-36c8-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>0.0</x> | |
| <y>278.56734752527575</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-standard-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.7.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>character-set</key> | |
| <value> | |
| <name>character-set</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>mime.type</key> | |
| <value> | |
| <name>mime.type</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>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><customers> | |
| <customer customer_id="1" name="John Doe"> | |
| <addresses> | |
| <address type="home" value="1 Apache NiFi street, Nifiville" /> | |
| <address type="work" value="10 MiNiFi avenue, Nifiville" /> | |
| </addresses> | |
| <accounts> | |
| <account account_id="1" shortname="perso" balance="1234.56" /> | |
| <account account_id="2" shortname="joint" balance="2345.67"> | |
| <transactions> | |
| <transaction transaction_id="1" source_account_id="123" destination_account_id="2" amount="123.00" /> | |
| <transaction transaction_id="2" source_account_id="3" destination_account_id="2" amount="500.00" /> | |
| </transactions> | |
| </account> | |
| </accounts> | |
| </customer> | |
| <customer customer_id="2" name="Jane Doe"> | |
| <addresses> | |
| <address type="home" value="1 Apache NiFi street, Nifiville" /> | |
| </addresses> | |
| <accounts> | |
| <account account_id="3" shortname="perso" balance="3333.33"> | |
| <transactions> | |
| <transaction transaction_id="2" source_account_id="3" destination_account_id="2" amount="500.00" /> | |
| </transactions> | |
| </account> | |
| </accounts> | |
| </customer> | |
| </customers></value> | |
| </entry> | |
| <entry> | |
| <key>character-set</key> | |
| <value>UTF-8</value> | |
| </entry> | |
| <entry> | |
| <key>mime.type</key> | |
| <value>application/xml</value> | |
| </entry> | |
| <entry> | |
| <key>schema.name</key> | |
| <value>bank-full-schema</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>10 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>Generate XML data</name> | |
| <relationships> | |
| <autoTerminate>false</autoTerminate> | |
| <name>success</name> | |
| </relationships> | |
| <state>STOPPED</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.standard.GenerateFlowFile</type> | |
| </processors> | |
| </snippet> | |
| <timestamp>06/27/2018 14:25:51 CEST</timestamp> | |
| </template> |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment