我正在尝试使用apacheflink来处理使用两种不同算法的数据流。我的伪代码如下：

env = getEnvironment();
DataStream<Event> inputStream = getInputStream();
// How to replicate the input stream?
Array[DataStream<Event>] inputStreams = inputStream.clone()

// apply different operations on the replicated streams
outputOne = inputStreams[0].map(func1);
outputTwo = inputStreams[1].map(func2);
 ...
outputOne.addSink(sink1);
outputTwo.addSink(sink2);
env.execute();

我用flink文档做了一些研究。似乎没有克隆流的概念。datastream.iterate（）和datastream.split（）都不是我想要的。除了从源多次创建流之外，还有其他方法吗？谢谢你的帮助。