Flink表转流一例+何时应该使用execute()
生活随笔
收集整理的這篇文章主要介紹了
Flink表转流一例+何时应该使用execute()
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
我們常常會遇到是否應該寫execute()的問題
batch的print()中已經加入了execute
executeSql()里面已經加入了 execute
所以上述兩種情況下,代碼使用者不需要再在代碼末尾加入execute()
那么為什么下面這種使用executeSql以后為啥還需要在代碼末尾加入execute()呢
這是因為這個例子是
表轉流,
雖然表操作時的executeSql里面已經具備了execute()功能
但是這個只是激活表環境,沒有流環境,
所以需要再次execute()
也就是說,
對于表轉流這類代碼,需要executeSql和execute()相當于兩次execute才能讓代碼順利運行。
?
這是因為這個例子是表轉流
總結
以上是生活随笔為你收集整理的Flink表转流一例+何时应该使用execute()的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 金融卡是什么银行卡 金融卡属于什么银行卡
- 下一篇: The proctime attribu