Member since
09-01-2017
3
Posts
0
Kudos Received
0
Solutions
09-05-2017
04:58 PM
@seshachalam malisetti, i'm not sure about the straight forward way to do this, but we can limit fetching the data twice by running query in execute sql processor with all the max value columns in it. 1.in my case i am having START_DATE_TIME,END_DATE_TIME are the Maximum-value Columns, so i have used them inside my execute sql processor sql statement. select max(START_DATE_TIME) as MAX_START_DATE_TIME,max(END_DATE_TIME) as MAX_END_DATE_TIME from test 2. Result flowfile from executesql will be in avro format use ConvertAvrotoJson processor with default properties. 3. Extract the attributes from json flowfile by using EvaluateJsonPath processor and change Destination property to flowfile-attribute, it will results the extracted attributes values will be part of flow file attributes. using the properties mentioned in the screenshot below:- 4. Use those max value attributes associated with the flowfile to run your join incrementally. Flow Screenshot:-
... View more