commit | ca24bce1c2ccf5e2f354ef5eeb4fc7d156a0a061 | [log] [tgz] |
---|---|---|
author | benjobs <benjobs@apache.org> | Tue Nov 22 00:48:47 2022 +0800 |
committer | benjobs <benjobs@apache.org> | Tue Nov 22 00:48:47 2022 +0800 |
tree | 5fded98227f90c78afd340bece045d5250227488 | |
parent | 35d203c208d5843347ebef343c90c7dc4a60ec6f [diff] | |
parent | e85a3c1205e78c2f1121faad5ef9c8562e985a06 [diff] |
Merge remote-tracking branch 'origin/jobName-fixed' into jobName-fixed
Apache StreamPark 开发Flink
的上手示例程序,分为四个模块:
quickstart-apacheflink
quickstart-datastream
quickstart-flinksql
quickstart-connector
quickstart-apacheflink 是Flink官方的SocketWindowWordCount
程序, 其中项目结构,打包规则,开发方式等和Flink官网要求的规范完全一致, 之所以有这个模块,是因为在streampark-console
中做了对标准的Flink程序
(按照官方要求的开发规范开发的Flink程序)的部署支持,后续方便演示使用.
该模块主要演示了如果利用Apache StreamPark
快速开发一个DataStream
程序,其中有java
和scala
两种语言的开发示例,供开发者快速上手学习使用
该模块主要演示了如果利用Apache StreamPark
快速开发一个Flink & SQL
程序,其中有java
和scala
两种语言的开发示例,供开发者快速上手学习使用
该模块演示了如何使用Apache StreamPark
里提供的各种 Datastream connector
, 里面集合了各种 Datastream connector
的配置和使用示例, 供开发者快速上手学习使用