apache-flink - 有没有办法将批处理数据移动到数据流中？

Question

我在看 Table-API。你能不能把一个批处理数据集转换成一个表，然后使用 todatastream 函数转换成数据流？我知道不久前有一个类似的问题，答案是否定的。自从重写 Table API 以来，这种情况发生了变化吗？

标签： apache-flink

Answer 1

不，这还不可能。表 API（和 SQL）查询被转换为 DataSet API 或 DataStream API 程序，具体取决于它们的源类型。

但是，有计划在较低级别建立统一的批处理/流 API。