flinksql基础知识

文章结构概览

• 表结构的转换
  • • • 将数据流转化为表格形式
      • 建立临时视图

  • 输出连接器

  • • • 导出至文件系统
      • 发送到Kafka
      • 写入ES
      • 存储到MySQL

  • 模式更新机制

  • • • 追加模式（append mode）
      • 撤销模式（retract mode）
      • 更新插入模式（Upsert mode）

  • 时间属性配置

  • • 处理时间设置

    • • 在数据流转换过程中直接设定
      • 在表结构定义中设定
      • 在DDL语句中设定

    • 事件时间配置

    • • 在数据流转换过程中直接设定
      • 在定义表结构时设定
      • 在创建DDL语句时设定

  • 窗口处理机制

  • • • 分组窗口（Group Windows）
    • Over窗口（Hive中的开窗函数）
    • 在SQL语句中定义窗口

  • 函数类型分类
    *
    常见的内置函数
    *
    用户自定义函数
    *
    标量函数（输入一个值，输出一个值）
    *
    表函数（输入一个值，输出多个值）