FlinkSQL中的Retraction回退更新是怎么進(jìn)行的

FlinkSQL中的Retraction回退更新是怎么進(jìn)行的，相信很多沒(méi)有經(jīng)驗(yàn)的人對(duì)此束手無(wú)策，為此本文總結(jié)了問(wèn)題出現(xiàn)的原因和解決方法，通過(guò)這篇文章希望你能解決這個(gè)問(wèn)題。

前言

如果你在使用FlinkSQL時(shí)出現(xiàn)如下的報(bào)錯(cuò)：

Table is not an append-only table. Use the toRetractStream() in order to handle add and retract messages.

簡(jiǎn)介

通俗的講"回退更新"就是傳統(tǒng)數(shù)據(jù)里面的更新操作，也就是說(shuō)Retract是流式計(jì)算場(chǎng)景下對(duì)數(shù)據(jù)更新的處理。

使用flinkSQL處理實(shí)時(shí)數(shù)據(jù)當(dāng)我們把表轉(zhuǎn)化成流的時(shí)候，需要用toAppendStream與toRetractStream這兩個(gè)方法。稍不注意可能直接選擇了toAppendStream。

區(qū)別

追加模式：只有在動(dòng)態(tài)Table僅通過(guò)INSERT更改修改時(shí)才能使用此模式，即它僅附加，并且以前發(fā)出的結(jié)果永遠(yuǎn)不會(huì)更新。

如果更新或刪除操作使用追加模式會(huì)失敗報(bào)錯(cuò)。

縮進(jìn)模式： 始終可以使用此模式。返回值是boolean類型。它用true或false來(lái)標(biāo)記數(shù)據(jù)的插入和撤回，返回true代表數(shù)據(jù)插入，false代表數(shù)據(jù)的撤回。

按照官網(wǎng)的理解如果數(shù)據(jù)只是不斷添加，可以使用追加模式，其余方式則不可以使用追加模式，而縮進(jìn)模式側(cè)可以適用于更新，刪除等場(chǎng)景。具體的區(qū)別如下圖所示：

通過(guò)上圖可以清晰的看到兩種方式的區(qū)別，當(dāng)我們使用的sql語(yǔ)句包含：count() group by時(shí)，必須使用縮進(jìn)模式。

舉個(gè)例子

上面的例子輸出結(jié)果如下：

前面數(shù)字相同的是同一組操作，true代表的是寫入，false代表的是撤回。

看完上述內(nèi)容，你們掌握FlinkSQL中的Retraction回退更新是怎么進(jìn)行的的方法了嗎？如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容，歡迎關(guān)注億速云行業(yè)資訊頻道，感謝各位的閱讀！