Member since
07-05-2024
5
Posts
2
Kudos Received
0
Solutions
07-17-2024
09:48 AM
Hi Team, I am facing the issue, while trying to fetch the value from jsonpathreader with avroschema attributes as below. json reading from avro schema with jsonpathreader, and want to fetch home number with expression $.phoneNumbers[?(@.type=="home")].number. However, it is getting failed. Please help on this. {
"firstName": "John",
"lastName": "Smith",
"isAlive": true,
"age": 25,
"address": {
"streetAddress": "21 2nd Street",
"city": "New York",
"state": "NY",
"postalCode": "10021-3100"
},
"phoneNumbers": [
{
"type": "home",
"number": "212 555-1234"
},
{
"type": "office",
"number": "646 555-4567"
}
],
"children": [],
"spouse": null
}
... View more
Labels:
- Labels:
-
Apache NiFi
07-11-2024
03:12 AM
1 Kudo
@SAMSAL I have found the issue, i.e data coming from C module. When i copy the c module data to a replacetext processor, and it is executing fine. So inside the module C it is required to apply regular expression (?s)(^.*$) to queue data in replacetext processor as mentioned below. Can you please suggest how to pass the queue data to Replacement Value in ReplaceText processor or any alternative approach. Appreciate your support on this!
... View more
07-10-2024
11:11 AM
Thanks for your info. Can you please suggest, is there any way to pinpoint the issues in a JoinEnrichment processor.
... View more
07-10-2024
06:54 AM
@SAMSAL : Thank so much for your feasible approach. I have applied the same way, however at AB&C JoinEnrichment processor is not getting executed. reviewed all input data parameters as well. Sample query is not getting executed ( select * from original) inside AB&C JoinEnrichment. I couldn't able to share the flow details as it is project specific. Can you please suggest!
... View more
07-05-2024
07:38 AM
1 Kudo
Hi Team, I have been trying to generate a scenario like three separate modules to join through Fork Enrichment with Join Enrichment process. For example: There are three processor groups A , B and C My existing code designed like join the A and B modules with Fork Enrichment with Join Enrichment process by adding strategy SQL, and getting the expected result. Now, latest requirement to join the Module C into SQL query with existing flow( SELECT a. id, b.name, c. city FROM A a JOIN B b ON a.id = b.id JOIN C c ON c.id = a.id) Is it possible to implement one original and two enrichment flows with Fork Enrichment with Join Enrichment, or any alternative approach Please advice.
... View more
Labels:
- Labels:
-
Apache NiFi