DTStack/flinkStreamSQL
Fork: 928 Star: 2024 (更新于 2024-11-06 13:54:22)
license: Apache-2.0
Language: Java .
基于开源的flink，对其实时sql进行扩展；主要实现了流与维表的join，支持原生flink SQL所有的语法
最后发布版本： r1.8.7 ( 2020-07-15 15:57:09)
FlinkStreamSQL
技术交流
- 招聘Flink开发工程师，如果有兴趣，请联系思枢【微信号ysqwhiletrue】，注明招聘<BR> Flink开发工程师JD要求：<BR> 1.负责袋鼠云基于Flink的衍生框架数据同步flinkx和实时计算flinkstreamsql框架的开发；<BR> 2.调研和把握当前最新大数据实时计算技术，将其中的合适技术引入到平台中，改善产品，提升竞争力；<BR> 职位要求：<BR> 1、本科及以上学历，3年及以上的Flink开发经验，精通Java，熟悉Scala、Python优先考虑；<BR> 2、熟悉Flink原理，有基于Flink做过二次源码的开发，在github上贡献者Flink源码者优先；<BR> 3、有机器学习、数据挖掘相关经验者优先；<BR> 4、对新技术有快速学习和上手能力，对代码有一定的洁癖；<BR> 加分项：<BR> 1.在GitHub或其他平台上有过开源项目;<BR> 可以添加本人微信号ysqwhiletrue，注明招聘，如有意者发送简历至sishu@dtstack.com<BR>
- 我们使用钉钉沟通交流，可以搜索群号[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.
最近版本更新:(数据更新于 2024-09-24 17:24:45)
2020-07-15 15:57:09 r1.8.7
2020-06-23 19:11:25 r1.8.6
2020-05-21 14:04:57 r1.8.5
2020-04-17 14:30:54 r1.10.1
2020-04-07 16:24:32 r1.8.4
2020-03-17 11:22:13 1.8.4
2020-03-03 20:52:32 r1.8.3
2020-02-22 14:29:24 1.8.2
2020-01-20 18:04:18 1.8.1
2018-10-12 09:46:46 r1.5.0
主题(topics):
bigdata, flink, sql, stream
DTStack/flinkStreamSQL同语言 Java最近更新仓库
2024-11-22 14:41:49 dromara/dante-cloud
2024-11-22 01:55:02 spring-projects/spring-boot
2024-11-21 09:44:43 Card-Forge/forge
2024-11-20 14:38:43 StarRocks/starrocks
2024-11-19 23:42:52 spring-projects/spring-authorization-server
2024-11-18 21:40:12 4379711/lol-helper