Hi Narayan,Looks like splitting two actions into two workflows and use
different coordinators to run would be a cleaner approach. I know it could be
one time extra work.
Regards,Mohammad
On Thursday, May 7, 2015 9:52 PM, Narayanan K <[email protected]>
wrote:
Hi
I have a workflow which has 2 actions run by a coordinator running daily.
The first one is daily aggregation - reads today's data, aggregates
and stores into today's daily folder.
The second action needs 7 day's daily aggregated data including
today's generated by the first action i.e it reads today's daily
aggregated data generated by the first action + the aggregated daily
data generated by the first action in the last 6 runs of the
coordinator.
Eg : If today is 20150510, first action generates
/user/abc/daily_interm/20150510.
Second action needs 7 days as input :
/user/abc/daily_interm/20150504,/user/abc/daily_interm/20150505,/user/abc/daily_interm/20150506,/user/abc/daily_interm/201505047,/user/abc/daily_interm/20150508,/user/abc/daily_interm/20150509,/user/abc/daily_interm/20150510
How can I form the input for the second action from the coordinator to
the workflow ?
Thanks
Narayan
