Hi Just wanted to check if some one has any suggestion ..
Narayan On Thu, May 7, 2015 at 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
