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

概念 自定義標(biāo)量函數(shù)斥季，接收一個或多個列交掏，輸出一個列沈条，行與行是一一對應(yīng)的 構(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，對應(yīng)輸出轉(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é)果進入對應(yīng)的KeyedProcessFunction subtask 同個key的數(shù)據(jù)的所有數(shù)據(jù)都會...