Repository: nifi-minifi Updated Branches: refs/heads/master 1bbeedf6f -> 31855bbc7
http://git-wip-us.apache.org/repos/asf/nifi-minifi/blob/31855bbc/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/ProcessGroupsAndRemoteProcessGroups.xml ---------------------------------------------------------------------- diff --git a/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/ProcessGroupsAndRemoteProcessGroups.xml b/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/ProcessGroupsAndRemoteProcessGroups.xml new file mode 100644 index 0000000..8cd6f1b --- /dev/null +++ b/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/ProcessGroupsAndRemoteProcessGroups.xml @@ -0,0 +1,648 @@ +<?xml version="1.0" ?> +<!-- +Licensed to the Apache Software Foundation (ASF) under one or more +contributor license agreements. See the NOTICE file distributed with +this work for additional information regarding copyright ownership. +The ASF licenses this file to You under the Apache License, Version 2.0 +(the "License"); you may not use this file except in compliance with +the License. You may obtain a copy of the License at + http://www.apache.org/licenses/LICENSE-2.0 +Unless required by applicable law or agreed to in writing, software +distributed under the License is distributed on an "AS IS" BASIS, +WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +See the License for the specific language governing permissions and +limitations under the License. + --> +<template encoding-version="1.0"> + <description></description> + <groupId>21a36442-0158-1000-dec0-d25353fe677c</groupId> + <name>ProcessGroupsAndRemoteProcessGroups</name> + <snippet> + <connections> + <id>2077bf8f-0158-1000-0000-000000000000</id> + <parentGroupId>21a36442-0158-1000-0000-000000000000</parentGroupId> + <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> + <backPressureObjectThreshold>10000</backPressureObjectThreshold> + <destination> + <groupId>21a36442-0158-1000-0000-000000000000</groupId> + <id>2077ab1e-0158-1000-0000-000000000000</id> + <type>PROCESSOR</type> + </destination> + <flowFileExpiration>0 sec</flowFileExpiration> + <labelIndex>1</labelIndex> + <name></name> + <selectedRelationships>success</selectedRelationships> + <source> + <groupId>21a36442-0158-1000-0000-000000000000</groupId> + <id>207748d1-0158-1000-0000-000000000000</id> + <type>PROCESSOR</type> + </source> + <zIndex>0</zIndex> + </connections> + <connections> + <id>2079cf6f-0158-1000-0000-000000000000</id> + <parentGroupId>21a36442-0158-1000-0000-000000000000</parentGroupId> + <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> + <backPressureObjectThreshold>10000</backPressureObjectThreshold> + <destination> + <groupId>207888b1-0158-1000-0000-000000000000</groupId> + <id>2078c936-0158-1000-0000-000000000000</id> + <type>INPUT_PORT</type> + </destination> + <flowFileExpiration>0 sec</flowFileExpiration> + <labelIndex>1</labelIndex> + <name></name> + <selectedRelationships>success</selectedRelationships> + <source> + <groupId>21a36442-0158-1000-0000-000000000000</groupId> + <id>2077ab1e-0158-1000-0000-000000000000</id> + <type>PROCESSOR</type> + </source> + <zIndex>0</zIndex> + </connections> + <connections> + <id>2079faa0-0158-1000-0000-000000000000</id> + <parentGroupId>21a36442-0158-1000-0000-000000000000</parentGroupId> + <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> + <backPressureObjectThreshold>10000</backPressureObjectThreshold> + <destination> + <groupId>21a36442-0158-1000-0000-000000000000</groupId> + <id>2079e8bd-0158-1000-0000-000000000000</id> + <type>PROCESSOR</type> + </destination> + <flowFileExpiration>0 sec</flowFileExpiration> + <labelIndex>1</labelIndex> + <name></name> + <source> + <groupId>207888b1-0158-1000-0000-000000000000</groupId> + <id>2079b327-0158-1000-0000-000000000000</id> + <type>OUTPUT_PORT</type> + </source> + <zIndex>0</zIndex> + </connections> + <processGroups> + <id>207888b1-0158-1000-0000-000000000000</id> + <parentGroupId>21a36442-0158-1000-0000-000000000000</parentGroupId> + <position> + <x>0.0</x> + <y>447.0719299316406</y> + </position> + <comments></comments> + <contents> + <connections> + <id>20792ec2-0158-1000-0000-000000000000</id> + <parentGroupId>207888b1-0158-1000-0000-000000000000</parentGroupId> + <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> + <backPressureObjectThreshold>10000</backPressureObjectThreshold> + <destination> + <groupId>207888b1-0158-1000-0000-000000000000</groupId> + <id>2078f34e-0158-1000-0000-000000000000</id> + <type>PROCESSOR</type> + </destination> + <flowFileExpiration>0 sec</flowFileExpiration> + <labelIndex>1</labelIndex> + <name></name> + <source> + <groupId>207888b1-0158-1000-0000-000000000000</groupId> + <id>2078c936-0158-1000-0000-000000000000</id> + <type>INPUT_PORT</type> + </source> + <zIndex>0</zIndex> + </connections> + <connections> + <id>207b0eb1-0158-1000-0000-000000000000</id> + <parentGroupId>207888b1-0158-1000-0000-000000000000</parentGroupId> + <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> + <backPressureObjectThreshold>10000</backPressureObjectThreshold> + <destination> + <groupId>20794cd4-0158-1000-0000-000000000000</groupId> + <id>207a5f50-0158-1000-0000-000000000000</id> + <type>INPUT_PORT</type> + </destination> + <flowFileExpiration>0 sec</flowFileExpiration> + <labelIndex>1</labelIndex> + <name></name> + <selectedRelationships>success</selectedRelationships> + <source> + <groupId>207888b1-0158-1000-0000-000000000000</groupId> + <id>2078f34e-0158-1000-0000-000000000000</id> + <type>PROCESSOR</type> + </source> + <zIndex>0</zIndex> + </connections> + <connections> + <id>207b1880-0158-1000-0000-000000000000</id> + <parentGroupId>207888b1-0158-1000-0000-000000000000</parentGroupId> + <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> + <backPressureObjectThreshold>10000</backPressureObjectThreshold> + <destination> + <groupId>207888b1-0158-1000-0000-000000000000</groupId> + <id>2079b327-0158-1000-0000-000000000000</id> + <type>OUTPUT_PORT</type> + </destination> + <flowFileExpiration>0 sec</flowFileExpiration> + <labelIndex>1</labelIndex> + <name></name> + <source> + <groupId>20794cd4-0158-1000-0000-000000000000</groupId> + <id>207a6d92-0158-1000-0000-000000000000</id> + <type>OUTPUT_PORT</type> + </source> + <zIndex>0</zIndex> + </connections> + <connections> + <id>21a5b1f1-0158-1000-0000-000000000000</id> + <parentGroupId>207888b1-0158-1000-0000-000000000000</parentGroupId> + <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> + <backPressureObjectThreshold>10000</backPressureObjectThreshold> + <destination> + <groupId>21a4e2f0-0158-1000-0000-000000000000</groupId> + <id>21a2fb5e-0158-1000-3b5e-5a7d3aaee01b</id> + <type>REMOTE_INPUT_PORT</type> + </destination> + <flowFileExpiration>0 sec</flowFileExpiration> + <labelIndex>1</labelIndex> + <name></name> + <selectedRelationships>success</selectedRelationships> + <source> + <groupId>207888b1-0158-1000-0000-000000000000</groupId> + <id>2078f34e-0158-1000-0000-000000000000</id> + <type>PROCESSOR</type> + </source> + <zIndex>0</zIndex> + </connections> + <inputPorts> + <id>2078c936-0158-1000-0000-000000000000</id> + <parentGroupId>207888b1-0158-1000-0000-000000000000</parentGroupId> + <position> + <x>433.0000001775595</x> + <y>46.99999825784364</y> + </position> + <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> + <name>input</name> + <state>STOPPED</state> + <type>INPUT_PORT</type> + </inputPorts> + <outputPorts> + <id>2079b327-0158-1000-0000-000000000000</id> + <parentGroupId>207888b1-0158-1000-0000-000000000000</parentGroupId> + <position> + <x>445.68731178433825</x> + <y>666.1011812611806</y> + </position> + <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> + <name>output</name> + <state>STOPPED</state> + <type>OUTPUT_PORT</type> + </outputPorts> + <processGroups> + <id>20794cd4-0158-1000-0000-000000000000</id> + <parentGroupId>207888b1-0158-1000-0000-000000000000</parentGroupId> + <position> + <x>371.304682389807</x> + <y>397.8012321556296</y> + </position> + <comments></comments> + <contents> + <connections> + <id>207aca0d-0158-1000-0000-000000000000</id> + <parentGroupId>20794cd4-0158-1000-0000-000000000000</parentGroupId> + <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> + <backPressureObjectThreshold>10000</backPressureObjectThreshold> + <destination> + <groupId>20794cd4-0158-1000-0000-000000000000</groupId> + <id>207a89ba-0158-1000-0000-000000000000</id> + <type>PROCESSOR</type> + </destination> + <flowFileExpiration>0 sec</flowFileExpiration> + <labelIndex>1</labelIndex> + <name></name> + <source> + <groupId>20794cd4-0158-1000-0000-000000000000</groupId> + <id>207a5f50-0158-1000-0000-000000000000</id> + <type>INPUT_PORT</type> + </source> + <zIndex>0</zIndex> + </connections> + <connections> + <id>207ad5e9-0158-1000-0000-000000000000</id> + <parentGroupId>20794cd4-0158-1000-0000-000000000000</parentGroupId> + <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> + <backPressureObjectThreshold>10000</backPressureObjectThreshold> + <destination> + <groupId>20794cd4-0158-1000-0000-000000000000</groupId> + <id>207a6d92-0158-1000-0000-000000000000</id> + <type>OUTPUT_PORT</type> + </destination> + <flowFileExpiration>0 sec</flowFileExpiration> + <labelIndex>1</labelIndex> + <name></name> + <selectedRelationships>success</selectedRelationships> + <source> + <groupId>20794cd4-0158-1000-0000-000000000000</groupId> + <id>207a89ba-0158-1000-0000-000000000000</id> + <type>PROCESSOR</type> + </source> + <zIndex>0</zIndex> + </connections> + <connections> + <id>21a6abb9-0158-1000-0000-000000000000</id> + <parentGroupId>20794cd4-0158-1000-0000-000000000000</parentGroupId> + <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> + <backPressureObjectThreshold>10000</backPressureObjectThreshold> + <destination> + <groupId>21a651bb-0158-1000-0000-000000000000</groupId> + <id>21a39aba-0158-1000-a1a0-1b55bcddcd72</id> + <type>REMOTE_INPUT_PORT</type> + </destination> + <flowFileExpiration>0 sec</flowFileExpiration> + <labelIndex>1</labelIndex> + <name></name> + <selectedRelationships>success</selectedRelationships> + <source> + <groupId>20794cd4-0158-1000-0000-000000000000</groupId> + <id>207a89ba-0158-1000-0000-000000000000</id> + <type>PROCESSOR</type> + </source> + <zIndex>0</zIndex> + </connections> + <inputPorts> + <id>207a5f50-0158-1000-0000-000000000000</id> + <parentGroupId>20794cd4-0158-1000-0000-000000000000</parentGroupId> + <position> + <x>570.9999962395234</x> + <y>37.999998611138864</y> + </position> + <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> + <name>input</name> + <state>STOPPED</state> + <type>INPUT_PORT</type> + </inputPorts> + <outputPorts> + <id>207a6d92-0158-1000-0000-000000000000</id> + <parentGroupId>20794cd4-0158-1000-0000-000000000000</parentGroupId> + <position> + <x>567.9999962395234</x> + <y>343.99999861113884</y> + </position> + <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> + <name>output</name> + <state>STOPPED</state> + <type>OUTPUT_PORT</type> + </outputPorts> + <processors> + <id>207a89ba-0158-1000-0000-000000000000</id> + <parentGroupId>20794cd4-0158-1000-0000-000000000000</parentGroupId> + <position> + <x>509.9999962395234</x> + <y>146.99999861113886</y> + </position> + <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>bottom</key> + <value> + <name>bottom</name> + </value> + </entry> + </descriptors> + <lossTolerant>false</lossTolerant> + <penaltyDuration>30 sec</penaltyDuration> + <properties> + <entry> + <key>Delete Attributes Expression</key> + </entry> + <entry> + <key>bottom</key> + <value>bottom</value> + </entry> + </properties> + <runDurationMillis>0</runDurationMillis> + <schedulingPeriod>0 sec</schedulingPeriod> + <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> + <yieldDuration>1 sec</yieldDuration> + </config> + <name>UpdateAttribute</name> + <relationships> + <autoTerminate>false</autoTerminate> + <name>success</name> + </relationships> + <style></style> + <type>org.apache.nifi.processors.attributes.UpdateAttribute</type> + </processors> + <remoteProcessGroups> + <id>21a651bb-0158-1000-0000-000000000000</id> + <parentGroupId>20794cd4-0158-1000-0000-000000000000</parentGroupId> + <position> + <x>1140.0000482871</x> + <y>130.0000033911915</y> + </position> + <communicationsTimeout>30 sec</communicationsTimeout> + <contents> + <inputPorts> + <comments></comments> + <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> + <connected>true</connected> + <exists>true</exists> + <id>21a39aba-0158-1000-a1a0-1b55bcddcd72</id> + <name>input2</name> + <targetRunning>true</targetRunning> + <transmitting>false</transmitting> + <useCompression>false</useCompression> + </inputPorts> + </contents> + <proxyHost></proxyHost> + <proxyUser></proxyUser> + <targetUri>http://localhost:9091/nifi</targetUri> + <transportProtocol>RAW</transportProtocol> + <yieldDuration>10 sec</yieldDuration> + </remoteProcessGroups> + </contents> + <name>bottom</name> + </processGroups> + <processors> + <id>2078f34e-0158-1000-0000-000000000000</id> + <parentGroupId>207888b1-0158-1000-0000-000000000000</parentGroupId> + <position> + <x>377.497680841622</x> + <y>186.3363935215155</y> + </position> + <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>middle</key> + <value> + <name>middle</name> + </value> + </entry> + </descriptors> + <lossTolerant>false</lossTolerant> + <penaltyDuration>30 sec</penaltyDuration> + <properties> + <entry> + <key>Delete Attributes Expression</key> + </entry> + <entry> + <key>middle</key> + <value>middle</value> + </entry> + </properties> + <runDurationMillis>0</runDurationMillis> + <schedulingPeriod>0 sec</schedulingPeriod> + <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> + <yieldDuration>1 sec</yieldDuration> + </config> + <name>UpdateAttribute</name> + <relationships> + <autoTerminate>false</autoTerminate> + <name>success</name> + </relationships> + <style></style> + <type>org.apache.nifi.processors.attributes.UpdateAttribute</type> + </processors> + <remoteProcessGroups> + <id>21a4e2f0-0158-1000-0000-000000000000</id> + <parentGroupId>207888b1-0158-1000-0000-000000000000</parentGroupId> + <position> + <x>1004.6132741275832</x> + <y>175.0721786721599</y> + </position> + <communicationsTimeout>30 sec</communicationsTimeout> + <contents> + <inputPorts> + <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> + <connected>true</connected> + <exists>true</exists> + <id>21a2fb5e-0158-1000-3b5e-5a7d3aaee01b</id> + <name>input</name> + <targetRunning>true</targetRunning> + <transmitting>false</transmitting> + <useCompression>false</useCompression> + </inputPorts> + </contents> + <proxyHost></proxyHost> + <proxyUser></proxyUser> + <targetUri>http://localhost:9090/nifi</targetUri> + <transportProtocol>RAW</transportProtocol> + <yieldDuration>10 sec</yieldDuration> + </remoteProcessGroups> + </contents> + <name>middle</name> + </processGroups> + <processors> + <id>207748d1-0158-1000-0000-000000000000</id> + <parentGroupId>21a36442-0158-1000-0000-000000000000</parentGroupId> + <position> + <x>8.7503662109375</x> + <y>0.0</y> + </position> + <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> + </descriptors> + <lossTolerant>false</lossTolerant> + <penaltyDuration>30 sec</penaltyDuration> + <properties> + <entry> + <key>File Size</key> + <value>1 b</value> + </entry> + <entry> + <key>Batch Size</key> + <value>1</value> + </entry> + <entry> + <key>Data Format</key> + <value>Binary</value> + </entry> + <entry> + <key>Unique FlowFiles</key> + <value>false</value> + </entry> + </properties> + <runDurationMillis>0</runDurationMillis> + <schedulingPeriod>0 sec</schedulingPeriod> + <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> + <yieldDuration>1 sec</yieldDuration> + </config> + <name>GenerateFlowFile</name> + <relationships> + <autoTerminate>false</autoTerminate> + <name>success</name> + </relationships> + <style></style> + <type>org.apache.nifi.processors.standard.GenerateFlowFile</type> + </processors> + <processors> + <id>2077ab1e-0158-1000-0000-000000000000</id> + <parentGroupId>21a36442-0158-1000-0000-000000000000</parentGroupId> + <position> + <x>15.7503662109375</x> + <y>230.0</y> + </position> + <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>top</key> + <value> + <name>top</name> + </value> + </entry> + </descriptors> + <lossTolerant>false</lossTolerant> + <penaltyDuration>30 sec</penaltyDuration> + <properties> + <entry> + <key>Delete Attributes Expression</key> + </entry> + <entry> + <key>top</key> + <value>top</value> + </entry> + </properties> + <runDurationMillis>0</runDurationMillis> + <schedulingPeriod>0 sec</schedulingPeriod> + <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> + <yieldDuration>1 sec</yieldDuration> + </config> + <name>UpdateAttribute</name> + <relationships> + <autoTerminate>false</autoTerminate> + <name>success</name> + </relationships> + <style></style> + <type>org.apache.nifi.processors.attributes.UpdateAttribute</type> + </processors> + <processors> + <id>2079e8bd-0158-1000-0000-000000000000</id> + <parentGroupId>21a36442-0158-1000-0000-000000000000</parentGroupId> + <position> + <x>20.064770209559924</x> + <y>701.7270693739383</y> + </position> + <config> + <bulletinLevel>WARN</bulletinLevel> + <comments></comments> + <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> + <descriptors> + <entry> + <key>Log Level</key> + <value> + <name>Log Level</name> + </value> + </entry> + <entry> + <key>Log Payload</key> + <value> + <name>Log Payload</name> + </value> + </entry> + <entry> + <key>Attributes to Log</key> + <value> + <name>Attributes to Log</name> + </value> + </entry> + <entry> + <key>Attributes to Ignore</key> + <value> + <name>Attributes to Ignore</name> + </value> + </entry> + <entry> + <key>Log prefix</key> + <value> + <name>Log prefix</name> + </value> + </entry> + </descriptors> + <lossTolerant>false</lossTolerant> + <penaltyDuration>30 sec</penaltyDuration> + <properties> + <entry> + <key>Log Level</key> + <value>info</value> + </entry> + <entry> + <key>Log Payload</key> + <value>false</value> + </entry> + <entry> + <key>Attributes to Log</key> + </entry> + <entry> + <key>Attributes to Ignore</key> + </entry> + <entry> + <key>Log prefix</key> + </entry> + </properties> + <runDurationMillis>0</runDurationMillis> + <schedulingPeriod>0 sec</schedulingPeriod> + <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> + <yieldDuration>1 sec</yieldDuration> + </config> + <name>LogAttribute</name> + <relationships> + <autoTerminate>true</autoTerminate> + <name>success</name> + </relationships> + <style></style> + <type>org.apache.nifi.processors.standard.LogAttribute</type> + </processors> + </snippet> + <timestamp>11/01/2016 16:49:02 EDT</timestamp> +</template> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/nifi-minifi/blob/31855bbc/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/ProcessGroupsAndRemoteProcessGroups.yml ---------------------------------------------------------------------- diff --git a/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/ProcessGroupsAndRemoteProcessGroups.yml b/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/ProcessGroupsAndRemoteProcessGroups.yml new file mode 100644 index 0000000..101a360 --- /dev/null +++ b/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/ProcessGroupsAndRemoteProcessGroups.yml @@ -0,0 +1,276 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the \"License\"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an \"AS IS\" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +MiNiFi Config Version: 2 +Flow Controller: + name: ProcessGroupsAndRemoteProcessGroups + comment: '' +Core Properties: + flow controller graceful shutdown period: 10 sec + flow service write delay interval: 500 ms + administrative yield duration: 30 sec + bored yield duration: 10 millis + max concurrent threads: 1 +FlowFile Repository: + partitions: 256 + checkpoint interval: 2 mins + always sync: false + Swap: + threshold: 20000 + in period: 5 sec + in threads: 1 + out period: 5 sec + out threads: 4 +Content Repository: + content claim max appendable size: 10 MB + content claim max flow files: 100 + always sync: false +Provenance Repository: + provenance rollover time: 1 min +Component Status Repository: + buffer size: 1440 + snapshot frequency: 1 min +Security Properties: + keystore: '' + keystore type: '' + keystore password: '' + key password: '' + truststore: '' + truststore type: '' + truststore password: '' + ssl protocol: '' + Sensitive Props: + key: + algorithm: PBEWITHMD5AND256BITAES-CBC-OPENSSL + provider: BC +Processors: +- id: 207748d1-0158-1000-0000-000000000000 + name: GenerateFlowFile + class: org.apache.nifi.processors.standard.GenerateFlowFile + max concurrent tasks: 1 + scheduling strategy: TIMER_DRIVEN + scheduling period: 0 sec + penalization period: 30 sec + yield period: 1 sec + run duration nanos: 0 + auto-terminated relationships list: [] + Properties: + Batch Size: '1' + Data Format: Binary + File Size: 1 b + Unique FlowFiles: 'false' +- id: 2079e8bd-0158-1000-0000-000000000000 + name: LogAttribute + class: org.apache.nifi.processors.standard.LogAttribute + max concurrent tasks: 1 + scheduling strategy: TIMER_DRIVEN + scheduling period: 0 sec + penalization period: 30 sec + yield period: 1 sec + run duration nanos: 0 + auto-terminated relationships list: + - success + Properties: + Attributes to Ignore: + Attributes to Log: + Log Level: info + Log Payload: 'false' + Log prefix: +- id: 2077ab1e-0158-1000-0000-000000000000 + name: UpdateAttribute + class: org.apache.nifi.processors.attributes.UpdateAttribute + max concurrent tasks: 1 + scheduling strategy: TIMER_DRIVEN + scheduling period: 0 sec + penalization period: 30 sec + yield period: 1 sec + run duration nanos: 0 + auto-terminated relationships list: [] + Properties: + Delete Attributes Expression: + top: top +Process Groups: +- id: 207888b1-0158-1000-0000-000000000000 + name: middle + Processors: + - id: 2078f34e-0158-1000-0000-000000000000 + name: UpdateAttribute + class: org.apache.nifi.processors.attributes.UpdateAttribute + max concurrent tasks: 1 + scheduling strategy: TIMER_DRIVEN + scheduling period: 0 sec + penalization period: 30 sec + yield period: 1 sec + run duration nanos: 0 + auto-terminated relationships list: [] + Properties: + Delete Attributes Expression: + middle: middle + Process Groups: + - id: 20794cd4-0158-1000-0000-000000000000 + name: bottom + Processors: + - id: 207a89ba-0158-1000-0000-000000000000 + name: UpdateAttribute + class: org.apache.nifi.processors.attributes.UpdateAttribute + max concurrent tasks: 1 + scheduling strategy: TIMER_DRIVEN + scheduling period: 0 sec + penalization period: 30 sec + yield period: 1 sec + run duration nanos: 0 + auto-terminated relationships list: [] + Properties: + Delete Attributes Expression: + bottom: bottom + Process Groups: [] + Input Ports: + - id: 207a5f50-0158-1000-0000-000000000000 + name: input + Output Ports: + - id: 207a6d92-0158-1000-0000-000000000000 + name: output + Connections: + - id: 21a6abb9-0158-1000-0000-000000000000 + name: UpdateAttribute/success/21a39aba-0158-1000-a1a0-1b55bcddcd72 + source id: 207a89ba-0158-1000-0000-000000000000 + source relationship names: + - success + destination id: 21a39aba-0158-1000-a1a0-1b55bcddcd72 + max work queue size: 10000 + max work queue data size: 1 GB + flowfile expiration: 0 sec + queue prioritizer class: '' + - id: 207ad5e9-0158-1000-0000-000000000000 + name: UpdateAttribute/success/output + source id: 207a89ba-0158-1000-0000-000000000000 + source relationship names: + - success + destination id: 207a6d92-0158-1000-0000-000000000000 + max work queue size: 10000 + max work queue data size: 1 GB + flowfile expiration: 0 sec + queue prioritizer class: '' + - id: 207aca0d-0158-1000-0000-000000000000 + name: input//UpdateAttribute + source id: 207a5f50-0158-1000-0000-000000000000 + source relationship names: [] + destination id: 207a89ba-0158-1000-0000-000000000000 + max work queue size: 10000 + max work queue data size: 1 GB + flowfile expiration: 0 sec + queue prioritizer class: '' + Remote Processing Groups: + - name: http://localhost:9091/nifi + url: http://localhost:9091/nifi + comment: '' + timeout: 30 sec + yield period: 10 sec + Input Ports: + - id: 21a39aba-0158-1000-a1a0-1b55bcddcd72 + name: input2 + comment: '' + max concurrent tasks: 1 + use compression: false + Input Ports: + - id: 2078c936-0158-1000-0000-000000000000 + name: input + Output Ports: + - id: 2079b327-0158-1000-0000-000000000000 + name: output + Connections: + - id: 21a5b1f1-0158-1000-0000-000000000000 + name: UpdateAttribute/success/21a2fb5e-0158-1000-3b5e-5a7d3aaee01b + source id: 2078f34e-0158-1000-0000-000000000000 + source relationship names: + - success + destination id: 21a2fb5e-0158-1000-3b5e-5a7d3aaee01b + max work queue size: 10000 + max work queue data size: 1 GB + flowfile expiration: 0 sec + queue prioritizer class: '' + - id: 207b0eb1-0158-1000-0000-000000000000 + name: UpdateAttribute/success/input + source id: 2078f34e-0158-1000-0000-000000000000 + source relationship names: + - success + destination id: 207a5f50-0158-1000-0000-000000000000 + max work queue size: 10000 + max work queue data size: 1 GB + flowfile expiration: 0 sec + queue prioritizer class: '' + - id: 20792ec2-0158-1000-0000-000000000000 + name: input//UpdateAttribute + source id: 2078c936-0158-1000-0000-000000000000 + source relationship names: [] + destination id: 2078f34e-0158-1000-0000-000000000000 + max work queue size: 10000 + max work queue data size: 1 GB + flowfile expiration: 0 sec + queue prioritizer class: '' + - id: 207b1880-0158-1000-0000-000000000000 + name: output//output + source id: 207a6d92-0158-1000-0000-000000000000 + source relationship names: [] + destination id: 2079b327-0158-1000-0000-000000000000 + max work queue size: 10000 + max work queue data size: 1 GB + flowfile expiration: 0 sec + queue prioritizer class: '' + Remote Processing Groups: + - name: http://localhost:9090/nifi + url: http://localhost:9090/nifi + comment: '' + timeout: 30 sec + yield period: 10 sec + Input Ports: + - id: 21a2fb5e-0158-1000-3b5e-5a7d3aaee01b + name: input + comment: '' + max concurrent tasks: 1 + use compression: false +Input Ports: [] +Output Ports: [] +Connections: +- id: 2077bf8f-0158-1000-0000-000000000000 + name: GenerateFlowFile/success/UpdateAttribute + source id: 207748d1-0158-1000-0000-000000000000 + source relationship names: + - success + destination id: 2077ab1e-0158-1000-0000-000000000000 + max work queue size: 10000 + max work queue data size: 1 GB + flowfile expiration: 0 sec + queue prioritizer class: '' +- id: 2079cf6f-0158-1000-0000-000000000000 + name: UpdateAttribute/success/input + source id: 2077ab1e-0158-1000-0000-000000000000 + source relationship names: + - success + destination id: 2078c936-0158-1000-0000-000000000000 + max work queue size: 10000 + max work queue data size: 1 GB + flowfile expiration: 0 sec + queue prioritizer class: '' +- id: 2079faa0-0158-1000-0000-000000000000 + name: output//LogAttribute + source id: 2079b327-0158-1000-0000-000000000000 + source relationship names: [] + destination id: 2079e8bd-0158-1000-0000-000000000000 + max work queue size: 10000 + max work queue data size: 1 GB + flowfile expiration: 0 sec + queue prioritizer class: '' +Remote Processing Groups: [] http://git-wip-us.apache.org/repos/asf/nifi-minifi/blob/31855bbc/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/ReplaceTextExpressionLanguageCSVReformatting.yml ---------------------------------------------------------------------- diff --git a/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/ReplaceTextExpressionLanguageCSVReformatting.yml b/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/ReplaceTextExpressionLanguageCSVReformatting.yml index d740cf2..36bdcd8 100644 --- a/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/ReplaceTextExpressionLanguageCSVReformatting.yml +++ b/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/ReplaceTextExpressionLanguageCSVReformatting.yml @@ -123,6 +123,9 @@ Processors: 2006,10-01-2004,10may2004 2007,15-05-2006,10jun2005 2009,8-8-2008,10aug2008 +Process Groups: [] +Input Ports: [] +Output Ports: [] Connections: - name: Generate Empty File/success/Set CSV Content id: ca71a875-0ff5-41ef-bbe0-da5de0ca1e08 http://git-wip-us.apache.org/repos/asf/nifi-minifi/blob/31855bbc/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/StressTestFramework.yml ---------------------------------------------------------------------- diff --git a/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/StressTestFramework.yml b/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/StressTestFramework.yml index be3d200..d135be8 100644 --- a/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/StressTestFramework.yml +++ b/minifi-toolkit/minifi-toolkit-configuration/src/test/resources/StressTestFramework.yml @@ -98,6 +98,9 @@ Processors: Delete Attributes Expression: property 1: value 1 property 2: value 2 ${nextInt()} +Process Groups: [] +Input Ports: [] +Output Ports: [] Connections: - name: GenerateFlowFile/success/UpdateAttribute id: 0e6873cc-cb9d-4e98-92aa-a3319f4c1b02
