希望有人可以帮助我，
我有一个数据流，我需要与数据中存在的不同键链接在一起 . 密钥最终应该链接，我需要输出一个流，其中所有已知密钥都添加到流中的相应数据中 . 我创建了一个变换器来构建密钥并将它们链接在一起 . 当我看到一组完整的密钥时，我将信息包含在变换流数据中 .
然后我设置了一个标识先前不完整密钥集的流 . 我创建了一个联接，目的是使用现在完整的密钥集加入以前不完整的密钥数据 . 然后将它们合并并转发 .
我还希望在1分钟后发出数据，这些数据在那段时间内没有完整的密钥集 .
我尝试使用左连接，但我发现连接数据发出两次（一个合并和原始数据），是否有一种技术，我应该用于获取连接数据和任何一分钟后不加入，没有得到连接数据两次 .