FlinkSQL提供了連接外部數(shù)據(jù)的方法桑谍，即通過建立Flink表與外部數(shù)據(jù)關(guān)聯(lián)起來眷射。其中最基本的連接方式為普通動態(tài)表連接茉继，普通動態(tài)表允許讀取外部...

概念 自定義標量函數(shù)，接收一個或多個列，輸出一個列，行與行是一一對應的 構(gòu)造函數(shù)在jobmanager上創(chuàng)建udf時就執(zhí)行 open方法在所有并...

依賴 描述 flinksql以多線程的方式將數(shù)據(jù)寫入外部數(shù)據(jù)表 flinksql sink table的ddl中若聲明了主鍵，則上游數(shù)據(jù)到達si...

謂詞 謂詞指的是帶有過濾屬性的系統(tǒng)關(guān)鍵詞糖驴，如where、on佛致、having贮缕、like、>等俺榆。 謂詞下推 謂詞下推表達的是讓過濾提前執(zhí)行感昼，減少后續(xù)...

描述 通過operation信息(insert、update罐脊、delete)定嗓，實現(xiàn)了對上游數(shù)據(jù)的變更識別能力，這些信息會記錄在于上游數(shù)據(jù)連接的f...

描述 自定義udf萍桌，接收一個字段的每一個value宵溅，對應輸出轉(zhuǎn)換后的新value，與原value的關(guān)系是一對一 依賴 示例 部署

描述 異步讀取外部數(shù)據(jù)源上炎，并使用這些外部數(shù)據(jù)對主流數(shù)據(jù)進行必要的轉(zhuǎn)換 要求外部數(shù)據(jù)源支持異步讀取 要求代碼中的client支持發(fā)起異步請求 輸入...

hive-exec-shaded 此包是hive exec的shaded版本恃逻，在flink環(huán)境訪問hive需要用到此包，兼容flink藕施，排除掉了...

描述 數(shù)據(jù)在KeyBy后對key按hash結(jié)果進入對應的KeyedProcessFunction subtask 同個key的數(shù)據(jù)的所有數(shù)據(jù)都會...