trident的另一种join

2018-07-11 本文已影响0人正居明阳

如果这个流有先后顺序，那么先的那个流，先写到kv存储
然后后的流，从kv中查找相同key的value，进行合并，然后再用这个state value进行输出一个新的流