English | 中文
Make stream processing easier
一个神奇的框架，让流处理更简单
实时即未来, 在实时处理流域 Apache Spark 和 Apache Flink 是一个伟大的进步,尤其是 Apache Flink 被普遍认为是下一代大数据流计算引擎, 我们在使用 Flink & Spark 时发现从编程模型, 参数配置到项目部署, 运维管理都有很多可以抽象共用的地方,
我们将一些好的经验固化下来并结合业内的最佳实践, 通过不断努力终于诞生了今天的框架 —— StreamX, 项目的初衷是 —— 让流处理更简单, 使用 StreamX 开发, 可以极大降低学习成本和开发门槛, 让开发者只用关心最核心的业务, StreamX 规范了项目的配置,
鼓励函数式编程, 定义了最佳的编程方式, 提供了一系列开箱即用的 Connectors, 标准化了配置、开发、测试、部署、监控、运维的整个过程, 提供了 Scala/Java 两套 api, 其最终目的是打造一个一站式大数据平台, 流批一体,湖仓一体的解决方案
- Apache Flink & Spark 开发脚手架
- 提供了一系列开箱即用的connectors
- 支持项目编译功能(maven 编译)
- 多版本flink & Spark支持
- Scala 2.11 / 2.12 支持
- 一站式的流任务管理平台
- 支持不限于 catalog、olap、process-warehouse.
- ...
Streamx 由三部分组成，分别是 streamx-core，streamx-pump 和 streamx-console
streamx-core 定位是一个开发时框架，关注编码开发，规范了配置文件，按照约定优于配置的方式进行开发，提供了一个开发时 RunTime Content 和一系列开箱即用的 Connector
，简化繁琐的操作，聚焦业务本身，提高开发效率和开发体验
pump 是抽水机，水泵的意思，streamx-pump 的定位是一个数据抽取的组件，基于streamx-core 中提供的各种 connector
开发，目的是打造一个方便快捷，开箱即用的大数据实时数据抽取和迁移组件，并且集成到 streamx-console 中，解决实时数据源获取问题，目前在规划中
streamx-console 是一个综合实时数据平台，低代码(Low Code)平台，可以较好的管理Flink & Spark 任务，集成了项目编译、发布、参数配置、启动、savepoint，火焰图(flame graph)
， 监控等诸多功能于一体，大大简化了 Flink & Spark 任务的日常操作和维护，融合了诸多最佳实践。旧时王谢堂前燕，飞入寻常百姓家，让大公司有能力研发使用的项目，现在人人可以使用，
其最终目标是打造成一个实时数仓，流批一体的一站式大数据解决方案，该平台使用但不仅限以下技术:
- Apache Flink
- Apache Spark
- Apache YARN
- Spring Boot
- Mybatis
- Mybatis-Plus
- Flame Graph
- JVM-Profiler
- Vue
- VuePress
- Ant Design of Vue
- ANTD PRO VUE
- xterm.js
- Monaco Editor
- ...
请查看官网文档了解更多信息
诸多公司和组织将 StreamX 用于研究、生产和商业产品中, 如果您也在使用 ? 可以在这里添加
我们获得了一些珍贵的荣誉, 这份荣誉属于参加建设 StreamX 的每一位朋友, 谢谢大家!
如果你希望参与贡献 欢迎 Pull Request，或给我们 报告 Bug。
强烈推荐阅读 《提问的智慧》(本指南不提供此项目的实际支持服务！)、《如何有效地报告 Bug》、《如何向开源项目提交无法解答的问题》，更好的问题更容易获得帮助。
感谢所有向 StreamX 贡献的朋友!
Streamx 已正式开源，现已经进入高速发展模式，如果您觉得还不错请在右上角点一下 star，帮忙转发，谢谢 🙏🙏🙏 大家的支持是开源最大动力，
你可以扫下面的二维码加入官方微信群，更多相关信息请访问官网
