企业官网建设流程全解析

鸿运通网站建设,英文写作网站,2023企业税收标准,页面模板功能找不到1. Window Top-N 是什么 Window Top-N 是一种特殊的 Top-N#xff1a;在每个窗口#xff08;window#xff09;内#xff0c;对 N 个最大/最小值进行筛选#xff0c;并且支持再叠加其它分区键#xff08;partition keys#xff09;。 在 Streaming 查询中#xff0c;Wi…1. Window Top-N 是什么Window Top-N 是一种特殊的 Top-N在每个窗口window内对 N 个最大/最小值进行筛选并且支持再叠加其它分区键partition keys。在Streaming查询中Window Top-N不会像连续 Top-N 那样持续输出中间更新而是只在窗口结束时输出最终 Top-N并且窗口结束后会清理中间状态因此如果你不需要“每条记录更新榜单”它通常性能更好。2. Window Top-N 的关键前置条件2.1 必须基于 Windowing TVF 或 Window AggregationWindow Top-N 一般直接跟在 Windowing TVF例如 TUMBLE/HOP/CUMULATE后或跟在 Window Aggregation窗口聚合后使用。2.2 PARTITION BY 必须包含 window_start 和 window_endWindow Top-N 的 SQL 形式和普通 Top-N 相同但额外要求PARTITION BY必须包含window_start与window_end来自 Windowing TVF 或 Window Aggregation 的结果否则优化器无法翻译成 Window Top-N。2.3 Windowing TVF 会产出哪些窗口字段Windowing TVF 会返回一个包含原始字段的关系表并额外生成window_start、window_end、window_time三个字段。3. Window Top-N 的标准语法模板下面这个模板建议严格照抄结构只改字段名与 N以保证优化器能识别SELECT[column_list]FROM(SELECT[column_list],ROW_NUMBER()OVER(PARTITIONBYwindow_start,window_end[,col_key1...]ORDERBYcol1[asc|desc][,col2[asc|desc]...])ASrownumFROMtable_name-- 必须是应用了 Windowing TVF 或 Window Aggregation 的关系)WHERErownumN[ANDconditions];4. 示例一Window Top-N 跟在 Window Aggregation 后Top 3 供应商销售额4.1 业务目标每个 10 分钟滚动窗口计算销售额最高的 Top3 供应商supplier。4.2 SQL 写法SELECT*FROM(SELECT*,ROW_NUMBER()OVER(PARTITIONBYwindow_start,window_endORDERBYpriceDESC)ASrownumFROM(SELECTwindow_start,window_end,supplier_id,SUM(price)ASprice,COUNT(*)AScntFROMTABLE(TUMBLE(TABLEBid,DESCRIPTOR(bidtime),INTERVAL10MINUTES))GROUPBYwindow_start,window_end,supplier_id))WHERErownum3;5. 示例二Window Top-N 直接跟在 Windowing TVF 后Top 3 单条最高价记录5.1 业务目标每个 10 分钟窗口找出价格最高的 Top3 记录不先聚合。5.2 SQL 写法SELECT*FROM(SELECTbidtime,price,item,supplier_id,window_start,window_end,ROW_NUMBER()OVER(PARTITIONBYwindow_start,window_endORDERBYpriceDESC)ASrownumFROMTABLE(TUMBLE(TABLEBid,DESCRIPTOR(bidtime),INTERVAL10MINUTES)))WHERErownum3;6. 限制与注意事项6.1 Batch 模式下不支持 SESSION Window Top-N目前 SESSION Window Top-N 在 batch 模式还不支持。6.2 Windowing TVF 路径的支持范围当前只支持 Window Top-N 跟在 Windowing TVF 的TUMBLE / HOP / CUMULATE后Windowing TVF 的 Session Window 路径将来会支持。7. 工程化落库建议主键怎么设计7.1 保存“窗口榜单结果”时的主键组合如果你要把 Window Top-N 落到外部存储通常建议把窗口边界作为主键的一部分比如window_start window_end 分区键supplier_id / category如果需要保存榜单位置再加rownum7.2 不输出 rownum 的策略如果你不希望把rownum输出到下游减轻下游写压力可以外层 SELECT 不带 rownum让消费端自行排序展示但此时主键应回归业务实体如 supplier_id / item_id 窗口字段。8. 性能调优table.exec.rank.topn-cache-sizeWindow Top-N 底层依然依赖 Rank/TopN 的实现细节缓存参数table.exec.rank.topn-cache-size默认 10000在分区键基数很大时很关键。当你发现延迟、反压明显且分区数量巨大时可尝试调大如 200000并观测 GC 与吞吐变化。