在Apache Flink中,我有一个元组流。让我们假设一个非常简单的Tuple1
- /输出/P1
在文档中,我只找到了可能写入我事先知道的位置(例如。stream.writeCsv文件(“/output/somewhere”)),但不能让数据的内容决定数据的实际结束位置。
我在文档中读到了关于输出拆分的内容,但这似乎没有提供一种将输出重定向到不同目的地的方法(或者我只是不明白这是如何 job 的)。
这可以用flinkapi实现吗?如果可以,怎么实现?如果没有,是否有第三方图书馆可以做到这一点,或者我必须自己建立这样一个东西?