文章目錄
SQL 表值聚合函數(shù)(Table Aggregate Function)
SQL 表值聚合函數(shù)(Table Aggregate Function)
Python UDTAF,即 Python TableAggregateFunction。Python UDTAF 用來針對一組數(shù)據(jù)進行聚合運算,比如同一個 window 下的多條數(shù)據(jù)、或者同一個 key 下的多條數(shù)據(jù)等,與 Python UDAF 不同的是,針對同一組輸入數(shù)據(jù),Python UDTAF 可以產生 0 條、1 條、甚至多條輸出數(shù)據(jù)。文章來源:http://www.zghlxwxcb.cn/news/detail-725937.html
以下示例,定義了一個名字為 Top2 的 Python UDTAF:文章來源地址http://www.zghlxwxcb.cn/news/detail-725937.html
from pyflink.common import Row
from pyflink.table import DataTypes
from pyflink
到了這里,關于大數(shù)據(jù)Flink(一百零三):SQL 表值聚合函數(shù)(Table Aggregate Function)的文章就介紹完了。如果您還想了解更多內容,請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關文章,希望大家以后多多支持TOY模板網(wǎng)!