{"flowContents":{"identifier":"617b88be-30db-3d0a-98c2-95e390642b59","instanceIdentifier":"466a2566-0181-1000-ffff-ffffa1f67c45","name":"Avro Conversion","comments":"","position":{"x":1520.0,"y":533.0},"processGroups":[],"remoteProcessGroups":[],"processors":[{"identifier":"ef7fe59b-f618-3a4a-bb7d-729778c4ae7a","instanceIdentifier":"875d3abe-8054-3bff-b32d-9ff5f9467c27","name":"ConvertRecord","comments":"","position":{"x":2048.0,"y":912.0},"type":"org.apache.nifi.processors.standard.ConvertRecord","bundle":{"group":"org.apache.nifi","artifact":"nifi-standard-nar","version":"1.16.0.2.2.5.0-59"},"properties":{"record-writer":"6218b897-46fa-36ab-976a-e5c4f7c8b975","record-reader":"2d5ee1f2-729e-3f1d-bbd3-675c3a92ef69","include-zero-record-flowfiles":"true"},"propertyDescriptors":{"record-writer":{"name":"record-writer","displayName":"Record Writer","identifiesControllerService":true,"sensitive":false},"record-reader":{"name":"record-reader","displayName":"Record Reader","identifiesControllerService":true,"sensitive":false},"include-zero-record-flowfiles":{"name":"include-zero-record-flowfiles","displayName":"Include Zero Record FlowFiles","identifiesControllerService":false,"sensitive":false}},"style":{},"schedulingPeriod":"0 sec","schedulingStrategy":"TIMER_DRIVEN","executionNode":"ALL","penaltyDuration":"30 sec","yieldDuration":"1 sec","bulletinLevel":"WARN","runDurationMillis":0,"concurrentlySchedulableTaskCount":1,"autoTerminatedRelationships":["failure"],"scheduledState":"ENABLED","retryCount":10,"retriedRelationships":[],"backoffMechanism":"PENALIZE_FLOWFILE","maxBackoffPeriod":"10 mins","componentType":"PROCESSOR","groupIdentifier":"617b88be-30db-3d0a-98c2-95e390642b59"},{"identifier":"5b2f6bec-e14e-36be-bc09-34267c2cbe3e","instanceIdentifier":"3d7a12ad-9d77-3029-a329-7029ac38f325","name":"GenerateFlowFile","comments":"","position":{"x":2048.0,"y":528.0},"type":"org.apache.nifi.processors.standard.GenerateFlowFile","bundle":{"group":"org.apache.nifi","artifact":"nifi-standard-nar","version":"1.16.0.2.2.5.0-59"},"properties":{"character-set":"UTF-8","File Size":"0B","mime-type":null,"generate-ff-custom-text":"{\n\n\"X\":123,\n\n\"Y\":\"ABC\",\n\n\"Z\":\"zzz\",\n\n\"W\":\"www\"\n\n}","Batch Size":"1","Unique FlowFiles":"false","Data Format":"Text"},"propertyDescriptors":{"character-set":{"name":"character-set","displayName":"Character Set","identifiesControllerService":false,"sensitive":false},"File Size":{"name":"File Size","displayName":"File Size","identifiesControllerService":false,"sensitive":false},"mime-type":{"name":"mime-type","displayName":"Mime Type","identifiesControllerService":false,"sensitive":false},"generate-ff-custom-text":{"name":"generate-ff-custom-text","displayName":"Custom Text","identifiesControllerService":false,"sensitive":false},"Batch Size":{"name":"Batch Size","displayName":"Batch Size","identifiesControllerService":false,"sensitive":false},"Unique FlowFiles":{"name":"Unique FlowFiles","displayName":"Unique FlowFiles","identifiesControllerService":false,"sensitive":false},"Data Format":{"name":"Data Format","displayName":"Data Format","identifiesControllerService":false,"sensitive":false}},"style":{},"schedulingPeriod":"0 sec","schedulingStrategy":"TIMER_DRIVEN","executionNode":"ALL","penaltyDuration":"30 sec","yieldDuration":"1 sec","bulletinLevel":"WARN","runDurationMillis":0,"concurrentlySchedulableTaskCount":1,"autoTerminatedRelationships":[],"scheduledState":"ENABLED","retryCount":10,"retriedRelationships":[],"backoffMechanism":"PENALIZE_FLOWFILE","maxBackoffPeriod":"10 mins","componentType":"PROCESSOR","groupIdentifier":"617b88be-30db-3d0a-98c2-95e390642b59"},{"identifier":"36eff10e-4651-319a-a4ac-a4fa01a172f1","instanceIdentifier":"5ac1dd92-3ffc-385f-b2e0-656f0d329117","name":"JoltTransformJSON","comments":"","position":{"x":2048.0,"y":720.0},"type":"org.apache.nifi.processors.standard.JoltTransformJSON","bundle":{"group":"org.apache.nifi","artifact":"nifi-standard-nar","version":"1.16.0.2.2.5.0-59"},"properties":{"jolt-spec":"[\n  {\n    \"operation\": \"shift\",\n    \"spec\": {\n      \"X\": \"&\",\n      \"Y\": \"&\",\n      \"*\": \"Custom.&\"\n    }\n  }\n]","jolt-transform":"jolt-transform-chain","jolt-custom-class":null,"jolt-custom-modules":null,"pretty_print":"false","Transform Cache Size":"1"},"propertyDescriptors":{"jolt-spec":{"name":"jolt-spec","displayName":"Jolt Specification","identifiesControllerService":false,"sensitive":false},"jolt-transform":{"name":"jolt-transform","displayName":"Jolt Transformation DSL","identifiesControllerService":false,"sensitive":false},"jolt-custom-class":{"name":"jolt-custom-class","displayName":"Custom Transformation Class Name","identifiesControllerService":false,"sensitive":false},"jolt-custom-modules":{"name":"jolt-custom-modules","displayName":"Custom Module Directory","identifiesControllerService":false,"sensitive":false,"resourceDefinition":{"cardinality":"MULTIPLE","resourceTypes":["DIRECTORY","FILE"]}},"pretty_print":{"name":"pretty_print","displayName":"Pretty Print","identifiesControllerService":false,"sensitive":false},"Transform Cache Size":{"name":"Transform Cache Size","displayName":"Transform Cache Size","identifiesControllerService":false,"sensitive":false}},"style":{},"schedulingPeriod":"0 sec","schedulingStrategy":"TIMER_DRIVEN","executionNode":"ALL","penaltyDuration":"30 sec","yieldDuration":"1 sec","bulletinLevel":"WARN","runDurationMillis":0,"concurrentlySchedulableTaskCount":1,"autoTerminatedRelationships":["failure"],"scheduledState":"ENABLED","retryCount":10,"retriedRelationships":[],"backoffMechanism":"PENALIZE_FLOWFILE","maxBackoffPeriod":"10 mins","componentType":"PROCESSOR","groupIdentifier":"617b88be-30db-3d0a-98c2-95e390642b59"}],"inputPorts":[],"outputPorts":[],"connections":[{"identifier":"f1989928-004a-33af-a94a-cf7ea532f08c","instanceIdentifier":"8c528301-e11f-314c-b76b-a1edb402d48c","name":"","source":{"id":"36eff10e-4651-319a-a4ac-a4fa01a172f1","type":"PROCESSOR","groupId":"617b88be-30db-3d0a-98c2-95e390642b59","name":"JoltTransformJSON","comments":"","instanceIdentifier":"5ac1dd92-3ffc-385f-b2e0-656f0d329117"},"destination":{"id":"ef7fe59b-f618-3a4a-bb7d-729778c4ae7a","type":"PROCESSOR","groupId":"617b88be-30db-3d0a-98c2-95e390642b59","name":"ConvertRecord","comments":"","instanceIdentifier":"875d3abe-8054-3bff-b32d-9ff5f9467c27"},"labelIndex":1,"zIndex":0,"selectedRelationships":["success"],"backPressureObjectThreshold":10000,"backPressureDataSizeThreshold":"1 GB","flowFileExpiration":"0 sec","prioritizers":[],"bends":[],"loadBalanceStrategy":"DO_NOT_LOAD_BALANCE","partitioningAttribute":"","loadBalanceCompression":"DO_NOT_COMPRESS","componentType":"CONNECTION","groupIdentifier":"617b88be-30db-3d0a-98c2-95e390642b59"},{"identifier":"543558a9-5422-3f74-9703-ead3b4f579b1","instanceIdentifier":"e5ca77fa-ecca-3b64-b0f0-3f45feecf437","name":"","source":{"id":"ef7fe59b-f618-3a4a-bb7d-729778c4ae7a","type":"PROCESSOR","groupId":"617b88be-30db-3d0a-98c2-95e390642b59","name":"ConvertRecord","comments":"","instanceIdentifier":"875d3abe-8054-3bff-b32d-9ff5f9467c27"},"destination":{"id":"3635c477-8db5-317a-975d-4dccdb60366c","type":"FUNNEL","groupId":"617b88be-30db-3d0a-98c2-95e390642b59","name":"Funnel","comments":"","instanceIdentifier":"f7d932ab-0ac9-3f0d-9e7e-4976596675c7"},"labelIndex":1,"zIndex":0,"selectedRelationships":["success"],"backPressureObjectThreshold":10000,"backPressureDataSizeThreshold":"1 GB","flowFileExpiration":"0 sec","prioritizers":[],"bends":[],"loadBalanceStrategy":"DO_NOT_LOAD_BALANCE","partitioningAttribute":"","loadBalanceCompression":"DO_NOT_COMPRESS","componentType":"CONNECTION","groupIdentifier":"617b88be-30db-3d0a-98c2-95e390642b59"},{"identifier":"d407f86f-5f9c-3af8-b616-8f8cd6522f02","instanceIdentifier":"61b1a306-60c8-3a46-9e9c-59b0a38e7611","name":"","source":{"id":"5b2f6bec-e14e-36be-bc09-34267c2cbe3e","type":"PROCESSOR","groupId":"617b88be-30db-3d0a-98c2-95e390642b59","name":"GenerateFlowFile","comments":"","instanceIdentifier":"3d7a12ad-9d77-3029-a329-7029ac38f325"},"destination":{"id":"36eff10e-4651-319a-a4ac-a4fa01a172f1","type":"PROCESSOR","groupId":"617b88be-30db-3d0a-98c2-95e390642b59","name":"JoltTransformJSON","comments":"","instanceIdentifier":"5ac1dd92-3ffc-385f-b2e0-656f0d329117"},"labelIndex":1,"zIndex":0,"selectedRelationships":["success"],"backPressureObjectThreshold":10000,"backPressureDataSizeThreshold":"1 GB","flowFileExpiration":"0 sec","prioritizers":[],"bends":[],"loadBalanceStrategy":"DO_NOT_LOAD_BALANCE","partitioningAttribute":"","loadBalanceCompression":"DO_NOT_COMPRESS","componentType":"CONNECTION","groupIdentifier":"617b88be-30db-3d0a-98c2-95e390642b59"}],"labels":[],"funnels":[{"identifier":"3635c477-8db5-317a-975d-4dccdb60366c","instanceIdentifier":"f7d932ab-0ac9-3f0d-9e7e-4976596675c7","position":{"x":2200.0,"y":1104.0},"componentType":"FUNNEL","groupIdentifier":"617b88be-30db-3d0a-98c2-95e390642b59"}],"controllerServices":[{"identifier":"6218b897-46fa-36ab-976a-e5c4f7c8b975","instanceIdentifier":"a76f37b4-d0e8-31d8-b5da-c55f2d81930f","name":"AvroRecordSetWriter - test","comments":"","type":"org.apache.nifi.avro.AvroRecordSetWriter","bundle":{"group":"org.apache.nifi","artifact":"nifi-record-serialization-services-nar","version":"1.16.0.2.2.5.0-59"},"properties":{"compression-format":"NONE","Schema Write Strategy":"avro-embedded","schema-branch":null,"schema-name":"${schema.name}","cache-size":"1000","schema-registry":null,"schema-access-strategy":"schema-text-property","schema-protocol-version":"1","schema-version":null,"encoder-pool-size":"32","schema-cache":null,"schema-text":"#{schema}"},"propertyDescriptors":{"compression-format":{"name":"compression-format","displayName":"Compression Format","identifiesControllerService":false,"sensitive":false},"Schema Write Strategy":{"name":"Schema Write Strategy","displayName":"Schema Write Strategy","identifiesControllerService":false,"sensitive":false},"schema-branch":{"name":"schema-branch","displayName":"Schema Branch","identifiesControllerService":false,"sensitive":false},"schema-name":{"name":"schema-name","displayName":"Schema Name","identifiesControllerService":false,"sensitive":false},"cache-size":{"name":"cache-size","displayName":"Cache Size","identifiesControllerService":false,"sensitive":false},"schema-registry":{"name":"schema-registry","displayName":"Schema Registry","identifiesControllerService":true,"sensitive":false},"schema-access-strategy":{"name":"schema-access-strategy","displayName":"Schema Access Strategy","identifiesControllerService":false,"sensitive":false},"schema-protocol-version":{"name":"schema-protocol-version","displayName":"Schema Protocol Version","identifiesControllerService":false,"sensitive":false},"schema-version":{"name":"schema-version","displayName":"Schema Version","identifiesControllerService":false,"sensitive":false},"encoder-pool-size":{"name":"encoder-pool-size","displayName":"Encoder Pool Size","identifiesControllerService":false,"sensitive":false},"schema-cache":{"name":"schema-cache","displayName":"Schema Cache","identifiesControllerService":true,"sensitive":false},"schema-text":{"name":"schema-text","displayName":"Schema Text","identifiesControllerService":false,"sensitive":false}},"controllerServiceApis":[{"type":"org.apache.nifi.serialization.RecordSetWriterFactory","bundle":{"group":"org.apache.nifi","artifact":"nifi-standard-services-api-nar","version":"1.16.0.2.2.5.0-59"}}],"scheduledState":"ENABLED","componentType":"CONTROLLER_SERVICE","groupIdentifier":"617b88be-30db-3d0a-98c2-95e390642b59"},{"identifier":"2d5ee1f2-729e-3f1d-bbd3-675c3a92ef69","instanceIdentifier":"c7b4a115-ecb6-397f-bf5c-c7a05d0f0277","name":"JsonTreeReader - test","comments":"","type":"org.apache.nifi.json.JsonTreeReader","bundle":{"group":"org.apache.nifi","artifact":"nifi-record-serialization-services-nar","version":"1.16.0.2.2.5.0-59"},"properties":{"Timestamp Format":null,"schema-inference-cache":null,"Date Format":null,"schema-branch":null,"schema-name":"${schema.name}","schema-registry":null,"Time Format":null,"schema-access-strategy":"schema-text-property","schema-version":null,"schema-text":"#{schema}"},"propertyDescriptors":{"Timestamp Format":{"name":"Timestamp Format","displayName":"Timestamp Format","identifiesControllerService":false,"sensitive":false},"schema-inference-cache":{"name":"schema-inference-cache","displayName":"Schema Inference Cache","identifiesControllerService":true,"sensitive":false},"Date Format":{"name":"Date Format","displayName":"Date Format","identifiesControllerService":false,"sensitive":false},"schema-branch":{"name":"schema-branch","displayName":"Schema Branch","identifiesControllerService":false,"sensitive":false},"schema-name":{"name":"schema-name","displayName":"Schema Name","identifiesControllerService":false,"sensitive":false},"schema-registry":{"name":"schema-registry","displayName":"Schema Registry","identifiesControllerService":true,"sensitive":false},"Time Format":{"name":"Time Format","displayName":"Time Format","identifiesControllerService":false,"sensitive":false},"schema-access-strategy":{"name":"schema-access-strategy","displayName":"Schema Access Strategy","identifiesControllerService":false,"sensitive":false},"schema-version":{"name":"schema-version","displayName":"Schema Version","identifiesControllerService":false,"sensitive":false},"schema-text":{"name":"schema-text","displayName":"Schema Text","identifiesControllerService":false,"sensitive":false}},"controllerServiceApis":[{"type":"org.apache.nifi.serialization.RecordReaderFactory","bundle":{"group":"org.apache.nifi","artifact":"nifi-standard-services-api-nar","version":"1.16.0.2.2.5.0-59"}}],"scheduledState":"ENABLED","componentType":"CONTROLLER_SERVICE","groupIdentifier":"617b88be-30db-3d0a-98c2-95e390642b59"}],"variables":{},"parameterContextName":"test","defaultFlowFileExpiration":"0 sec","defaultBackPressureObjectThreshold":10000,"defaultBackPressureDataSizeThreshold":"1 GB","flowFileConcurrency":"UNBOUNDED","flowFileOutboundPolicy":"STREAM_WHEN_AVAILABLE","componentType":"PROCESS_GROUP"},"externalControllerServices":{},"parameterContexts":{"test":{"name":"test","parameters":[{"name":"schema","description":"","sensitive":false,"value":"{\n  \"name\": \"schema\",\n  \"type\": \"record\",\n  \"fields\": [\n    {\n      \"name\": \"X\",\n      \"type\": \"long\"\n    },\n    {\n      \"name\": \"Y\",\n      \"type\": \"string\"\n    },\n    {\n      \"name\": \"Custom\",\n      \"type\": {\n        \"type\": \"map\",\n        \"values\": \"string\"\n      }\n    }\n  ]\n}"}],"inheritedParameterContexts":[],"componentType":"PARAMETER_CONTEXT"}},"flowEncodingVersion":"1.0"}