Commit 988f683f by Hassan Javeed

Change output path for user_video_viewing.

parent 924deb83
......@@ -537,7 +537,7 @@ class UserVideoViewingByDateTask(OverwriteOutputMixin, VideoTableDownstreamMixin
))
def requires(self):
output_path = self.hive_partition_path('user_video_viewing', self.interval.date_b)
output_path = self.hive_partition_path('user_video_viewing_with_user_id', self.interval.date_b)
return UserVideoViewingTask(
mapreduce_engine=self.mapreduce_engine,
n_reduce_tasks=self.n_reduce_tasks,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment