About ang_coder

ang_coder · ‎04-20-2021

@Shu_ashu I tried this below expression for two job names in my flow and it is throwing error. Could you help? Options I tried: ```${N_JOB:equalsIgnoreCase('DWDMBL0D','DWDMBL0F'):and(${LAST_RUN:equals('${custom_date}')}):and(${C_CURR_STA:equalsIgnoreCase('C')})}``` ```${N_JOB:equalsIgnoreCase("DWDMBL0D","DWDMBL0F"):and(${LAST_RUN:equals('${custom_date}')}):and(${C_CURR_STA:equalsIgnoreCase('C')})}```

ang_coder · ‎04-19-2021

I get two flow files and I need to look at the value of data in flow files based on two different conditions in RouteOnAttribute. If both the conditions match, then only the flow should be routed to executeSQL processor, else it should flow down to MonitorActivity Processor. I tried multiple ways, but this is not working. Every time, when one of the conditions match, it gets routed to executeSQL Processor.

ang_coder · ‎12-08-2020

thank you very much! This works.

ang_coder · ‎12-07-2020

Can you please tell me where did you set the AvroSchemaRegistry? Since you are retrieving the data from SQL DB, you are getting it as Avro format. My incoming data is json format. So how can I use my flow file directly in Update Attribute and use in ConvertRecord? Does it make sense?

ang_coder · ‎12-03-2020

I am using ConvertJSONtoSQL to convert simple JSON to a SQL statement for inserting rows in DB2. I am using ConvertJSONtoSQL and PutSQL to write to DB2, but it is omitting the unmatched columns. How can I add unmatched columns to the SQL? Is there a way to add the matching names in the JSON prior to running ConvertJSONtoSQL? I tried using AttributestoJSON but it didn't work. Can someone please help me?

ang_coder · ‎05-29-2020

My processor is querying a DB2 table and loads data to S3 and then ingest it into Snowflake. I have unique account numbers in my table and I need to add a column with unique identifier for each unique account number.

Online	Offline
Last Visited	‎05-07-2021 09:10 AM

Member Since	‎05-29-2020 07:41 AM
Last Visited	‎05-07-2021 09:10 AM
Posts	6

Cloudera Community

Re: Trigger processor based on the condition - Nif...

RountOnAttribute Multiple Conditions (Properties)

Re: ConvertJSONtoSQL Issue: How to get unmatched C...

Re: ConvertJSONtoSQL Issue: How to get unmatched C...

ConvertJSONtoSQL Issue: How to get unmatched Colum...

Is there any processor in NiFi which helps me add ...