close
The Wayback Machine - https://web.archive.org/web/20200905075824/https://github.com/binglind/alchemy
Skip to content
master
Go to file
Code

Latest commit

 

Git stats

Files

Permalink
Failed to load latest commit information.
Type
Name
Latest commit message
Commit time
 
 
 
 
 
 
 
 
 
 
 
 
 
 

README.md

License

Alchemy:

alchemy是以Jhipster为脚手架开发的web系统,能够在界面上开发基于flink的sql任务,也支持拉取jar包上传任务。

大家如果觉得有帮助的话,请帮忙点个star

环境

  • Java 8
  • Maven3.x
  • Flink 1.8.0 (table和hadoop依赖放入lib目录下)
  • node.js (可选,开发前端需要)

快速运行

  mvn clean package -DskipTests -Pdev,npm
  java -jar alchemy-web/target/alchemy-web-1.0.0-SNAPSHOT.jar
  访问 http://localhost:8080
  登录用户admin  密码admin

User Guide

支持

yaml配置

所有的yaml配置建议以"-"作为分隔符

flink集群模式
  • standalone
  • openshift : 可以在openshift上自动创建和管理集群
源表
维表
视图
用户函数
  • 页面编写用户函数
  • jar包加载用户函数
写入端
钉钉机器人告警

resource的config目录下,修改dingtalk的webhook

Image

生产环境

必须要做以下事情:

  • dev默认是h2数据库,所以必须修改数据库配置
  • 代码deploy到自己的maven私服
  • 配置私服地址 Image

开发

贡献

欢迎大家提交自己的代码

近期计划

  • 维表支持redis、hbase等
  • 支持yarn模式
  • 动态拉取schema字段
  • ......

About

给flink开发的web系统。支持页面上定义udf,进行sql和jar任务的提交;支持source、sink、job的管理;可以管理openshift上的flink集群

Topics

Resources

License

Releases

No releases published

Packages

No packages published
You can’t perform that action at this time.