FlinkSQL中的回退更新-Retraction

flinkSQL錶轉流 Flink 提出 Stream <–> Dynamic Table 之間是能夠等價轉換的 須要引入Retraction機制web toAppendStream 只支持insert toRetractStream 其他模式均可以 SQL 註冊表過程json TableDescriptor 描述表，尋找正確的factory，以後進行註冊爲table //對錶的描述 Tab

>>阅读原文<<