1.user表和invitation可以join,join的结果和activity没有可以关联的字段,除了cartesian,还有别的方法可以将他们关联到一起吗?
2.userActivity中if判断不生效,或者我使用filter会将所有数据过滤掉(条件应该没有错)?
3.
通过getRow拿到的rowkey写进mysql中是地址,这个问题怎么解决?
1.user表和invitation可以join,join的结果和activity没有可以关联的字段,除了cartesian,还有别的方法可以将他们关联到一起吗?
2.userActivity中if判断不生效,或者我使用filter会将所有数据过滤掉(条件应该没有错)?
3.
通过getRow拿到的rowkey写进mysql中是地址,这个问题怎么解决?
你保存的是地址,可能是由于你这段代码的原因
你这么写是不会生效的,过滤要用filter
你用的是cartesian,是笛卡尔集,你确定要这么关联吗?还是只关联必要的,当然这个cartesian不会产生shuffle,但是会产生很大的数据集