flinkStreamSQL

基于开源的flink,对其实时sql进行扩展;主要实现了流与维表的join,支持原生flink SQL所有的语法

  • 所有者: DTStack/flinkStreamSQL
  • 平台: Cygwin, Linux, Mac, Unix-like, Docker, Kubernetes, Mesos
  • 許可證: Apache License 2.0
  • 分類:
  • 主題:
  • 喜歡:
    0
      比較:

Github星跟蹤圖

FlinkStreamSQL

License

技术交流

  • 招聘大数据平台开发工程师,想了解岗位详细信息可以添加本人微信号ysqwhiletrue,注明招聘,如有意者发送简历至sishu@dtstack.com
  • 我们使用钉钉沟通交流,可以搜索群号[30537511]或者扫描下面的二维码进入钉钉群

介绍

  • 基于开源的flink,对其实时sql进行扩展
    • 自定义create table 语法(包括源表,输出表,维表)
    • 自定义create view 语法
    • 自定义create function 语法
    • 实现了流与维表的join
    • 支持原生FlinkSQL所有的语法
    • 扩展了输入和输出的性能指标到Task metrics

目录

1.1 demo
1.2 快速开始
1.3 参数配置
1.4 支持的插件介绍和demo
1.5 指标参数
1.6 自定义函数
1.7 自定义视图

如何贡献FlinkStreamSQL

License

FlinkStreamSQL is under the Apache 2.0 license. See the LICENSE file for details.

概覽

名稱與所有者DTStack/flinkStreamSQL
主編程語言Java
編程語言Java (語言數: 3)
平台Cygwin, Linux, Mac, Unix-like, Docker, Kubernetes, Mesos
許可證Apache License 2.0
發布數12
最新版本名稱v1.10.1 (發布於 2021-03-02 19:14:40)
第一版名稱r1.4.0 (發布於 )
創建於2018-09-12 05:51:37
推送於2024-02-21 00:11:04
最后一次提交2019-11-12 09:28:52
星數2k
關注者數117
派生數0.9k
提交數2.5k
已啟用問題?
問題數322
打開的問題數59
拉請求數61
打開的拉請求數28
關閉的拉請求數54
已啟用Wiki?
已存檔?
是復刻?
已鎖定?
是鏡像?
是私有?
去到頂部