Hi, I was wondering if there is a reason for limiting union to only work on streams with the same slideDuration. Looking at UnionDStream.scala, if slideDuration was set to the minimum of the parents, and there was a require to enforce that all slideDuration were divisible wholly by the minimum, the exception could be removed from the compute method.
Is this correct or am I missing something? ******************************************************************** This email and any attachments are confidential to the intended recipient and may also be privileged. If you are not the intended recipient please delete it from your system and notify the sender. You should not copy it or use it for any purpose nor disclose or distribute its contents to any other person. ********************************************************************
