Created
April 18, 2020 16:57
-
-
Save cjimti/90abd6dbf1ce67ee4c526a32f96abd47 to your computer and use it in GitHub Desktop.
NiFi Demo Template for apk8s.
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>0b45efb0-0171-1000-7cad-457ce8f223d5</groupId> | |
| <name>Twitter Sentiment v2</name> | |
| <snippet> | |
| <connections> | |
| <id>45c0992d-ba9e-3d80-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <destination> | |
| <groupId>23f6c2f1-9874-3710-0000-000000000000</groupId> | |
| <id>0484e41f-f406-329f-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>1</labelIndex> | |
| <loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
| <loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
| <loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
| <loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
| <name></name> | |
| <selectedRelationships>success</selectedRelationships> | |
| <source> | |
| <groupId>23f6c2f1-9874-3710-0000-000000000000</groupId> | |
| <id>9dc25cbc-8900-3498-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>85f01adc-b71c-33b6-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <destination> | |
| <groupId>23f6c2f1-9874-3710-0000-000000000000</groupId> | |
| <id>5cdc453d-ef89-30cb-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>1</labelIndex> | |
| <loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
| <loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
| <loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
| <loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
| <name></name> | |
| <selectedRelationships>Response</selectedRelationships> | |
| <source> | |
| <groupId>23f6c2f1-9874-3710-0000-000000000000</groupId> | |
| <id>0484e41f-f406-329f-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>8b11bcf3-b17b-3f6f-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <destination> | |
| <groupId>23f6c2f1-9874-3710-0000-000000000000</groupId> | |
| <id>9e48521f-c27f-32d5-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>1</labelIndex> | |
| <loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
| <loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
| <loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
| <loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
| <name></name> | |
| <selectedRelationships>success</selectedRelationships> | |
| <source> | |
| <groupId>23f6c2f1-9874-3710-0000-000000000000</groupId> | |
| <id>5706948f-d8bc-3074-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>a8790d4c-4538-32a3-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <destination> | |
| <groupId>23f6c2f1-9874-3710-0000-000000000000</groupId> | |
| <id>71dea0e6-7821-3ccd-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>1</labelIndex> | |
| <loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
| <loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
| <loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
| <loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
| <name></name> | |
| <selectedRelationships>success</selectedRelationships> | |
| <source> | |
| <groupId>23f6c2f1-9874-3710-0000-000000000000</groupId> | |
| <id>15d1ef2f-040f-3c53-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>b6bc7a5d-3d5f-3329-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <destination> | |
| <groupId>23f6c2f1-9874-3710-0000-000000000000</groupId> | |
| <id>2293d5d6-22cd-3632-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>1</labelIndex> | |
| <loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
| <loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
| <loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
| <loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
| <name></name> | |
| <selectedRelationships>matched</selectedRelationships> | |
| <source> | |
| <groupId>23f6c2f1-9874-3710-0000-000000000000</groupId> | |
| <id>9e48521f-c27f-32d5-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>c3a3c1a8-b3aa-3332-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <destination> | |
| <groupId>23f6c2f1-9874-3710-0000-000000000000</groupId> | |
| <id>9dc25cbc-8900-3498-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>1</labelIndex> | |
| <loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
| <loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
| <loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
| <loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
| <name></name> | |
| <selectedRelationships>matched</selectedRelationships> | |
| <source> | |
| <groupId>23f6c2f1-9874-3710-0000-000000000000</groupId> | |
| <id>2293d5d6-22cd-3632-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>deaf017b-15ef-3f3d-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <destination> | |
| <groupId>23f6c2f1-9874-3710-0000-000000000000</groupId> | |
| <id>15d1ef2f-040f-3c53-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>1</labelIndex> | |
| <loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
| <loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
| <loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
| <loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
| <name></name> | |
| <selectedRelationships>matched</selectedRelationships> | |
| <source> | |
| <groupId>23f6c2f1-9874-3710-0000-000000000000</groupId> | |
| <id>5cdc453d-ef89-30cb-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <connections> | |
| <id>e1b920cd-0723-3cf8-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
| <backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
| <destination> | |
| <groupId>23f6c2f1-9874-3710-0000-000000000000</groupId> | |
| <id>4f5c8088-ada3-3246-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </destination> | |
| <flowFileExpiration>0 sec</flowFileExpiration> | |
| <labelIndex>1</labelIndex> | |
| <loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
| <loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
| <loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
| <loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
| <name></name> | |
| <selectedRelationships>success</selectedRelationships> | |
| <source> | |
| <groupId>23f6c2f1-9874-3710-0000-000000000000</groupId> | |
| <id>bb7acbcf-d79c-3438-0000-000000000000</id> | |
| <type>PROCESSOR</type> | |
| </source> | |
| <zIndex>0</zIndex> | |
| </connections> | |
| <processors> | |
| <id>0484e41f-f406-329f-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>418.1578317166179</x> | |
| <y>409.9165029743967</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-standard-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.9.2</version> | |
| </bundle> | |
| <config> | |
| <bulletinLevel>WARN</bulletinLevel> | |
| <comments></comments> | |
| <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
| <descriptors> | |
| <entry> | |
| <key>HTTP Method</key> | |
| <value> | |
| <name>HTTP Method</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Remote URL</key> | |
| <value> | |
| <name>Remote URL</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>SSL Context Service</key> | |
| <value> | |
| <identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService> | |
| <name>SSL Context Service</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Connection Timeout</key> | |
| <value> | |
| <name>Connection Timeout</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Read Timeout</key> | |
| <value> | |
| <name>Read Timeout</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Include Date Header</key> | |
| <value> | |
| <name>Include Date Header</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Follow Redirects</key> | |
| <value> | |
| <name>Follow Redirects</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Attributes to Send</key> | |
| <value> | |
| <name>Attributes to Send</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Basic Authentication Username</key> | |
| <value> | |
| <name>Basic Authentication Username</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Basic Authentication Password</key> | |
| <value> | |
| <name>Basic Authentication Password</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>proxy-configuration-service</key> | |
| <value> | |
| <identifiesControllerService>org.apache.nifi.proxy.ProxyConfigurationService</identifiesControllerService> | |
| <name>proxy-configuration-service</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Proxy Host</key> | |
| <value> | |
| <name>Proxy Host</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Proxy Port</key> | |
| <value> | |
| <name>Proxy Port</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Proxy Type</key> | |
| <value> | |
| <name>Proxy Type</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>invokehttp-proxy-user</key> | |
| <value> | |
| <name>invokehttp-proxy-user</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>invokehttp-proxy-password</key> | |
| <value> | |
| <name>invokehttp-proxy-password</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Put Response Body In Attribute</key> | |
| <value> | |
| <name>Put Response Body In Attribute</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Max Length To Put In Attribute</key> | |
| <value> | |
| <name>Max Length To Put In Attribute</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Digest Authentication</key> | |
| <value> | |
| <name>Digest Authentication</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Always Output Response</key> | |
| <value> | |
| <name>Always Output Response</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Trusted Hostname</key> | |
| <value> | |
| <name>Trusted Hostname</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Add Response Headers to Request</key> | |
| <value> | |
| <name>Add Response Headers to Request</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Content-Type</key> | |
| <value> | |
| <name>Content-Type</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>send-message-body</key> | |
| <value> | |
| <name>send-message-body</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Use Chunked Encoding</key> | |
| <value> | |
| <name>Use Chunked Encoding</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Penalize on "No Retry"</key> | |
| <value> | |
| <name>Penalize on "No Retry"</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>use-etag</key> | |
| <value> | |
| <name>use-etag</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>etag-max-cache-size</key> | |
| <value> | |
| <name>etag-max-cache-size</name> | |
| </value> | |
| </entry> | |
| </descriptors> | |
| <executionNode>ALL</executionNode> | |
| <lossTolerant>false</lossTolerant> | |
| <penaltyDuration>30 sec</penaltyDuration> | |
| <properties> | |
| <entry> | |
| <key>HTTP Method</key> | |
| <value>POST</value> | |
| </entry> | |
| <entry> | |
| <key>Remote URL</key> | |
| <value>http://gateway:8080/function/sentimentanalysis</value> | |
| </entry> | |
| <entry> | |
| <key>SSL Context Service</key> | |
| </entry> | |
| <entry> | |
| <key>Connection Timeout</key> | |
| <value>5 secs</value> | |
| </entry> | |
| <entry> | |
| <key>Read Timeout</key> | |
| <value>15 secs</value> | |
| </entry> | |
| <entry> | |
| <key>Include Date Header</key> | |
| <value>True</value> | |
| </entry> | |
| <entry> | |
| <key>Follow Redirects</key> | |
| <value>True</value> | |
| </entry> | |
| <entry> | |
| <key>Attributes to Send</key> | |
| </entry> | |
| <entry> | |
| <key>Basic Authentication Username</key> | |
| </entry> | |
| <entry> | |
| <key>Basic Authentication Password</key> | |
| </entry> | |
| <entry> | |
| <key>proxy-configuration-service</key> | |
| </entry> | |
| <entry> | |
| <key>Proxy Host</key> | |
| </entry> | |
| <entry> | |
| <key>Proxy Port</key> | |
| </entry> | |
| <entry> | |
| <key>Proxy Type</key> | |
| <value>http</value> | |
| </entry> | |
| <entry> | |
| <key>invokehttp-proxy-user</key> | |
| </entry> | |
| <entry> | |
| <key>invokehttp-proxy-password</key> | |
| </entry> | |
| <entry> | |
| <key>Put Response Body In Attribute</key> | |
| </entry> | |
| <entry> | |
| <key>Max Length To Put In Attribute</key> | |
| <value>256</value> | |
| </entry> | |
| <entry> | |
| <key>Digest Authentication</key> | |
| <value>false</value> | |
| </entry> | |
| <entry> | |
| <key>Always Output Response</key> | |
| <value>false</value> | |
| </entry> | |
| <entry> | |
| <key>Trusted Hostname</key> | |
| </entry> | |
| <entry> | |
| <key>Add Response Headers to Request</key> | |
| <value>false</value> | |
| </entry> | |
| <entry> | |
| <key>Content-Type</key> | |
| <value>${mime.type}</value> | |
| </entry> | |
| <entry> | |
| <key>send-message-body</key> | |
| <value>true</value> | |
| </entry> | |
| <entry> | |
| <key>Use Chunked Encoding</key> | |
| <value>false</value> | |
| </entry> | |
| <entry> | |
| <key>Penalize on "No Retry"</key> | |
| <value>false</value> | |
| </entry> | |
| <entry> | |
| <key>use-etag</key> | |
| <value>false</value> | |
| </entry> | |
| <entry> | |
| <key>etag-max-cache-size</key> | |
| <value>10MB</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>0 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>InvokeHTTP</name> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>Failure</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>No Retry</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>Original</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>false</autoTerminate> | |
| <name>Response</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>Retry</name> | |
| </relationships> | |
| <state>RUNNING</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.standard.InvokeHTTP</type> | |
| </processors> | |
| <processors> | |
| <id>15d1ef2f-040f-3c53-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>418.1578317166179</x> | |
| <y>598.2285636080262</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-standard-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.9.2</version> | |
| </bundle> | |
| <config> | |
| <bulletinLevel>WARN</bulletinLevel> | |
| <comments></comments> | |
| <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
| <descriptors> | |
| <entry> | |
| <key>Attributes List</key> | |
| <value> | |
| <name>Attributes List</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>attributes-to-json-regex</key> | |
| <value> | |
| <name>attributes-to-json-regex</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Destination</key> | |
| <value> | |
| <name>Destination</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Include Core Attributes</key> | |
| <value> | |
| <name>Include Core Attributes</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Null Value</key> | |
| <value> | |
| <name>Null Value</name> | |
| </value> | |
| </entry> | |
| </descriptors> | |
| <executionNode>ALL</executionNode> | |
| <lossTolerant>false</lossTolerant> | |
| <penaltyDuration>30 sec</penaltyDuration> | |
| <properties> | |
| <entry> | |
| <key>Attributes List</key> | |
| </entry> | |
| <entry> | |
| <key>attributes-to-json-regex</key> | |
| </entry> | |
| <entry> | |
| <key>Destination</key> | |
| <value>flowfile-content</value> | |
| </entry> | |
| <entry> | |
| <key>Include Core Attributes</key> | |
| <value>true</value> | |
| </entry> | |
| <entry> | |
| <key>Null Value</key> | |
| <value>false</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>0 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>AttributesToJSON</name> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>failure</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>false</autoTerminate> | |
| <name>success</name> | |
| </relationships> | |
| <state>RUNNING</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.standard.AttributesToJSON</type> | |
| </processors> | |
| <processors> | |
| <id>2293d5d6-22cd-3632-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>418.1578317166179</x> | |
| <y>214.10092828886894</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-standard-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.9.2</version> | |
| </bundle> | |
| <config> | |
| <bulletinLevel>WARN</bulletinLevel> | |
| <comments></comments> | |
| <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
| <descriptors> | |
| <entry> | |
| <key>Routing Strategy</key> | |
| <value> | |
| <name>Routing Strategy</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Is Not Null</key> | |
| <value> | |
| <name>Is Not Null</name> | |
| </value> | |
| </entry> | |
| </descriptors> | |
| <executionNode>ALL</executionNode> | |
| <lossTolerant>false</lossTolerant> | |
| <penaltyDuration>30 sec</penaltyDuration> | |
| <properties> | |
| <entry> | |
| <key>Routing Strategy</key> | |
| <value>Route to 'match' if any matches</value> | |
| </entry> | |
| <entry> | |
| <key>Is Not Null</key> | |
| <value>${twitter.created_at:isNull():not()}</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>0 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>RouteOnAttribute</name> | |
| <relationships> | |
| <autoTerminate>false</autoTerminate> | |
| <name>matched</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>unmatched</name> | |
| </relationships> | |
| <state>RUNNING</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.standard.RouteOnAttribute</type> | |
| </processors> | |
| <processors> | |
| <id>4f5c8088-ada3-3246-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>0.0</x> | |
| <y>211.9667386222804</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-kafka-0-9-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.9.2</version> | |
| </bundle> | |
| <config> | |
| <bulletinLevel>WARN</bulletinLevel> | |
| <comments></comments> | |
| <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
| <descriptors> | |
| <entry> | |
| <key>bootstrap.servers</key> | |
| <value> | |
| <name>bootstrap.servers</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>security.protocol</key> | |
| <value> | |
| <name>security.protocol</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>sasl.kerberos.service.name</key> | |
| <value> | |
| <name>sasl.kerberos.service.name</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>ssl.context.service</key> | |
| <value> | |
| <identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService> | |
| <name>ssl.context.service</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>topic</key> | |
| <value> | |
| <name>topic</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>acks</key> | |
| <value> | |
| <name>acks</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>kafka-key</key> | |
| <value> | |
| <name>kafka-key</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>key-attribute-encoding</key> | |
| <value> | |
| <name>key-attribute-encoding</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>message-demarcator</key> | |
| <value> | |
| <name>message-demarcator</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>max.request.size</key> | |
| <value> | |
| <name>max.request.size</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>ack.wait.time</key> | |
| <value> | |
| <name>ack.wait.time</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>max.block.ms</key> | |
| <value> | |
| <name>max.block.ms</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>partitioner.class</key> | |
| <value> | |
| <name>partitioner.class</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>compression.type</key> | |
| <value> | |
| <name>compression.type</name> | |
| </value> | |
| </entry> | |
| </descriptors> | |
| <executionNode>ALL</executionNode> | |
| <lossTolerant>false</lossTolerant> | |
| <penaltyDuration>30 sec</penaltyDuration> | |
| <properties> | |
| <entry> | |
| <key>bootstrap.servers</key> | |
| <value>kafka:9092</value> | |
| </entry> | |
| <entry> | |
| <key>security.protocol</key> | |
| <value>PLAINTEXT</value> | |
| </entry> | |
| <entry> | |
| <key>sasl.kerberos.service.name</key> | |
| </entry> | |
| <entry> | |
| <key>ssl.context.service</key> | |
| </entry> | |
| <entry> | |
| <key>topic</key> | |
| <value>twitter</value> | |
| </entry> | |
| <entry> | |
| <key>acks</key> | |
| <value>0</value> | |
| </entry> | |
| <entry> | |
| <key>kafka-key</key> | |
| </entry> | |
| <entry> | |
| <key>key-attribute-encoding</key> | |
| <value>utf-8</value> | |
| </entry> | |
| <entry> | |
| <key>message-demarcator</key> | |
| </entry> | |
| <entry> | |
| <key>max.request.size</key> | |
| <value>1 MB</value> | |
| </entry> | |
| <entry> | |
| <key>ack.wait.time</key> | |
| <value>5 secs</value> | |
| </entry> | |
| <entry> | |
| <key>max.block.ms</key> | |
| <value>5 sec</value> | |
| </entry> | |
| <entry> | |
| <key>partitioner.class</key> | |
| <value>org.apache.kafka.clients.producer.internals.DefaultPartitioner</value> | |
| </entry> | |
| <entry> | |
| <key>compression.type</key> | |
| <value>none</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>0 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>PublishKafka</name> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>failure</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>success</name> | |
| </relationships> | |
| <state>RUNNING</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.kafka.pubsub.PublishKafka</type> | |
| </processors> | |
| <processors> | |
| <id>5706948f-d8bc-3074-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>418.1578317166179</x> | |
| <y>0.0</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-kafka-0-9-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.9.2</version> | |
| </bundle> | |
| <config> | |
| <bulletinLevel>WARN</bulletinLevel> | |
| <comments></comments> | |
| <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
| <descriptors> | |
| <entry> | |
| <key>bootstrap.servers</key> | |
| <value> | |
| <name>bootstrap.servers</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>security.protocol</key> | |
| <value> | |
| <name>security.protocol</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>sasl.kerberos.service.name</key> | |
| <value> | |
| <name>sasl.kerberos.service.name</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>ssl.context.service</key> | |
| <value> | |
| <identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService> | |
| <name>ssl.context.service</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>topic</key> | |
| <value> | |
| <name>topic</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>group.id</key> | |
| <value> | |
| <name>group.id</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>auto.offset.reset</key> | |
| <value> | |
| <name>auto.offset.reset</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>key-attribute-encoding</key> | |
| <value> | |
| <name>key-attribute-encoding</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>message-demarcator</key> | |
| <value> | |
| <name>message-demarcator</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>max.poll.records</key> | |
| <value> | |
| <name>max.poll.records</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>max-uncommit-offset-wait</key> | |
| <value> | |
| <name>max-uncommit-offset-wait</name> | |
| </value> | |
| </entry> | |
| </descriptors> | |
| <executionNode>ALL</executionNode> | |
| <lossTolerant>false</lossTolerant> | |
| <penaltyDuration>30 sec</penaltyDuration> | |
| <properties> | |
| <entry> | |
| <key>bootstrap.servers</key> | |
| <value>kafka:9092</value> | |
| </entry> | |
| <entry> | |
| <key>security.protocol</key> | |
| <value>PLAINTEXT</value> | |
| </entry> | |
| <entry> | |
| <key>sasl.kerberos.service.name</key> | |
| </entry> | |
| <entry> | |
| <key>ssl.context.service</key> | |
| </entry> | |
| <entry> | |
| <key>topic</key> | |
| <value>twitter</value> | |
| </entry> | |
| <entry> | |
| <key>group.id</key> | |
| <value>nifi</value> | |
| </entry> | |
| <entry> | |
| <key>auto.offset.reset</key> | |
| <value>latest</value> | |
| </entry> | |
| <entry> | |
| <key>key-attribute-encoding</key> | |
| <value>utf-8</value> | |
| </entry> | |
| <entry> | |
| <key>message-demarcator</key> | |
| </entry> | |
| <entry> | |
| <key>max.poll.records</key> | |
| <value>10000</value> | |
| </entry> | |
| <entry> | |
| <key>max-uncommit-offset-wait</key> | |
| <value>1 secs</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>0 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>ConsumeKafkaTweets</name> | |
| <relationships> | |
| <autoTerminate>false</autoTerminate> | |
| <name>success</name> | |
| </relationships> | |
| <state>RUNNING</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.kafka.pubsub.ConsumeKafka</type> | |
| </processors> | |
| <processors> | |
| <id>5cdc453d-ef89-30cb-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>1050.7052235154788</x> | |
| <y>455.02906202058347</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-standard-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.9.2</version> | |
| </bundle> | |
| <config> | |
| <bulletinLevel>WARN</bulletinLevel> | |
| <comments></comments> | |
| <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
| <descriptors> | |
| <entry> | |
| <key>Destination</key> | |
| <value> | |
| <name>Destination</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Return Type</key> | |
| <value> | |
| <name>Return Type</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Path Not Found Behavior</key> | |
| <value> | |
| <name>Path Not Found Behavior</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Null Value Representation</key> | |
| <value> | |
| <name>Null Value Representation</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>polarity</key> | |
| <value> | |
| <name>polarity</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>sentence_count</key> | |
| <value> | |
| <name>sentence_count</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>subjectivity</key> | |
| <value> | |
| <name>subjectivity</name> | |
| </value> | |
| </entry> | |
| </descriptors> | |
| <executionNode>ALL</executionNode> | |
| <lossTolerant>false</lossTolerant> | |
| <penaltyDuration>30 sec</penaltyDuration> | |
| <properties> | |
| <entry> | |
| <key>Destination</key> | |
| <value>flowfile-attribute</value> | |
| </entry> | |
| <entry> | |
| <key>Return Type</key> | |
| <value>auto-detect</value> | |
| </entry> | |
| <entry> | |
| <key>Path Not Found Behavior</key> | |
| <value>ignore</value> | |
| </entry> | |
| <entry> | |
| <key>Null Value Representation</key> | |
| <value>empty string</value> | |
| </entry> | |
| <entry> | |
| <key>polarity</key> | |
| <value>$.polarity</value> | |
| </entry> | |
| <entry> | |
| <key>sentence_count</key> | |
| <value>$.sentence_count</value> | |
| </entry> | |
| <entry> | |
| <key>subjectivity</key> | |
| <value>$.subjectivity</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>0 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>EvaluateJsonPath</name> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>failure</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>false</autoTerminate> | |
| <name>matched</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>unmatched</name> | |
| </relationships> | |
| <state>RUNNING</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.standard.EvaluateJsonPath</type> | |
| </processors> | |
| <processors> | |
| <id>71dea0e6-7821-3ccd-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>1050.7052235154788</x> | |
| <y>643.8465399479787</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-elasticsearch-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.9.2</version> | |
| </bundle> | |
| <config> | |
| <bulletinLevel>WARN</bulletinLevel> | |
| <comments></comments> | |
| <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
| <descriptors> | |
| <entry> | |
| <key>elasticsearch-http-url</key> | |
| <value> | |
| <name>elasticsearch-http-url</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>SSL Context Service</key> | |
| <value> | |
| <identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService> | |
| <name>SSL Context Service</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Username</key> | |
| <value> | |
| <name>Username</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Password</key> | |
| <value> | |
| <name>Password</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>elasticsearch-http-connect-timeout</key> | |
| <value> | |
| <name>elasticsearch-http-connect-timeout</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>elasticsearch-http-response-timeout</key> | |
| <value> | |
| <name>elasticsearch-http-response-timeout</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>proxy-configuration-service</key> | |
| <value> | |
| <identifiesControllerService>org.apache.nifi.proxy.ProxyConfigurationService</identifiesControllerService> | |
| <name>proxy-configuration-service</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>elasticsearch-http-proxy-host</key> | |
| <value> | |
| <name>elasticsearch-http-proxy-host</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>elasticsearch-http-proxy-port</key> | |
| <value> | |
| <name>elasticsearch-http-proxy-port</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>proxy-username</key> | |
| <value> | |
| <name>proxy-username</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>proxy-password</key> | |
| <value> | |
| <name>proxy-password</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>put-es-id-attr</key> | |
| <value> | |
| <name>put-es-id-attr</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>put-es-index</key> | |
| <value> | |
| <name>put-es-index</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>put-es-type</key> | |
| <value> | |
| <name>put-es-type</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Character Set</key> | |
| <value> | |
| <name>Character Set</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>put-es-batch-size</key> | |
| <value> | |
| <name>put-es-batch-size</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>put-es-index-op</key> | |
| <value> | |
| <name>put-es-index-op</name> | |
| </value> | |
| </entry> | |
| </descriptors> | |
| <executionNode>ALL</executionNode> | |
| <lossTolerant>false</lossTolerant> | |
| <penaltyDuration>30 sec</penaltyDuration> | |
| <properties> | |
| <entry> | |
| <key>elasticsearch-http-url</key> | |
| <value>http://elasticsearch.data:9200</value> | |
| </entry> | |
| <entry> | |
| <key>SSL Context Service</key> | |
| </entry> | |
| <entry> | |
| <key>Username</key> | |
| </entry> | |
| <entry> | |
| <key>Password</key> | |
| </entry> | |
| <entry> | |
| <key>elasticsearch-http-connect-timeout</key> | |
| <value>5 secs</value> | |
| </entry> | |
| <entry> | |
| <key>elasticsearch-http-response-timeout</key> | |
| <value>15 secs</value> | |
| </entry> | |
| <entry> | |
| <key>proxy-configuration-service</key> | |
| </entry> | |
| <entry> | |
| <key>elasticsearch-http-proxy-host</key> | |
| </entry> | |
| <entry> | |
| <key>elasticsearch-http-proxy-port</key> | |
| </entry> | |
| <entry> | |
| <key>proxy-username</key> | |
| </entry> | |
| <entry> | |
| <key>proxy-password</key> | |
| </entry> | |
| <entry> | |
| <key>put-es-id-attr</key> | |
| </entry> | |
| <entry> | |
| <key>put-es-index</key> | |
| <value>sentiment-${now():format('yyyy-MM')}</value> | |
| </entry> | |
| <entry> | |
| <key>put-es-type</key> | |
| <value>_doc</value> | |
| </entry> | |
| <entry> | |
| <key>Character Set</key> | |
| <value>UTF-8</value> | |
| </entry> | |
| <entry> | |
| <key>put-es-batch-size</key> | |
| <value>100</value> | |
| </entry> | |
| <entry> | |
| <key>put-es-index-op</key> | |
| <value>index</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>0 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>PutElasticsearchHttp</name> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>failure</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>retry</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>success</name> | |
| </relationships> | |
| <state>RUNNING</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.elasticsearch.PutElasticsearchHttp</type> | |
| </processors> | |
| <processors> | |
| <id>9dc25cbc-8900-3498-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>1050.7052235154788</x> | |
| <y>245.0333503400231</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-standard-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.9.2</version> | |
| </bundle> | |
| <config> | |
| <bulletinLevel>WARN</bulletinLevel> | |
| <comments></comments> | |
| <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
| <descriptors> | |
| <entry> | |
| <key>attribute-list</key> | |
| <value> | |
| <name>attribute-list</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>attributes-regex</key> | |
| <value> | |
| <name>attributes-regex</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>destination</key> | |
| <value> | |
| <name>destination</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>include-core-attributes</key> | |
| <value> | |
| <name>include-core-attributes</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>null-value</key> | |
| <value> | |
| <name>null-value</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>include-schema</key> | |
| <value> | |
| <name>include-schema</name> | |
| </value> | |
| </entry> | |
| </descriptors> | |
| <executionNode>ALL</executionNode> | |
| <lossTolerant>false</lossTolerant> | |
| <penaltyDuration>30 sec</penaltyDuration> | |
| <properties> | |
| <entry> | |
| <key>attribute-list</key> | |
| <value>twitter.msg</value> | |
| </entry> | |
| <entry> | |
| <key>attributes-regex</key> | |
| </entry> | |
| <entry> | |
| <key>destination</key> | |
| <value>flowfile-content</value> | |
| </entry> | |
| <entry> | |
| <key>include-core-attributes</key> | |
| <value>true</value> | |
| </entry> | |
| <entry> | |
| <key>null-value</key> | |
| <value>false</value> | |
| </entry> | |
| <entry> | |
| <key>include-schema</key> | |
| <value>false</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>0 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>AttributesToCSV</name> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>failure</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>false</autoTerminate> | |
| <name>success</name> | |
| </relationships> | |
| <state>RUNNING</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.standard.AttributesToCSV</type> | |
| </processors> | |
| <processors> | |
| <id>9e48521f-c27f-32d5-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>1050.7052235154788</x> | |
| <y>55.3484712810486</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-standard-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.9.2</version> | |
| </bundle> | |
| <config> | |
| <bulletinLevel>WARN</bulletinLevel> | |
| <comments></comments> | |
| <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
| <descriptors> | |
| <entry> | |
| <key>Destination</key> | |
| <value> | |
| <name>Destination</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Return Type</key> | |
| <value> | |
| <name>Return Type</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Path Not Found Behavior</key> | |
| <value> | |
| <name>Path Not Found Behavior</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Null Value Representation</key> | |
| <value> | |
| <name>Null Value Representation</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>twitter.created_at</key> | |
| <value> | |
| <name>twitter.created_at</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>twitter.handle</key> | |
| <value> | |
| <name>twitter.handle</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>twitter.msg</key> | |
| <value> | |
| <name>twitter.msg</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>twitter.user</key> | |
| <value> | |
| <name>twitter.user</name> | |
| </value> | |
| </entry> | |
| </descriptors> | |
| <executionNode>ALL</executionNode> | |
| <lossTolerant>false</lossTolerant> | |
| <penaltyDuration>30 sec</penaltyDuration> | |
| <properties> | |
| <entry> | |
| <key>Destination</key> | |
| <value>flowfile-attribute</value> | |
| </entry> | |
| <entry> | |
| <key>Return Type</key> | |
| <value>auto-detect</value> | |
| </entry> | |
| <entry> | |
| <key>Path Not Found Behavior</key> | |
| <value>ignore</value> | |
| </entry> | |
| <entry> | |
| <key>Null Value Representation</key> | |
| <value>empty string</value> | |
| </entry> | |
| <entry> | |
| <key>twitter.created_at</key> | |
| <value>$.created_at</value> | |
| </entry> | |
| <entry> | |
| <key>twitter.handle</key> | |
| <value>$.user.screen_name</value> | |
| </entry> | |
| <entry> | |
| <key>twitter.msg</key> | |
| <value>$.text</value> | |
| </entry> | |
| <entry> | |
| <key>twitter.user</key> | |
| <value>$.user.name</value> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>25</runDurationMillis> | |
| <schedulingPeriod>0 sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>EvaluateJsonPath</name> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>failure</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>false</autoTerminate> | |
| <name>matched</name> | |
| </relationships> | |
| <relationships> | |
| <autoTerminate>true</autoTerminate> | |
| <name>unmatched</name> | |
| </relationships> | |
| <state>RUNNING</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.standard.EvaluateJsonPath</type> | |
| </processors> | |
| <processors> | |
| <id>bb7acbcf-d79c-3438-0000-000000000000</id> | |
| <parentGroupId>23f6c2f1-9874-3710-0000-000000000000</parentGroupId> | |
| <position> | |
| <x>0.0</x> | |
| <y>3.2645596672022634</y> | |
| </position> | |
| <bundle> | |
| <artifact>nifi-social-media-nar</artifact> | |
| <group>org.apache.nifi</group> | |
| <version>1.9.2</version> | |
| </bundle> | |
| <config> | |
| <bulletinLevel>WARN</bulletinLevel> | |
| <comments></comments> | |
| <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
| <descriptors> | |
| <entry> | |
| <key>Twitter Endpoint</key> | |
| <value> | |
| <name>Twitter Endpoint</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Consumer Key</key> | |
| <value> | |
| <name>Consumer Key</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Consumer Secret</key> | |
| <value> | |
| <name>Consumer Secret</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Access Token</key> | |
| <value> | |
| <name>Access Token</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Access Token Secret</key> | |
| <value> | |
| <name>Access Token Secret</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Languages</key> | |
| <value> | |
| <name>Languages</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Terms to Filter On</key> | |
| <value> | |
| <name>Terms to Filter On</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>IDs to Follow</key> | |
| <value> | |
| <name>IDs to Follow</name> | |
| </value> | |
| </entry> | |
| <entry> | |
| <key>Locations to Filter On</key> | |
| <value> | |
| <name>Locations to Filter On</name> | |
| </value> | |
| </entry> | |
| </descriptors> | |
| <executionNode>PRIMARY</executionNode> | |
| <lossTolerant>false</lossTolerant> | |
| <penaltyDuration>30 sec</penaltyDuration> | |
| <properties> | |
| <entry> | |
| <key>Twitter Endpoint</key> | |
| <value>Filter Endpoint</value> | |
| </entry> | |
| <entry> | |
| <key>Consumer Key</key> | |
| </entry> | |
| <entry> | |
| <key>Consumer Secret</key> | |
| </entry> | |
| <entry> | |
| <key>Access Token</key> | |
| </entry> | |
| <entry> | |
| <key>Access Token Secret</key> | |
| </entry> | |
| <entry> | |
| <key>Languages</key> | |
| <value>en</value> | |
| </entry> | |
| <entry> | |
| <key>Terms to Filter On</key> | |
| <value>covid19, covid-19</value> | |
| </entry> | |
| <entry> | |
| <key>IDs to Follow</key> | |
| </entry> | |
| <entry> | |
| <key>Locations to Filter On</key> | |
| </entry> | |
| </properties> | |
| <runDurationMillis>0</runDurationMillis> | |
| <schedulingPeriod>1sec</schedulingPeriod> | |
| <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
| <yieldDuration>1 sec</yieldDuration> | |
| </config> | |
| <executionNodeRestricted>false</executionNodeRestricted> | |
| <name>GetTwitter</name> | |
| <relationships> | |
| <autoTerminate>false</autoTerminate> | |
| <name>success</name> | |
| </relationships> | |
| <state>STOPPED</state> | |
| <style/> | |
| <type>org.apache.nifi.processors.twitter.GetTwitter</type> | |
| </processors> | |
| </snippet> | |
| <timestamp>03/26/2020 07:23:59 UTC</timestamp> | |
| </template> |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment