Skip to content

Instantly share code, notes, and snippets.

@MikeThomsen

MikeThomsen/ExecuteGraphQueryTest.xml

Created November 17, 2020 20:16
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save MikeThomsen/57a99042bab2cd09b31a1c78fb191d25 to your computer and use it in GitHub Desktop.
Save MikeThomsen/57a99042bab2cd09b31a1c78fb191d25 to your computer and use it in GitHub Desktop.
Download ZIP
Cypher test for ExecuteGraphQueryRecord
Raw
ExecuteGraphQueryTest.xml
<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<template encoding-version="1.3">
<description></description>
<groupId>b36f9057-0175-1000-7ec1-63187bd2c0b0</groupId>
<name>ExecuteGraphQueryRecord Cypher</name>
<snippet>
<processGroups>
<id>db861c5f-cbf3-35c8-0000-000000000000</id>
<parentGroupId>70bbc5bf-8996-3d7b-0000-000000000000</parentGroupId>
<position>
<x>0.0</x>
<y>0.0</y>
</position>
<comments></comments>
<contents>
<connections>
<id>598f9b91-d089-3c05-0000-000000000000</id>
<parentGroupId>db861c5f-cbf3-35c8-0000-000000000000</parentGroupId>
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
<backPressureObjectThreshold>10000</backPressureObjectThreshold>
<bends>
<x>712.0</x>
<y>512.0</y>
</bends>
<destination>
<groupId>db861c5f-cbf3-35c8-0000-000000000000</groupId>
<id>20ecd160-1d6b-3411-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>original</selectedRelationships>
<source>
<groupId>db861c5f-cbf3-35c8-0000-000000000000</groupId>
<id>275b3a69-88d3-303d-0000-000000000000</id>
<type>PROCESSOR</type>
</source>
<zIndex>0</zIndex>
</connections>
<connections>
<id>6967291d-612f-3034-0000-000000000000</id>
<parentGroupId>db861c5f-cbf3-35c8-0000-000000000000</parentGroupId>
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
<backPressureObjectThreshold>10000</backPressureObjectThreshold>
<bends>
<x>1104.0</x>
<y>528.0</y>
</bends>
<destination>
<groupId>db861c5f-cbf3-35c8-0000-000000000000</groupId>
<id>20ecd160-1d6b-3411-0000-000000000000</id>
<type>PROCESSOR</type>
</destination>
<flowFileExpiration>0 sec</flowFileExpiration>
<labelIndex>0</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>db861c5f-cbf3-35c8-0000-000000000000</groupId>
<id>275b3a69-88d3-303d-0000-000000000000</id>
<type>PROCESSOR</type>
</source>
<zIndex>0</zIndex>
</connections>
<connections>
<id>79a00ddd-f1b6-31dd-0000-000000000000</id>
<parentGroupId>db861c5f-cbf3-35c8-0000-000000000000</parentGroupId>
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
<backPressureObjectThreshold>10000</backPressureObjectThreshold>
<destination>
<groupId>db861c5f-cbf3-35c8-0000-000000000000</groupId>
<id>20ecd160-1d6b-3411-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>db861c5f-cbf3-35c8-0000-000000000000</groupId>
<id>07c1d347-822f-3380-0000-000000000000</id>
<type>PROCESSOR</type>
</source>
<zIndex>0</zIndex>
</connections>
<connections>
<id>80c6f85b-8035-3e4c-0000-000000000000</id>
<parentGroupId>db861c5f-cbf3-35c8-0000-000000000000</parentGroupId>
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
<backPressureObjectThreshold>10000</backPressureObjectThreshold>
<destination>
<groupId>db861c5f-cbf3-35c8-0000-000000000000</groupId>
<id>275b3a69-88d3-303d-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>db861c5f-cbf3-35c8-0000-000000000000</groupId>
<id>ac3ac062-4207-3c28-0000-000000000000</id>
<type>PROCESSOR</type>
</source>
<zIndex>0</zIndex>
</connections>
<connections>
<id>f3de12ad-7af0-3406-0000-000000000000</id>
<parentGroupId>db861c5f-cbf3-35c8-0000-000000000000</parentGroupId>
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
<backPressureObjectThreshold>10000</backPressureObjectThreshold>
<destination>
<groupId>db861c5f-cbf3-35c8-0000-000000000000</groupId>
<id>20ecd160-1d6b-3411-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>db861c5f-cbf3-35c8-0000-000000000000</groupId>
<id>f5f21cf9-f123-3156-0000-000000000000</id>
<type>PROCESSOR</type>
</source>
<zIndex>0</zIndex>
</connections>
<controllerServices>
<id>0ef19cc9-4294-39c0-0000-000000000000</id>
<parentGroupId>db861c5f-cbf3-35c8-0000-000000000000</parentGroupId>
<bundle>
<artifact>nifi-record-serialization-services-nar</artifact>
<group>org.apache.nifi</group>
<version>1.13.0-SNAPSHOT</version>
</bundle>
<comments></comments>
<descriptors>
<entry>
<key>Schema Write Strategy</key>
<value>
<name>Schema Write Strategy</name>
</value>
</entry>
<entry>
<key>schema-cache</key>
<value>
<identifiesControllerService>org.apache.nifi.serialization.RecordSchemaCacheService</identifiesControllerService>
<name>schema-cache</name>
</value>
</entry>
<entry>
<key>schema-protocol-version</key>
<value>
<dependencies>
<dependentValues>hwx-schema-ref-attributes</dependentValues>
<dependentValues>hwx-content-encoded-schema</dependentValues>
<propertyName>Schema Write Strategy</propertyName>
</dependencies>
<name>schema-protocol-version</name>
</value>
</entry>
<entry>
<key>schema-access-strategy</key>
<value>
<name>schema-access-strategy</name>
</value>
</entry>
<entry>
<key>schema-registry</key>
<value>
<dependencies>
<dependentValues>confluent-encoded</dependentValues>
<dependentValues>schema-name</dependentValues>
<dependentValues>hwx-schema-ref-attributes</dependentValues>
<dependentValues>hwx-content-encoded-schema</dependentValues>
<propertyName>schema-access-strategy</propertyName>
</dependencies>
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService>
<name>schema-registry</name>
</value>
</entry>
<entry>
<key>schema-name</key>
<value>
<dependencies>
<dependentValues>schema-name</dependentValues>
<propertyName>schema-access-strategy</propertyName>
</dependencies>
<name>schema-name</name>
</value>
</entry>
<entry>
<key>schema-version</key>
<value>
<dependencies>
<dependentValues>schema-name</dependentValues>
<propertyName>schema-access-strategy</propertyName>
</dependencies>
<name>schema-version</name>
</value>
</entry>
<entry>
<key>schema-branch</key>
<value>
<dependencies>
<dependentValues>schema-name</dependentValues>
<propertyName>schema-access-strategy</propertyName>
</dependencies>
<name>schema-branch</name>
</value>
</entry>
<entry>
<key>schema-text</key>
<value>
<dependencies>
<dependentValues>schema-text-property</dependentValues>
<propertyName>schema-access-strategy</propertyName>
</dependencies>
<name>schema-text</name>
</value>
</entry>
<entry>
<key>Date Format</key>
<value>
<name>Date Format</name>
</value>
</entry>
<entry>
<key>Time Format</key>
<value>
<name>Time Format</name>
</value>
</entry>
<entry>
<key>Timestamp Format</key>
<value>
<name>Timestamp Format</name>
</value>
</entry>
<entry>
<key>Pretty Print JSON</key>
<value>
<name>Pretty Print JSON</name>
</value>
</entry>
<entry>
<key>suppress-nulls</key>
<value>
<name>suppress-nulls</name>
</value>
</entry>
<entry>
<key>output-grouping</key>
<value>
<name>output-grouping</name>
</value>
</entry>
<entry>
<key>compression-format</key>
<value>
<name>compression-format</name>
</value>
</entry>
<entry>
<key>compression-level</key>
<value>
<dependencies>
<dependentValues>gzip</dependentValues>
<propertyName>compression-format</propertyName>
</dependencies>
<name>compression-level</name>
</value>
</entry>
</descriptors>
<name>JsonRecordSetWriter</name>
<persistsState>false</persistsState>
<properties>
<entry>
<key>Schema Write Strategy</key>
<value>no-schema</value>
</entry>
<entry>
<key>schema-cache</key>
</entry>
<entry>
<key>schema-protocol-version</key>
<value>1</value>
</entry>
<entry>
<key>schema-access-strategy</key>
<value>schema-name</value>
</entry>
<entry>
<key>schema-registry</key>
<value>167503f4-5c33-3148-0000-000000000000</value>
</entry>
<entry>
<key>schema-name</key>
<value>${schema.name}</value>
</entry>
<entry>
<key>schema-version</key>
</entry>
<entry>
<key>schema-branch</key>
</entry>
<entry>
<key>schema-text</key>
<value>${avro.schema}</value>
</entry>
<entry>
<key>Date Format</key>
</entry>
<entry>
<key>Time Format</key>
</entry>
<entry>
<key>Timestamp Format</key>
</entry>
<entry>
<key>Pretty Print JSON</key>
<value>false</value>
</entry>
<entry>
<key>suppress-nulls</key>
<value>never-suppress</value>
</entry>
<entry>
<key>output-grouping</key>
<value>output-array</value>
</entry>
<entry>
<key>compression-format</key>
<value>none</value>
</entry>
<entry>
<key>compression-level</key>
<value>1</value>
</entry>
</properties>
<state>ENABLED</state>
<type>org.apache.nifi.json.JsonRecordSetWriter</type>
</controllerServices>
<controllerServices>
<id>167503f4-5c33-3148-0000-000000000000</id>
<parentGroupId>db861c5f-cbf3-35c8-0000-000000000000</parentGroupId>
<bundle>
<artifact>nifi-registry-nar</artifact>
<group>org.apache.nifi</group>
<version>1.13.0-SNAPSHOT</version>
</bundle>
<comments></comments>
<descriptors>
<entry>
<key>avro-reg-validated-field-names</key>
<value>
<name>avro-reg-validated-field-names</name>
</value>
</entry>
<entry>
<key>user</key>
<value>
<name>user</name>
</value>
</entry>
</descriptors>
<name>AvroSchemaRegistry</name>
<persistsState>false</persistsState>
<properties>
<entry>
<key>avro-reg-validated-field-names</key>
<value>true</value>
</entry>
<entry>
<key>user</key>
<value>{
"name": "UserRecord",
"type": "record",
"fields": [
{
"name": "name",
"type": "string"
}
]
}</value>
</entry>
</properties>
<state>ENABLED</state>
<type>org.apache.nifi.schemaregistry.services.AvroSchemaRegistry</type>
</controllerServices>
<controllerServices>
<id>3982c468-fd64-36d9-0000-000000000000</id>
<parentGroupId>db861c5f-cbf3-35c8-0000-000000000000</parentGroupId>
<bundle>
<artifact>nifi-record-serialization-services-nar</artifact>
<group>org.apache.nifi</group>
<version>1.13.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>
<dependencies>
<dependentValues>confluent-encoded</dependentValues>
<dependentValues>schema-name</dependentValues>
<dependentValues>hwx-schema-ref-attributes</dependentValues>
<dependentValues>hwx-content-encoded-schema</dependentValues>
<propertyName>schema-access-strategy</propertyName>
</dependencies>
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService>
<name>schema-registry</name>
</value>
</entry>
<entry>
<key>schema-name</key>
<value>
<dependencies>
<dependentValues>schema-name</dependentValues>
<propertyName>schema-access-strategy</propertyName>
</dependencies>
<name>schema-name</name>
</value>
</entry>
<entry>
<key>schema-version</key>
<value>
<dependencies>
<dependentValues>schema-name</dependentValues>
<propertyName>schema-access-strategy</propertyName>
</dependencies>
<name>schema-version</name>
</value>
</entry>
<entry>
<key>schema-branch</key>
<value>
<dependencies>
<dependentValues>schema-name</dependentValues>
<propertyName>schema-access-strategy</propertyName>
</dependencies>
<name>schema-branch</name>
</value>
</entry>
<entry>
<key>schema-text</key>
<value>
<dependencies>
<dependentValues>schema-text-property</dependentValues>
<propertyName>schema-access-strategy</propertyName>
</dependencies>
<name>schema-text</name>
</value>
</entry>
<entry>
<key>schema-inference-cache</key>
<value>
<dependencies>
<dependentValues>infer-schema</dependentValues>
<propertyName>schema-access-strategy</propertyName>
</dependencies>
<identifiesControllerService>org.apache.nifi.serialization.RecordSchemaCacheService</identifiesControllerService>
<name>schema-inference-cache</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>
<value>schema-name</value>
</entry>
<entry>
<key>schema-registry</key>
<value>167503f4-5c33-3148-0000-000000000000</value>
</entry>
<entry>
<key>schema-name</key>
<value>${schema.name}</value>
</entry>
<entry>
<key>schema-version</key>
</entry>
<entry>
<key>schema-branch</key>
</entry>
<entry>
<key>schema-text</key>
<value>${avro.schema}</value>
</entry>
<entry>
<key>schema-inference-cache</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>c23d6c4e-eb7a-39c6-0000-000000000000</id>
<parentGroupId>db861c5f-cbf3-35c8-0000-000000000000</parentGroupId>
<bundle>
<artifact>nifi-neo4j-cypher-service-nar</artifact>
<group>org.apache.nifi</group>
<version>1.13.0-SNAPSHOT</version>
</bundle>
<comments></comments>
<descriptors>
<entry>
<key>neo4j-connection-url</key>
<value>
<name>neo4j-connection-url</name>
</value>
</entry>
<entry>
<key>neo4j-username</key>
<value>
<name>neo4j-username</name>
</value>
</entry>
<entry>
<key>neo4j-password</key>
<value>
<name>neo4j-password</name>
</value>
</entry>
<entry>
<key>neo4j-load-balancing-strategy</key>
<value>
<name>neo4j-load-balancing-strategy</name>
</value>
</entry>
<entry>
<key>neo4j-max-connection-time-out</key>
<value>
<name>neo4j-max-connection-time-out</name>
</value>
</entry>
<entry>
<key>neo4j-max-connection-pool-size</key>
<value>
<name>neo4j-max-connection-pool-size</name>
</value>
</entry>
<entry>
<key>neo4j-max-connection-acquisition-timeout</key>
<value>
<name>neo4j-max-connection-acquisition-timeout</name>
</value>
</entry>
<entry>
<key>neo4j-idle-time-before-test</key>
<value>
<name>neo4j-idle-time-before-test</name>
</value>
</entry>
<entry>
<key>neo4j-max-connection-lifetime</key>
<value>
<name>neo4j-max-connection-lifetime</name>
</value>
</entry>
<entry>
<key>neo4j-driver-tls-encryption-enabled</key>
<value>
<name>neo4j-driver-tls-encryption-enabled</name>
</value>
</entry>
<entry>
<key>SSL Context Service</key>
<value>
<identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService>
<name>SSL Context Service</name>
</value>
</entry>
</descriptors>
<name>Neo4JCypherClientService</name>
<persistsState>false</persistsState>
<properties>
<entry>
<key>neo4j-connection-url</key>
<value>bolt://localhost:7687</value>
</entry>
<entry>
<key>neo4j-username</key>
<value>neo4j</value>
</entry>
<entry>
<key>neo4j-password</key>
</entry>
<entry>
<key>neo4j-load-balancing-strategy</key>
<value>ROUND_ROBIN</value>
</entry>
<entry>
<key>neo4j-max-connection-time-out</key>
<value>5 seconds</value>
</entry>
<entry>
<key>neo4j-max-connection-pool-size</key>
<value>100</value>
</entry>
<entry>
<key>neo4j-max-connection-acquisition-timeout</key>
<value>60 second</value>
</entry>
<entry>
<key>neo4j-idle-time-before-test</key>
<value>60 seconds</value>
</entry>
<entry>
<key>neo4j-max-connection-lifetime</key>
<value>3600 seconds</value>
</entry>
<entry>
<key>neo4j-driver-tls-encryption-enabled</key>
<value>true</value>
</entry>
<entry>
<key>SSL Context Service</key>
</entry>
</properties>
<state>ENABLED</state>
<type>org.apache.nifi.graph.Neo4JCypherClientService</type>
</controllerServices>
<processors>
<id>07c1d347-822f-3380-0000-000000000000</id>
<parentGroupId>db861c5f-cbf3-35c8-0000-000000000000</parentGroupId>
<position>
<x>-72.0</x>
<y>592.0</y>
</position>
<bundle>
<artifact>nifi-graph-nar</artifact>
<group>org.apache.nifi</group>
<version>1.13.0-SNAPSHOT</version>
</bundle>
<config>
<bulletinLevel>WARN</bulletinLevel>
<comments></comments>
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
<descriptors>
<entry>
<key>graph-client-service</key>
<value>
<identifiesControllerService>org.apache.nifi.graph.GraphClientService</identifiesControllerService>
<name>graph-client-service</name>
</value>
</entry>
<entry>
<key>graph-query</key>
<value>
<name>graph-query</name>
</value>
</entry>
</descriptors>
<executionNode>ALL</executionNode>
<lossTolerant>false</lossTolerant>
<penaltyDuration>30 sec</penaltyDuration>
<properties>
<entry>
<key>graph-client-service</key>
<value>c23d6c4e-eb7a-39c6-0000-000000000000</value>
</entry>
<entry>
<key>graph-query</key>
<value>CREATE (p:Person { name: 'John' })</value>
</entry>
</properties>
<runDurationMillis>0</runDurationMillis>
<schedulingPeriod>5 sec</schedulingPeriod>
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
<yieldDuration>1 sec</yieldDuration>
</config>
<executionNodeRestricted>false</executionNodeRestricted>
<name>ExecuteGraphQuery</name>
<relationships>
<autoTerminate>true</autoTerminate>
<name>failure</name>
</relationships>
<relationships>
<autoTerminate>true</autoTerminate>
<name>original</name>
</relationships>
<relationships>
<autoTerminate>false</autoTerminate>
<name>success</name>
</relationships>
<state>STOPPED</state>
<style/>
<type>org.apache.nifi.processors.graph.ExecuteGraphQuery</type>
</processors>
<processors>
<id>20ecd160-1d6b-3411-0000-000000000000</id>
<parentGroupId>db861c5f-cbf3-35c8-0000-000000000000</parentGroupId>
<position>
<x>428.3333282470703</x>
<y>621.1666717529297</y>
</position>
<bundle>
<artifact>nifi-standard-nar</artifact>
<group>org.apache.nifi</group>
<version>1.13.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>false</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>
<executionNodeRestricted>false</executionNodeRestricted>
<name>LogAttribute</name>
<relationships>
<autoTerminate>false</autoTerminate>
<name>success</name>
</relationships>
<state>STOPPED</state>
<style/>
<type>org.apache.nifi.processors.standard.LogAttribute</type>
</processors>
<processors>
<id>275b3a69-88d3-303d-0000-000000000000</id>
<parentGroupId>db861c5f-cbf3-35c8-0000-000000000000</parentGroupId>
<position>
<x>568.0</x>
<y>280.0</y>
</position>
<bundle>
<artifact>nifi-graph-nar</artifact>
<group>org.apache.nifi</group>
<version>1.13.0-SNAPSHOT</version>
</bundle>
<config>
<bulletinLevel>WARN</bulletinLevel>
<comments></comments>
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
<descriptors>
<entry>
<key>client-service</key>
<value>
<identifiesControllerService>org.apache.nifi.graph.GraphClientService</identifiesControllerService>
<name>client-service</name>
</value>
</entry>
<entry>
<key>reader-service</key>
<value>
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService>
<name>reader-service</name>
</value>
</entry>
<entry>
<key>writer-service</key>
<value>
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService>
<name>writer-service</name>
</value>
</entry>
<entry>
<key>record-script</key>
<value>
<name>record-script</name>
</value>
</entry>
<entry>
<key>name</key>
<value>
<name>name</name>
</value>
</entry>
</descriptors>
<executionNode>ALL</executionNode>
<lossTolerant>false</lossTolerant>
<penaltyDuration>30 sec</penaltyDuration>
<properties>
<entry>
<key>client-service</key>
<value>c23d6c4e-eb7a-39c6-0000-000000000000</value>
</entry>
<entry>
<key>reader-service</key>
<value>3982c468-fd64-36d9-0000-000000000000</value>
</entry>
<entry>
<key>writer-service</key>
<value>0ef19cc9-4294-39c0-0000-000000000000</value>
</entry>
<entry>
<key>record-script</key>
<value>MATCH (p:Person) WHERE p.name = $name RETURN p</value>
</entry>
<entry>
<key>name</key>
<value>/name</value>
</entry>
</properties>
<runDurationMillis>0</runDurationMillis>
<schedulingPeriod>0 sec</schedulingPeriod>
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
<yieldDuration>1 sec</yieldDuration>
</config>
<executionNodeRestricted>false</executionNodeRestricted>
<name>ExecuteGraphQueryRecord</name>
<relationships>
<autoTerminate>true</autoTerminate>
<name>errors</name>
</relationships>
<relationships>
<autoTerminate>true</autoTerminate>
<name>failure</name>
</relationships>
<relationships>
<autoTerminate>false</autoTerminate>
<name>original</name>
</relationships>
<relationships>
<autoTerminate>false</autoTerminate>
<name>response</name>
</relationships>
<state>RUNNING</state>
<style/>
<type>org.apache.nifi.processors.graph.ExecuteGraphQueryRecord</type>
</processors>
<processors>
<id>ac3ac062-4207-3c28-0000-000000000000</id>
<parentGroupId>db861c5f-cbf3-35c8-0000-000000000000</parentGroupId>
<position>
<x>544.0</x>
<y>56.0</y>
</position>
<bundle>
<artifact>nifi-standard-nar</artifact>
<group>org.apache.nifi</group>
<version>1.13.0-SNAPSHOT</version>
</bundle>
<config>
<bulletinLevel>WARN</bulletinLevel>
<comments></comments>
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
<descriptors>
<entry>
<key>File Size</key>
<value>
<name>File Size</name>
</value>
</entry>
<entry>
<key>Batch Size</key>
<value>
<name>Batch Size</name>
</value>
</entry>
<entry>
<key>Data Format</key>
<value>
<name>Data Format</name>
</value>
</entry>
<entry>
<key>Unique FlowFiles</key>
<value>
<name>Unique FlowFiles</name>
</value>
</entry>
<entry>
<key>generate-ff-custom-text</key>
<value>
<name>generate-ff-custom-text</name>
</value>
</entry>
<entry>
<key>character-set</key>
<value>
<name>character-set</name>
</value>
</entry>
<entry>
<key>mime-type</key>
<value>
<name>mime-type</name>
</value>
</entry>
<entry>
<key>schema.name</key>
<value>
<name>schema.name</name>
</value>
</entry>
</descriptors>
<executionNode>ALL</executionNode>
<lossTolerant>false</lossTolerant>
<penaltyDuration>30 sec</penaltyDuration>
<properties>
<entry>
<key>File Size</key>
<value>0B</value>
</entry>
<entry>
<key>Batch Size</key>
<value>1</value>
</entry>
<entry>
<key>Data Format</key>
<value>Text</value>
</entry>
<entry>
<key>Unique FlowFiles</key>
<value>false</value>
</entry>
<entry>
<key>generate-ff-custom-text</key>
<value>[{
"name": "John"
},{
"name": "Jane"
}]</value>
</entry>
<entry>
<key>character-set</key>
<value>UTF-8</value>
</entry>
<entry>
<key>mime-type</key>
</entry>
<entry>
<key>schema.name</key>
<value>user</value>
</entry>
</properties>
<runDurationMillis>0</runDurationMillis>
<schedulingPeriod>5 sec</schedulingPeriod>
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
<yieldDuration>1 sec</yieldDuration>
</config>
<executionNodeRestricted>false</executionNodeRestricted>
<name>GenerateFlowFile</name>
<relationships>
<autoTerminate>false</autoTerminate>
<name>success</name>
</relationships>
<state>STOPPED</state>
<style/>
<type>org.apache.nifi.processors.standard.GenerateFlowFile</type>
</processors>
<processors>
<id>f5f21cf9-f123-3156-0000-000000000000</id>
<parentGroupId>db861c5f-cbf3-35c8-0000-000000000000</parentGroupId>
<position>
<x>85.33332824707031</x>
<y>278.1666717529297</y>
</position>
<bundle>
<artifact>nifi-graph-nar</artifact>
<group>org.apache.nifi</group>
<version>1.13.0-SNAPSHOT</version>
</bundle>
<config>
<bulletinLevel>WARN</bulletinLevel>
<comments></comments>
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
<descriptors>
<entry>
<key>graph-client-service</key>
<value>
<identifiesControllerService>org.apache.nifi.graph.GraphClientService</identifiesControllerService>
<name>graph-client-service</name>
</value>
</entry>
<entry>
<key>graph-query</key>
<value>
<name>graph-query</name>
</value>
</entry>
</descriptors>
<executionNode>ALL</executionNode>
<lossTolerant>false</lossTolerant>
<penaltyDuration>30 sec</penaltyDuration>
<properties>
<entry>
<key>graph-client-service</key>
<value>c23d6c4e-eb7a-39c6-0000-000000000000</value>
</entry>
<entry>
<key>graph-query</key>
<value>MATCH (p:Person) RETURN p</value>
</entry>
</properties>
<runDurationMillis>0</runDurationMillis>
<schedulingPeriod>5 sec</schedulingPeriod>
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
<yieldDuration>1 sec</yieldDuration>
</config>
<executionNodeRestricted>false</executionNodeRestricted>
<name>ExecuteGraphQuery</name>
<relationships>
<autoTerminate>true</autoTerminate>
<name>failure</name>
</relationships>
<relationships>
<autoTerminate>true</autoTerminate>
<name>original</name>
</relationships>
<relationships>
<autoTerminate>false</autoTerminate>
<name>success</name>
</relationships>
<state>STOPPED</state>
<style/>
<type>org.apache.nifi.processors.graph.ExecuteGraphQuery</type>
</processors>
</contents>
<flowfileConcurrency>UNBOUNDED</flowfileConcurrency>
<flowfileOutboundPolicy>STREAM_WHEN_AVAILABLE</flowfileOutboundPolicy>
<name>graph test</name>
<variables/>
</processGroups>
</snippet>
<timestamp>11/17/2020 15:14:49 EST</timestamp>
</template>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment