Hi > 这个难道没有一个列表，或者是配置开关之类的吗？难道只能一个一个地尝试？各种算子连接在一起，更难判断了。
现在确实缺少这方面的文档，简单的办法可以看下这个类org.apache.flink.table.plan.nodes.datastream.DataStreamRel 如果需要了解可以看下都有哪些算子实现这些方法即可 def needsUpdatesAsRetraction: Boolean = false def producesUpdates: Boolean = false def consumesRetractions: Boolean = false def producesRetractions: Boolean = false 祝好， Leonard Xu
