Created
June 27, 2018 12:26
-
-
Save pvillard31/eeea8a462992e034ffeefc87dd7e4731 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<?xml version="1.0" encoding="UTF-8" standalone="yes"?> | |
<template encoding-version="1.2"> | |
<description></description> | |
<groupId>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