转换函数

板块：pb-functions-transform · 88 篇

---

📄 文档列表

• Aggregate on condition（条件聚合 (Aggregate on condition)）
• Aggregate over window（基于窗口的聚合（Aggregate over window））
• Aggregate（聚合(Aggregate)）
• Apply expression（应用表达式（Apply expression））
• Array elements to columns（数组元素转列（Array elements to columns））
• Assign timestamps and watermarks（分配时间戳和水印(Assign timestamps and watermarks)）
• Coalesce data（合并分区（Coalesce data））
• Anti join（反连接（Anti join））
• Cross join（交叉连接（Cross join））
• Inner join（内连接（Inner join））
• KNN join（KNN 连接（KNN join））
• Left join（左连接(Left join)）
• Outer join（外连接(Outer join)）
• Semi join（半连接（Semi join））
• Compute if expression absent（计算表达式缺失时）
• Date distribution（日期分布（Date distribution））
• Drop duplicates（删除重复行（Drop duplicates））
• Drop columns（删除列（Drop columns））
• Empty file（空文件(Empty file)）
• Empty media set file（空媒体集文件（Empty media set file））
• Empty table（空表（Empty table））
• Extract rows from a dataset of email files（从电子邮件文件数据集中提取行）
• Extract file metadata from dataset as rows（从数据集中提取文件元数据为行）
• Filter files（筛选文件（Filter files））
• Filter（筛选（Filter））
• First union by name（按首个数据集名称合并（First union by name））
• Flatten struct（展开结构体 (Flatten struct)）
• Frequent pattern growth（频繁模式增长（Frequent pattern growth））
• Outer caching join（外缓存连接（Outer caching join））
• Geo distance inner join（地理距离内连接（Geo distance inner join））
• Geo distance left join（地理距离左连接(Geo distance left join)）
• Geo intersection left anti join（几何左反连接（Geo intersection left anti join））
• Geo intersection inner join（几何相交内连接（Geo intersection inner join））
• Geometry intersection join（几何相交连接（Geometry intersection join））
• Geo intersection left join（地理空间左连接（Geo intersection left join））
• Geometry knn inner join（几何K近邻内连接(Geometry knn inner join)）
• Geometry knn left join（几何K近邻左连接（Geometry knn left join））
• GeoPoint-to-GeoPoint 3d distance inner join（GeoPoint 到 GeoPoint 三维距离内连接（GeoPoint-to-GeoPoint 3d distance inner join））
• Extract many struct fields（提取多个结构体字段（Extract many struct fields））
• Heartbeat detection（心跳检测(Heartbeat detection)）
• Join（连接（Join））
• Keeps duplicates（保留重复行）
• Key by（按键分组 (Key by)）
• K-means clustering（K-means聚类（K-means clustering））
• Left lookup join（左查找连接(Left lookup join)）
• Get media references (datasets)（获取媒体引用（数据集））
• Convert media set to table rows（将媒体集转换为表行（Convert media set to table rows））
• Manually entered table（手动输入表）
• Mapping join（映射连接（Mapping join））
• Narrow union by name（按名称窄联合（Narrow union by name））
• New operator chain（新算子链(New operator chain)）
• Normalize column names（标准化列名）
• Numeric distribution（数值分布（Numeric distribution））
• Outer caching join（外缓存连接（Outer caching join））
• Extract rows from a CSV file（从CSV文件中提取行（Extract rows from a CSV file））
• Extract rows from an Excel file（从 Excel 文件中提取行）
• Extract rows from a GeoJSON file（从 GeoJSON 文件中提取行（Extract rows from a GeoJSON file））
• Extract rows from a JSON file（从 JSON 文件中提取行（Extract rows from a JSON file））
• Parse KML files into geometry lists（将KML文件解析为几何图形列表）
• Extract rows from shapefile（从 shapefile 中提取行）
• Extract rows from a dataset of text files（从文本文件数据集中提取行（Extract rows from a dataset of text files））
• Pivot（数据透视（Pivot））
• Apply to multiple columns（应用于多列）
• Apply multiple expressions（应用多个表达式（Apply multiple expressions））
• Rename columns（重命名列（Rename columns））
• Repartition data（重新分区数据 (Repartition data)）
• Rollup（汇总聚合 (Rollup)）
• Row size（行大小（Row size））
• Select columns（选择列(Select columns)）
• Sort（排序（Sort））
• Split on condition（按条件拆分（Split on condition））
• Text block（文本块（Text block））
• Time bounded drop duplicates（时间限定去重（Time bounded drop duplicates））
• Time bounded drop out of order（超时乱序丢弃（Time bounded drop out of order））
• Time bounded event time sort（时间有界事件时间排序（Time bounded event time sort））
• Top rows（顶行选取（Top rows））
• Decompress gzip files（解压缩 gzip 文件）
• Union by name（按名称联合（Union by name））
• Union files（合并文件（Union files））
• Unpivot（逆透视（Unpivot））
• Decompress tar files（解压 tar 文件）
• Unzip files（解压文件）
• Uppercase column names（将列名转换为大写）
• Wide union by name（按名称宽联合 (Wide union by name)）
• Window（窗口(Window)）
• Project over window（项目窗口（Project over window））
• Extract rows from an XML file（从 XML 文件中提取行（Extract rows from an XML file））