您好:
目前公司数据都是密文,要进行密文数据的比较或者计算的话,只能调用公司密文计算的接口,去看了下flink的分组和join算子,都只能指定分组的key或者join的key,不知道怎么改写比较的规则,我用mapreduce实现了重写shuffle的比较规则,可以实现密文下的join和group
 by,对于使用spark和flink算子不知道如何实现。

问题:
请问有啥办法,实现密文下的join和group by操作吗?(在不能解密,只能调用公司密文计算的接口)

谢谢您。



发自 网易邮箱大师

回复