当前位置:网站首页>Flink weapon: introduction to the open source platform streamx
Flink weapon: introduction to the open source platform streamx
2022-06-24 01:28:00 【Wuyuntao】
StreamX brief introduction
StreamX yes Flink & Spark Rapid development of scaffolding , Open source stream batch one-stop big data platform .
StreamX Support Flink Many versions , Support Flink SQL WebIDE, Support Flink SQL check . since 2021 year 3 Open source since January , Provides a range of out of the box Conncetor, Standardized configuration 、 Development 、 test 、 Deploy 、 monitor 、 The whole process of operation and maintenance , Provide scala and java Two sets api, Its ultimate goal is to build a one-stop big data platform , Stream batch integration , Lake warehouse integrated solution .
It can be understood as an open source version 、 Simplified alicloud real-time computing Flink Version or Tencent cloud Flow calculation Oceanus platform .
The architecture is as follows :
StreamX features :
- Development scaffold
- Many versions Flink Support (1.11,x, 1.12.x, 1.13 )
- A series of out of the box connectors
- Support project compilation function (maven compile )
- Online parameter configuration
- Support
ApplicaionPattern ,Yarn-Per-Jobmode - Quick daily operation ( Mission
start-up、stop it、savepoint, fromsavepointrecovery ) - Support flame chart
- Support
notebook( Online task development ) - Project configuration and dependency versioning management
- Support task backup 、 Roll back ( Configure rollback )
- Online management depends on (maven pom) And customization jar
- Customize udf、 Connectors, etc
- Flink SQL WebIDE
- Support catalog、hive
- If the task fails to run, send an alarm message
- Support failed restart retry
- From task
DevelopmentStage toDeployment managementFull link support - ...
Reference reading :
[1] Streamx Github: https://github.com/streamxhub/streamx
[2] StreamX Official website :http://www.streamxhub.com/
[3] StreamX documentation : http://www.streamxhub.com/zh/doc/guide/intro/
[4] Baili International StreamX Practice on :https://mp.weixin.qq.com/s/0WvUiMgzRXRWiaRkiIz7qA
边栏推荐
- Map data types in golang
- CODING CD
- An accident caused by a MySQL misoperation, and the "high availability" cannot withstand it!
- 对抗训练理论分析:自适应步长快速对抗训练
- Gin framework: automatically add requestid
- [new secsha!] Have you got the 22 year new seckill activity of Tencent cloud?
- Feasibility of importing UE4 using gltf with instances
- Teach you to set up a gift card voucher exchange platform
- 跨域和JSONP
- CSDN auto sign in
猜你喜欢

对抗训练理论分析:自适应步长快速对抗训练

Error reported using worker: uncaught domexception: failed to construct 'worker': script at***

GNN upper edge distributor! Instead of trying to refine pills, you might as well give your GNN some tricks
Shengdun technology joined dragon lizard community to build a new open source ecosystem
![[flutter] comment utiliser les paquets et plug - ins flutter](/img/a6/e494dcdb2d3830b6d6c24d0ee05af2.png)
[flutter] comment utiliser les paquets et plug - ins flutter

用一个软件纪念自己故去的母亲,这或许才是程序员最大的浪漫吧

JS input / output statements, variables

Arm learning (7) symbol table and debugging

【Redis进阶之ZipList】如果再有人问你什么是压缩列表?请把这篇文章直接甩给他。

LSF opens job idle information to view the CPU time/elapse time usage of the job
随机推荐
Part of the problem solution of unctf2020
【Flutter】如何使用Flutter包和插件
How to use IOT gateway to realize networking communication of smart road lamp posts
[flutter] comment utiliser les paquets et plug - ins flutter
LSF opens job idle information to view the CPU time/elapse time usage of the job
LMS Virtual. Derivation method of lab acoustic simulation results
Network security meets new regulations again, UK and US warn apt hacker attacks November 18 global network security hotspots
[solution] how to realize AI automatic recognition of high altitude parabolic behavior?
Arm learning (7) symbol table and debugging
How to realize IP invariance in the private network of basic network ECs and cloud database resource switching
Video stream playback address redirection optimization after easycvr replaces the new kernel
Error reported using worker: uncaught domexception: failed to construct 'worker': script at***
What is hypervisor? What is the difference between type 1 and type 2?
Forward design of business application data technology architecture
Longest substring without duplicate characters
[technical grass planting] use webhook to automatically deploy my blogs on multiple sites in Tencent cloud
Output type SPED trigger inbound delivery after PGI for inter-company STO's outb
ctfhub---SSRF
CDN access log quality performance monitoring and operation statistical analysis best practices
用一个软件纪念自己故去的母亲,这或许才是程序员最大的浪漫吧