Hi, I have rather complex input dataset dependency.
My coordinator should run each day
Coordinator does get two input datasets:
-daily result
-weekly result
and produces one daily output dataset.
Example:
Imagine now is 24.09 (the 24th of Septemeber)
Corodinator should get:
/daily_dataset/2013/09/23/*
/weekly_calculated_dataset/2013/09/20 (it's last friday)
on the 28th of September it should be be:
/daily_dataset/2013/09/27/*
/weekly_calculated_dataset/2013/09/27 ("new" friday has been calculated by
other coordinator)
How can implement it?