StreamTableEnvironment#toDataStream 和 toAppendStream 之间有什么区别

Question

我正在阅读StreamTableEnvironment的源代码，它有两个方法：toDataStream和toAppendStream。

这两种方法都只对行数为RowKind.INSERT的table起作用，也就是说，这两种方法都是将table转换为追加流。

请问这两种方法的主要区别是什么，我认为它们是相同的。

Answer 1

toAppendStream 是遗留的，将在下一个 Flink 版本中弃用。尚未弃用它的原因是我们希望 toDataStream 在 1.13.1 中提供更多的曝光度和稳定性。

差异不是直接可见的，而是存在的。例如，结构化 POJO 类型的处理方式不同。