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

Reply via email to