我正在使用两个不同的[flink 1.1.2]-不同大小的数据集，让我们称之为dem ds\u little和ds\u big。我现在要做的是只保留dsu big的条目，这些条目在dsu little中有相应的条目。
比如：

if (first element of DS_Big = any element of DS_little)
{keep it and add an additional entry of DS_little to DS_Big}
else{forget it}

有没有一个聪明的方法可以做到这一点？
提前感谢您的帮助，
贝斯特t。