Member since
12-03-2017
155
Posts
26
Kudos Received
11
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
1825 | 11-03-2023 12:17 AM | |
3778 | 12-12-2022 09:16 PM | |
1438 | 07-14-2022 03:25 AM | |
2204 | 07-28-2021 04:42 AM | |
2783 | 06-23-2020 10:08 PM |
04-03-2019
04:54 AM
1 Kudo
Hello, I am observing quite strange behaviour of anyDelineatedValue expression when I use it with 'OR' operation. If I use 'AND' operation there is no issues. Input attribute value: org.entitlement.list=AA,CC,DD,FF Expression used in RouteOnAttribte/UpdateAttribute processor : ${anyDelineatedValue("${org.entitlement.list}", ","):equals('BB'):or(${anyDelineatedValue("${org.entitlement.list}", ","):contains('EE')})} Above expression is giving ArrayIndexOutOfBoundException for OR operation for the given input (where both the values which expression is looking is not present) If I use 'AND' operation expression works fine. What is the difference here? If I pass BB or EE in the input then expression wont give exception ! Looks like defect, can some one please suggest if anything wrong in this? Thanks Mahendra
... View more
Labels:
- Labels:
-
Apache NiFi
12-05-2018
11:34 AM
Thank you, its working with ${anyDelineatedValue("${your_attribute}", ","):equals("US")}
... View more
12-05-2018
10:24 AM
Hello, I have a scenario where I need to check for string contains, but for exact match of comma separated words. Example String: example = "US,UK,IN,NOT_APPLICABLE" I want to check above string contains specific word like 'US' or 'LE' Case 1: example.contains('US') . - expecting TRUE Case 2: example.contains('LE') - expecting FALSE If I use normal :contains(), case 2 will also return TRUE since 'LE' is part of 'NOT_APPLICABLE' But I want to check contains for comma separated values strictly. Is there any easy way to achieve this? Thanks, Mahendra
... View more
Labels:
- Labels:
-
Apache NiFi
11-23-2018
05:54 AM
Thanks @Shu ! It worked, I was using 'Return type' as auto instead of json in EvaluateJsonPath. Thanks for the reply 🙂
... View more
11-22-2018
10:53 AM
Hello, I have below json as flowfile content - { "organization_id": "life-360", "message_type_id": "MSG01", "consent_required": "1", "country_list": [
"GB",
"IT",
"BG"
]
} I want below content as output - GB, IT, BG I am able to get "country_list": [ "GB", "IT", "BG" ] in flow file using JOLT but not comma separated country list. Could any one please help with best way? Thanks, Mahendra
... View more
Labels:
- Labels:
-
Apache NiFi
11-20-2018
07:29 AM
Hello , I have a scenario where I need to run a processor on NiFi restart. Is there any way to trigger a nifi processor whenever nifi restarts ? Thanks in advance, Mahendra
... View more
Labels:
- Labels:
-
Apache NiFi
10-30-2018
03:42 PM
Thanks @Matt Burgess for clear information. Do you suggest any other approach? I am open for any kind of storage or caching, but end goal is I should be able to use some master data for every flow file validation without impacting performance..... (Master data is combination of company-country-datatype : this i want to use for every flow file validation) Thanks for your response 🙂 Mahendra
... View more
10-30-2018
11:27 AM
Hello All, I have requirement of caching some information in nifi and which should be used for every flow file validation (more than 1000 per second). I am thinking to store information in Cassandra table and update that to Nifi cache every 24 hours or so.. (Nifi cache update using PutDistributedMapCache processor) But problem is how to hold/re-load cache value when Nifi restarts due to various reasons.. I also want to understand where these cached message will be stored actually in multinode cluster nifi. Thanks in advance. Thanks, Mahendra
... View more
Labels:
- Labels:
-
Apache NiFi
07-23-2018
09:20 AM
@Matt Burgess , @Shu- Your help would be appreciated. Thanks
... View more
07-23-2018
09:19 AM
Hello, I have a json input for which I need to add one key-value("correlationId": "123456789") under 'tripSummaryMetaData' section dynamically. I tried with below spec and its working fine, but the issues is when 'tripSummaryMetaData' is not available the it is creating new 'tripSummaryMetaData' and adding my attribute. When 'tripSummaryMetaData' is not available the it should not add my new attribute, is that possible in JOLT? Thanks in advance. Input: {
"tripSummaryMetaData": {
"orgId": "demo",
"message_type_id": "MB-CD-MSG0001"
},
"eventSummary": {
"tripId": "2018072204cc7851d3e84f7ea8a1155c95f65b06",
"referenceData": "050bfa62-430a-45a5-b7a6-78d688d45167",
"gpsData": [{
"gpsTimeReceived": 1532319157338,
"gpsTime": "2018-07-22T21:12:38-07:00"
}]
}
} Output: {
"tripSummaryMetaData" : {
"orgId" : "demo",
"message_type_id" : "MB-CD-MSG0001",
"correlationId" : "123456789"
},
"eventSummary" : {
"tripId" : "2018072204cc7851d3e84f7ea8a1155c95f65b06",
"referenceData" : "050bfa62-430a-45a5-b7a6-78d688d45167",
"gpsData" : [ {
"gpsTimeReceived" : 1532319157338,
"gpsTime" : "2018-07-22T21:12:38-07:00"
} ]
}
} Spec : [{
"operation": "default",
"spec": {
"tripSummaryMetaData": {
"correlationId": "123456789"
}
}
}] Thanks, Mahendra
... View more
Labels:
- Labels:
-
Apache NiFi