RuleGo RuleGo
🏠首页
  • 快速入门
  • 规则链
  • 标准组件
  • 扩展组件
  • 自定义组件
  • 可视化
  • RuleGo-Server
  • RuleGo-MCP-Server
  • AOP
  • 触发器
  • 高级主题
  • 性能
  • 标准组件
  • 扩展组件
  • 自定义组件
  • 流式计算
  • 组件市场
  • 概述
  • 快速入门
  • 路由
  • DSL
  • API
  • Options
  • 组件
🔥编辑器 (opens new window)
  • 可视化编辑器 (opens new window)
  • RuleGo-Server (opens new window)
  • 🌊StreamSQL
  • ❓问答

    • FAQ
💖支持
👥加入社区
  • Github (opens new window)
  • Gitee (opens new window)
  • GitCode (opens new window)
  • 更新日志 (opens new window)
  • English
  • 简体中文
🏠首页
  • 快速入门
  • 规则链
  • 标准组件
  • 扩展组件
  • 自定义组件
  • 可视化
  • RuleGo-Server
  • RuleGo-MCP-Server
  • AOP
  • 触发器
  • 高级主题
  • 性能
  • 标准组件
  • 扩展组件
  • 自定义组件
  • 流式计算
  • 组件市场
  • 概述
  • 快速入门
  • 路由
  • DSL
  • API
  • Options
  • 组件
🔥编辑器 (opens new window)
  • 可视化编辑器 (opens new window)
  • RuleGo-Server (opens new window)
  • 🌊StreamSQL
  • ❓问答

    • FAQ
💖支持
👥加入社区
  • Github (opens new window)
  • Gitee (opens new window)
  • GitCode (opens new window)
  • 更新日志 (opens new window)
  • English
  • 简体中文

广告采用随机轮播方式显示 ❤️成为赞助商
  • 概述
  • 快速开始
  • 核心概念
  • SQL参考
  • API参考
  • RuleGo集成
  • 函数

    • 聚合函数
    • 分析函数
    • 窗口函数
      • WINDOW_START - 窗口开始时间
      • WINDOW_END - 窗口结束时间
      • 扩展窗口函数
        • ROW_NUMBER - 行号函数
        • FIRST_VALUE - 首值函数
        • LEAD - 前导函数
        • NTH_VALUE - 第N个值函数
      • 📚 相关文档
    • 数学函数
    • 字符串函数
    • 类型转换函数
    • 时间日期函数
    • JSON函数
    • 哈希函数
    • 数组函数
    • 类型检查函数
    • 条件函数
    • 多行函数
    • 表达式函数
    • 自定义函数
  • 案例集锦

目录

窗口函数

# StreamSQL 窗口函数

窗口函数提供窗口相关的信息。

# WINDOW_START - 窗口开始时间

语法: window_start()
描述: 返回当前窗口的开始时间。
增量计算: ✅ 支持
示例:

SELECT device, window_start() as window_begin, avg(temperature) as avg_temp 
FROM stream 
GROUP BY device, TumblingWindow('10s')
1
2
3

# WINDOW_END - 窗口结束时间

语法: window_end()
描述: 返回当前窗口的结束时间。
增量计算: ✅ 支持
示例:

SELECT device, window_end() as window_finish, avg(temperature) as avg_temp 
FROM stream 
GROUP BY device, TumblingWindow('10s')
1
2
3

# 扩展窗口函数

扩展窗口函数提供更多窗口相关功能。

# ROW_NUMBER - 行号函数

语法: row_number() OVER (ORDER BY col)
描述: 为结果集中的每一行分配一个唯一的行号。
增量计算: ✅ 支持

# FIRST_VALUE - 首值函数

语法: first_value(col) OVER (ORDER BY col)
描述: 返回窗口中第一行的值。
增量计算: ✅ 支持

# LEAD - 前导函数

语法: lead(col, offset, default_value) OVER (ORDER BY col)
描述: 返回当前行之后第N行的值。
增量计算: ✅ 支持

# NTH_VALUE - 第N个值函数

语法: nth_value(col, n) OVER (ORDER BY col)
描述: 返回窗口中第N行的值。
增量计算: ✅ 支持

# 📚 相关文档

  • 聚合函数 - 了解聚合函数的详细用法
  • 分析函数 - 了解分析函数的详细用法
  • SQL参考 - 查看完整的SQL语法参考
在 GitHub 上编辑此页 (opens new window)
上次更新: 2025/07/27, 15:17:27
分析函数
数学函数

← 分析函数 数学函数→

Theme by Vdoing | Copyright © 2023-2025 RuleGo Team | Apache 2.0 License

  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式