Hi Robert,
Thanks for your response.
Regards,
Shen
On Wed, Jul 6, 2016 at 4:02 PM, Robert Bradshaw wrote:
> It is an error at pipeline construction time to use CoGroupByKey with
> differing windowing strategies. If you want to do such joins, you may
> want to look into using side inputs which
It is an error at pipeline construction time to use CoGroupByKey with
differing windowing strategies. If you want to do such joins, you may
want to look into using side inputs which are more flexible.
On Wed, Jul 6, 2016 at 8:01 AM, Shen Li wrote:
> Hi,
>
> If the PCollections in a KeyedPCollecti
Hi,
If the PCollections in a KeyedPCollectionTuple have different window
strategies (WindowFn, Trigger, etc.), how does a CoGroupByKey work? When
will it be triggered? How does it determine which kvs from each PCollection
to co-group?
Thanks,
Shen
