Created
October 5, 2017 01:04
-
-
Save alopresto/63c087854c5300f7c0763ce118c1eef6 to your computer and use it in GitHub Desktop.
This Apache NiFi template is designed to test the Jackson version upgrades. Runs a self-contained web server to respond with static JSON content and then a separate flow consumes and manipulates the JSON response.
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" ?> | |
<template encoding-version="1.1"> | |
<description>This template is designed to test the Jackson version upgrades. Runs a self-contained web server to respond with static JSON content and then a separate flow consumes and manipulates the JSON response. </description> | |
<groupId>ea0e59a1-015e-1000-a9c0-19adc6e77a4c</groupId> | |
<name>Web Server and JSON Test</name> | |
<snippet> | |
<connections> | |
<id>89dc319b-d631-35e4-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>ca99ad21-b382-3186-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>Response</selectedRelationships> | |
<source> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>80683900-5093-3f8d-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>b0d2991b-0531-3fec-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>dc8a4ef0-31af-3b7d-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>merged</selectedRelationships> | |
<source> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>47ce6067-6153-31be-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>b14cd7a0-cd97-30fc-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>b0884d28-ba6a-3f22-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>matched</selectedRelationships> | |
<source> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>b3925510-3ae2-312d-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>f6ddf21f-d033-3041-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>47ce6067-6153-31be-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>split</selectedRelationships> | |
<source> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>ca99ad21-b382-3186-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>fd6f2a1e-0d3a-38af-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>0b82c909-03d2-3a24-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>58d84e83-e5d5-3ccf-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>08e06172-3ca0-3f57-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>266ffea1-bc53-37c6-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>0b82c909-03d2-3a24-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>3960249b-d082-38c1-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>9b441c9e-e1ef-3880-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>dc8a4ef0-31af-3b7d-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>3f409145-ea1d-3030-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>b3925510-3ae2-312d-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>9b441c9e-e1ef-3880-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>5597f8ee-38c4-3957-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>58d84e83-e5d5-3ccf-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>f31765c3-5e97-3ff1-0000-000000000000</groupId> | |
<id>b9cce103-435f-3cd9-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<controllerServices> | |
<id>975e765e-e875-377a-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-record-serialization-services-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.5.0-SNAPSHOT</version> | |
</bundle> | |
<comments></comments> | |
<descriptors> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value> | |
<name>schema-access-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
<name>schema-registry</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value> | |
<name>schema-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value> | |
<name>schema-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
<value> | |
<name>Date Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
<value> | |
<name>Time Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
<value> | |
<name>Timestamp Format</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>JsonTreeReader</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>schema-access-strategy</key> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value>14cbfabe-a96f-341f-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.json.JsonTreeReader</type> | |
</controllerServices> | |
<controllerServices> | |
<id>c1dafd64-0828-34b6-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-record-serialization-services-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.5.0-SNAPSHOT</version> | |
</bundle> | |
<comments></comments> | |
<descriptors> | |
<entry> | |
<key>Schema Write Strategy</key> | |
<value> | |
<name>Schema Write Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value> | |
<name>schema-access-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
<name>schema-registry</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value> | |
<name>schema-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value> | |
<name>schema-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
<value> | |
<name>Date Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
<value> | |
<name>Time Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
<value> | |
<name>Timestamp Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Pretty Print JSON</key> | |
<value> | |
<name>Pretty Print JSON</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>JsonRecordSetWriter</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>Schema Write Strategy</key> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value>schema-name</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value>14cbfabe-a96f-341f-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
</entry> | |
<entry> | |
<key>Pretty Print JSON</key> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.json.JsonRecordSetWriter</type> | |
</controllerServices> | |
<controllerServices> | |
<id>f59e5758-f1dd-380d-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-http-context-map-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.5.0-SNAPSHOT</version> | |
</bundle> | |
<comments></comments> | |
<descriptors> | |
<entry> | |
<key>Maximum Outstanding Requests</key> | |
<value> | |
<name>Maximum Outstanding Requests</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Request Expiration</key> | |
<value> | |
<name>Request Expiration</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>StandardHttpContextMap</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>Maximum Outstanding Requests</key> | |
</entry> | |
<entry> | |
<key>Request Expiration</key> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.http.StandardHttpContextMap</type> | |
</controllerServices> | |
<controllerServices> | |
<id>14cbfabe-a96f-341f-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-registry-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.5.0-SNAPSHOT</version> | |
</bundle> | |
<comments></comments> | |
<descriptors> | |
<entry> | |
<key>song</key> | |
<value> | |
<name>song</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>AvroSchemaRegistry</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>song</key> | |
<value>{ | |
"namespace": "example.nifi", | |
"type": "record", | |
"name": "song", | |
"fields": [ | |
{"name": "artist", "type": "string"}, | |
{"name": "title", "type": "string"}, | |
{"name": "album", "type": ["string", "null"]} | |
] | |
}</value> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.schemaregistry.services.AvroSchemaRegistry</type> | |
</controllerServices> | |
<labels> | |
<id>c4963d06-a619-3d95-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<position> | |
<x>448.0</x> | |
<y>0.0</y> | |
</position> | |
<height>891.0</height> | |
<label>JSON Retrieval - Makes an HTTP query to the endpoint, retrieves JSON content (a single object with one element -- an array of three-element records), splits and recombines the array | |
into a root array, trims the *title* of each to one word, and collects all titles in an attribute before logging. </label> | |
<style> | |
<entry> | |
<key>font-size</key> | |
<value>12px</value> | |
</entry> | |
</style> | |
<width>1007.0</width> | |
</labels> | |
<labels> | |
<id>d91451ce-65ed-342b-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<position> | |
<x>0.0</x> | |
<y>0.0</y> | |
</position> | |
<height>677.0</height> | |
<label>Web server - Listens for HTTP GET requests on localhost:9999 and | |
responds with JSON content and custom response headers. </label> | |
<style> | |
<entry> | |
<key>font-size</key> | |
<value>12px</value> | |
</entry> | |
</style> | |
<width>420.0</width> | |
</labels> | |
<processors> | |
<id>80683900-5093-3f8d-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<position> | |
<x>496.0</x> | |
<y>55.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.5.0-SNAPSHOT</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 Host</key> | |
<value> | |
<name>Proxy Host</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Proxy Port</key> | |
<value> | |
<name>Proxy Port</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> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>HTTP Method</key> | |
<value>GET</value> | |
</entry> | |
<entry> | |
<key>Remote URL</key> | |
<value>http://localhost:9999</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 Host</key> | |
</entry> | |
<entry> | |
<key>Proxy Port</key> | |
</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> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>10 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<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>STOPPED</state> | |
<style></style> | |
<type>org.apache.nifi.processors.standard.InvokeHTTP</type> | |
</processors> | |
<processors> | |
<id>9b441c9e-e1ef-3880-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<position> | |
<x>1040.0</x> | |
<y>54.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.5.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>replacement-value-strategy</key> | |
<value> | |
<name>replacement-value-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>/title</key> | |
<value> | |
<name>/title</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>record-reader</key> | |
<value>975e765e-e875-377a-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>c1dafd64-0828-34b6-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>replacement-value-strategy</key> | |
<value>record-path-value</value> | |
</entry> | |
<entry> | |
<key>/title</key> | |
<value>substringBefore( /title, ' ' )</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<name>UpdateRecord</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style></style> | |
<type>org.apache.nifi.processors.standard.UpdateRecord</type> | |
</processors> | |
<processors> | |
<id>b0884d28-ba6a-3f22-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<position> | |
<x>1039.0</x> | |
<y>519.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.5.0-SNAPSHOT</version> | |
</bundle> | |
<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-log-regex</key> | |
<value> | |
<name>attributes-to-log-regex</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Attributes to Ignore</key> | |
<value> | |
<name>Attributes to Ignore</name> | |
</value> | |
</entry> | |
<entry> | |
<key>attributes-to-ignore-regex</key> | |
<value> | |
<name>attributes-to-ignore-regex</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Log prefix</key> | |
<value> | |
<name>Log prefix</name> | |
</value> | |
</entry> | |
<entry> | |
<key>character-set</key> | |
<value> | |
<name>character-set</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Log Level</key> | |
<value>info</value> | |
</entry> | |
<entry> | |
<key>Log Payload</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Attributes to Log</key> | |
</entry> | |
<entry> | |
<key>attributes-to-log-regex</key> | |
<value>.*</value> | |
</entry> | |
<entry> | |
<key>Attributes to Ignore</key> | |
</entry> | |
<entry> | |
<key>attributes-to-ignore-regex</key> | |
</entry> | |
<entry> | |
<key>Log prefix</key> | |
</entry> | |
<entry> | |
<key>character-set</key> | |
<value>UTF-8</value> | |
</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> | |
<state>STOPPED</state> | |
<style></style> | |
<type>org.apache.nifi.processors.standard.LogAttribute</type> | |
</processors> | |
<processors> | |
<id>b3925510-3ae2-312d-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<position> | |
<x>1041.0</x> | |
<y>273.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.5.0-SNAPSHOT</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>title</key> | |
<value> | |
<name>title</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>json</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>title</key> | |
<value>$[*].title</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<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>STOPPED</state> | |
<style></style> | |
<type>org.apache.nifi.processors.standard.EvaluateJsonPath</type> | |
</processors> | |
<processors> | |
<id>b9cce103-435f-3cd9-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<position> | |
<x>35.0</x> | |
<y>54.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.5.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Listening Port</key> | |
<value> | |
<name>Listening Port</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Hostname</key> | |
<value> | |
<name>Hostname</name> | |
</value> | |
</entry> | |
<entry> | |
<key>SSL Context Service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.ssl.RestrictedSSLContextService</identifiesControllerService> | |
<name>SSL Context Service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>HTTP Context Map</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.http.HttpContextMap</identifiesControllerService> | |
<name>HTTP Context Map</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Allowed Paths</key> | |
<value> | |
<name>Allowed Paths</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Default URL Character Set</key> | |
<value> | |
<name>Default URL Character Set</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Allow GET</key> | |
<value> | |
<name>Allow GET</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Allow POST</key> | |
<value> | |
<name>Allow POST</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Allow PUT</key> | |
<value> | |
<name>Allow PUT</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Allow DELETE</key> | |
<value> | |
<name>Allow DELETE</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Allow HEAD</key> | |
<value> | |
<name>Allow HEAD</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Allow OPTIONS</key> | |
<value> | |
<name>Allow OPTIONS</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Additional HTTP Methods</key> | |
<value> | |
<name>Additional HTTP Methods</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Client Authentication</key> | |
<value> | |
<name>Client Authentication</name> | |
</value> | |
</entry> | |
<entry> | |
<key>container-queue-size</key> | |
<value> | |
<name>container-queue-size</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Listening Port</key> | |
<value>9999</value> | |
</entry> | |
<entry> | |
<key>Hostname</key> | |
</entry> | |
<entry> | |
<key>SSL Context Service</key> | |
</entry> | |
<entry> | |
<key>HTTP Context Map</key> | |
<value>f59e5758-f1dd-380d-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>Allowed Paths</key> | |
</entry> | |
<entry> | |
<key>Default URL Character Set</key> | |
<value>UTF-8</value> | |
</entry> | |
<entry> | |
<key>Allow GET</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Allow POST</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Allow PUT</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Allow DELETE</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Allow HEAD</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Allow OPTIONS</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Additional HTTP Methods</key> | |
</entry> | |
<entry> | |
<key>Client Authentication</key> | |
<value>No Authentication</value> | |
</entry> | |
<entry> | |
<key>container-queue-size</key> | |
<value>50</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<name>HandleHttpRequest</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style></style> | |
<type>org.apache.nifi.processors.standard.HandleHttpRequest</type> | |
</processors> | |
<processors> | |
<id>ca99ad21-b382-3186-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<position> | |
<x>496.0</x> | |
<y>272.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.5.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>JsonPath Expression</key> | |
<value> | |
<name>JsonPath Expression</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Null Value Representation</key> | |
<value> | |
<name>Null Value Representation</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>JsonPath Expression</key> | |
<value>$.tracks</value> | |
</entry> | |
<entry> | |
<key>Null Value Representation</key> | |
<value>empty string</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<name>SplitJson</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>original</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>split</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style></style> | |
<type>org.apache.nifi.processors.standard.SplitJson</type> | |
</processors> | |
<processors> | |
<id>dc8a4ef0-31af-3b7d-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<position> | |
<x>500.0</x> | |
<y>724.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.5.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Regular Expression</key> | |
<value> | |
<name>Regular Expression</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Replacement Value</key> | |
<value> | |
<name>Replacement Value</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Character Set</key> | |
<value> | |
<name>Character Set</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Maximum Buffer Size</key> | |
<value> | |
<name>Maximum Buffer Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Replacement Strategy</key> | |
<value> | |
<name>Replacement Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Evaluation Mode</key> | |
<value> | |
<name>Evaluation Mode</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Regular Expression</key> | |
<value>(?s)(^.*$)</value> | |
</entry> | |
<entry> | |
<key>Replacement Value</key> | |
<value>[$1]</value> | |
</entry> | |
<entry> | |
<key>Character Set</key> | |
<value>UTF-8</value> | |
</entry> | |
<entry> | |
<key>Maximum Buffer Size</key> | |
<value>1 MB</value> | |
</entry> | |
<entry> | |
<key>Replacement Strategy</key> | |
<value>Regex Replace</value> | |
</entry> | |
<entry> | |
<key>Evaluation Mode</key> | |
<value>Entire text</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<name>ReplaceText</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style></style> | |
<type>org.apache.nifi.processors.standard.ReplaceText</type> | |
</processors> | |
<processors> | |
<id>0b82c909-03d2-3a24-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<position> | |
<x>35.0</x> | |
<y>383.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-update-attribute-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.5.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>batchId</key> | |
<value> | |
<name>batchId</name> | |
</value> | |
</entry> | |
<entry> | |
<key>groupSize</key> | |
<value> | |
<name>groupSize</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> | |
<entry> | |
<key>time</key> | |
<value> | |
<name>time</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>batchId</key> | |
<value>${UUID()}</value> | |
</entry> | |
<entry> | |
<key>groupSize</key> | |
<value>3</value> | |
</entry> | |
<entry> | |
<key>mime.type</key> | |
<value>application/json</value> | |
</entry> | |
<entry> | |
<key>schema.name</key> | |
<value>song</value> | |
</entry> | |
<entry> | |
<key>time</key> | |
<value>This data was generated at ${now():format("YYYY-MM-dd HH:mm:ss.SSS ZZZ")}. </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> | |
<state>STOPPED</state> | |
<style></style> | |
<type>org.apache.nifi.processors.attributes.UpdateAttribute</type> | |
</processors> | |
<processors> | |
<id>266ffea1-bc53-37c6-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<position> | |
<x>35.0</x> | |
<y>540.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.5.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>HTTP Status Code</key> | |
<value> | |
<name>HTTP Status Code</name> | |
</value> | |
</entry> | |
<entry> | |
<key>HTTP Context Map</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.http.HttpContextMap</identifiesControllerService> | |
<name>HTTP Context Map</name> | |
</value> | |
</entry> | |
<entry> | |
<key>batchId</key> | |
<value> | |
<name>batchId</name> | |
</value> | |
</entry> | |
<entry> | |
<key>groupSize</key> | |
<value> | |
<name>groupSize</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> | |
<entry> | |
<key>time</key> | |
<value> | |
<name>time</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>HTTP Status Code</key> | |
<value>200</value> | |
</entry> | |
<entry> | |
<key>HTTP Context Map</key> | |
<value>f59e5758-f1dd-380d-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>batchId</key> | |
<value>${batchId}</value> | |
</entry> | |
<entry> | |
<key>groupSize</key> | |
<value>${groupSize}</value> | |
</entry> | |
<entry> | |
<key>mime.type</key> | |
<value>${mime.type}</value> | |
</entry> | |
<entry> | |
<key>schema.name</key> | |
<value>${schema.name}</value> | |
</entry> | |
<entry> | |
<key>time</key> | |
<value>${time}</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<name>HandleHttpResponse</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style></style> | |
<type>org.apache.nifi.processors.standard.HandleHttpResponse</type> | |
</processors> | |
<processors> | |
<id>47ce6067-6153-31be-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<position> | |
<x>495.0</x> | |
<y>512.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.5.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Merge Strategy</key> | |
<value> | |
<name>Merge Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Merge Format</key> | |
<value> | |
<name>Merge Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Attribute Strategy</key> | |
<value> | |
<name>Attribute Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Correlation Attribute Name</key> | |
<value> | |
<name>Correlation Attribute Name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>mergecontent-metadata-strategy</key> | |
<value> | |
<name>mergecontent-metadata-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Minimum Number of Entries</key> | |
<value> | |
<name>Minimum Number of Entries</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Maximum Number of Entries</key> | |
<value> | |
<name>Maximum Number of Entries</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Minimum Group Size</key> | |
<value> | |
<name>Minimum Group Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Maximum Group Size</key> | |
<value> | |
<name>Maximum Group Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Max Bin Age</key> | |
<value> | |
<name>Max Bin Age</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Maximum number of Bins</key> | |
<value> | |
<name>Maximum number of Bins</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Delimiter Strategy</key> | |
<value> | |
<name>Delimiter Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Header File</key> | |
<value> | |
<name>Header File</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Footer File</key> | |
<value> | |
<name>Footer File</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Demarcator File</key> | |
<value> | |
<name>Demarcator File</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Compression Level</key> | |
<value> | |
<name>Compression Level</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Keep Path</key> | |
<value> | |
<name>Keep Path</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Tar Modified Time</key> | |
<value> | |
<name>Tar Modified Time</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Merge Strategy</key> | |
<value>Bin-Packing Algorithm</value> | |
</entry> | |
<entry> | |
<key>Merge Format</key> | |
<value>Binary Concatenation</value> | |
</entry> | |
<entry> | |
<key>Attribute Strategy</key> | |
<value>Keep Only Common Attributes</value> | |
</entry> | |
<entry> | |
<key>Correlation Attribute Name</key> | |
<value>batchId</value> | |
</entry> | |
<entry> | |
<key>mergecontent-metadata-strategy</key> | |
<value>Do Not Merge Uncommon Metadata</value> | |
</entry> | |
<entry> | |
<key>Minimum Number of Entries</key> | |
<value>3</value> | |
</entry> | |
<entry> | |
<key>Maximum Number of Entries</key> | |
<value>1000</value> | |
</entry> | |
<entry> | |
<key>Minimum Group Size</key> | |
<value>0 B</value> | |
</entry> | |
<entry> | |
<key>Maximum Group Size</key> | |
</entry> | |
<entry> | |
<key>Max Bin Age</key> | |
</entry> | |
<entry> | |
<key>Maximum number of Bins</key> | |
<value>5</value> | |
</entry> | |
<entry> | |
<key>Delimiter Strategy</key> | |
<value>Text</value> | |
</entry> | |
<entry> | |
<key>Header File</key> | |
</entry> | |
<entry> | |
<key>Footer File</key> | |
</entry> | |
<entry> | |
<key>Demarcator File</key> | |
<value>, | |
</value> | |
</entry> | |
<entry> | |
<key>Compression Level</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>Keep Path</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Tar Modified Time</key> | |
<value>${file.lastModifiedTime}</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<name>MergeContent</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>merged</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>original</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style></style> | |
<type>org.apache.nifi.processors.standard.MergeContent</type> | |
</processors> | |
<processors> | |
<id>58d84e83-e5d5-3ccf-0000-000000000000</id> | |
<parentGroupId>f31765c3-5e97-3ff1-0000-000000000000</parentGroupId> | |
<position> | |
<x>35.0</x> | |
<y>220.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.5.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Regular Expression</key> | |
<value> | |
<name>Regular Expression</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Replacement Value</key> | |
<value> | |
<name>Replacement Value</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Character Set</key> | |
<value> | |
<name>Character Set</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Maximum Buffer Size</key> | |
<value> | |
<name>Maximum Buffer Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Replacement Strategy</key> | |
<value> | |
<name>Replacement Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Evaluation Mode</key> | |
<value> | |
<name>Evaluation Mode</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Regular Expression</key> | |
<value>(?s)(^.*$)</value> | |
</entry> | |
<entry> | |
<key>Replacement Value</key> | |
<value>{ | |
"tracks": [{ | |
"artist": "Foo Fighters", | |
"title": "Bridge Burning", | |
"album": "Wasting Light" | |
}, | |
{ | |
"artist": "The Dave Brubeck Quartet", | |
"title": "Take Five", | |
"album": "Time Out" | |
}, | |
{ | |
"artist": "Smash Mouth", | |
"title": "AllStar", | |
"album": "Astro Lounge" | |
} | |
] | |
}</value> | |
</entry> | |
<entry> | |
<key>Character Set</key> | |
<value>UTF-8</value> | |
</entry> | |
<entry> | |
<key>Maximum Buffer Size</key> | |
<value>1 MB</value> | |
</entry> | |
<entry> | |
<key>Replacement Strategy</key> | |
<value>Regex Replace</value> | |
</entry> | |
<entry> | |
<key>Evaluation Mode</key> | |
<value>Entire text</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<name>ReplaceText</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>STOPPED</state> | |
<style></style> | |
<type>org.apache.nifi.processors.standard.ReplaceText</type> | |
</processors> | |
</snippet> | |
<timestamp>10/04/2017 18:03:43 PDT</timestamp> | |
</template> |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment