Flink MultipleInputStreamOperator，用于连接不同数据类型的多个流
对于同样面临使用Flink连接多个流问题的开发人员来说，这个线程应该是一个小的“入门”或起点。对于这个任务，我选择了级联方法或专门开发的“联合类型”。使用MultipleInputStreamOperatorFlink提供了一个涵盖此用例的工具。不幸的是，我没有找到任何示例或大量文档。因此，我决定写这篇文章，并提供一小段我的实现。这个例子并不完美，但它应该能让人理解这个想法。首先，您需要一个扩展MultipleInputStreamOperator和AbstractStreamOperatorV2的类以及