MCPcopy Index your code
hub / github.com/DataLinkDC/dinky

github.com/DataLinkDC/dinky @v1.2.5

Chat with this repo
repository ↗ · DeepWiki ↗ · release v1.2.5 ↗ · + Follow
11,144 symbols 37,084 edges 1,864 files 2,588 documented · 23%
What it actually does AI analysis from the code graph — generated when you open this
loading…
README

Dinky

License Stars Downloads CN doc EN doc

Stargazers over time

简介

以 Apache Flink 为内核构建的开源实时计算平台,具备实时应用的作业开发、数据调试及运行监控能力,助力实时计算高效应用。

功能

其主要功能如下:

  • FlinkSQL 数据开发:提示补全、语句美化、在线调试、逻辑校验、执行计划、Catalog、血缘分析、版本对比等
  • 支持 FlinkSQL 多版本开发及多种执行模式:Local、Standalone、Yarn/Kubernetes Session、Yarn Per-Job、Yarn/Kubernetes Application
  • 支持 Apache Flink 生态:FlinkCDC、Connector、FlinkCEP、Paimon、PyFlink 等
  • 支持 FlinkSQL 语法增强:整库同步、执行环境、全局变量、表值聚合、加载依赖、行级权限、执行Jar任务等
  • 支持 FlinkCDC 整库实时入仓入湖与 FlinkCDCPipeline 整库同步
  • 支持实时在线调试预览 Table、ChangeLog 和 UDF
  • 支持 Flink Catalog、数据源元数据在线查询及管理
  • 支持实时任务运维:上线下线、作业信息、作业日志、版本信息、作业快照、监控、SQL 血缘、告警记录等
  • 支持实时作业报警及报警组:钉钉、企业微信、飞书、邮箱、短信、http 等
  • 支持自动托管的 SavePoint/CheckPoint 恢复及触发机制:最近一次、最早一次、指定一次等
  • 支持多种资源管理:集群实例、集群配置、数据源、告警、文档、全局变量、Git 项目、UDF、资源、系统配置等
  • 支持企业级管理:多租户、用户、角色、菜单、令牌
  • 更多隐藏功能等待小伙伴们探索

原理

dinky_principle

运行效果

数据开发

datastudio

数据调试

datadebug

作业监控

devops

作业指标

metrics

参与贡献

PRs Welcome

欢迎加入社区,共建共赢,贡献流程请参考: 参与贡献

感谢所有已经为 Dinky 做出贡献的人!

contrib graph

如何部署

详见 源码编译安装部署

感谢

站在巨人的肩膀上,Dinky 才得以诞生。对此我们对使用的所有开源软件及其社区表示衷心的感谢!我们也希望自己不仅是开源的受益者,也能成为开源的贡献者,也希望对开源有同样热情和信念的伙伴加入进来,一起为开源献出一份力!

部分致谢列表如下:

Apache Flink

Apache FlinkCDC

Apache Paimon

Apache Dolphinscheduler

Apache Doris

Druid

Ant-Design-Pro

Mybatis Plus

Monaco Editor

Sa Token

SpringBoot

感谢 JetBrains 提供的免费开源 License 赞助。

JetBrains

获得帮助

1.创建 issue,并描述清晰

2.访问 官网 网址,阅读最新文档手册

3.进入微信用户社区群(推荐,添加微信号 wenmo_ai 邀请进群)和 QQ 用户社区群(543709668)交流,必须申请备注 “Dinky + 企业名 + 职位”,

4.关注微信公众号获取官方最新文章:Dinky 开源

版权

请参考 LICENSE 文件。

Extension points exported contracts — how you extend this code

CatalogueTreeSortStrategy (Interface)
CatalogueTreeSortStrategy @since 2024/4/29 14:10 [7 implementers]
dinky-admin/src/main/java/org/dinky/service/catalogue/strategy/CatalogueTreeSortStrategy.java
IResult (Interface)
IResult @since 2021/5/25 16:22 [6 implementers]
dinky-common/src/main/java/org/dinky/data/result/IResult.java
CustomTableEnvironment (Interface)
CustomTableEnvironment @since 2022/2/5 10:35 [7 implementers]
dinky-client/dinky-client-base/src/main/java/org/dinky/executor/CustomTableEnvironment.java
ResultBuilder (Interface)
ResultBuilder @since 2021/5/25 15:59 [5 implementers]
dinky-core/src/main/java/org/dinky/data/result/ResultBuilder.java
Parser (Interface)
Provides methods for parsing SQL objects from a SQL string. [5 implementers]
dinky-client/dinky-client-1.15/src/main/java/org/apache/flink/table/delegation/Parser.java
Parser (Interface)
Provides methods for parsing SQL objects from a SQL string. [5 implementers]
dinky-client/dinky-client-1.14/src/main/java/org/apache/flink/table/delegation/Parser.java
FunctionCompiler (Interface)
@since 0.6.8 [3 implementers]
dinky-function/src/main/java/org/dinky/function/compiler/FunctionCompiler.java
Driver (Interface)
Driver @since 2021/7/19 23:15 [3 implementers]
dinky-metadata/dinky-metadata-base/src/main/java/org/dinky/metadata/driver/Driver.java

Core symbols most depended-on inside this repo

l
called by 1972
dinky-web/src/utils/intl.tsx
get
called by 1192
dinky-gateway/src/main/java/org/dinky/gateway/Gateway.java
getName
called by 1024
dinky-metadata/dinky-metadata-base/src/main/java/org/dinky/metadata/driver/Driver.java
put
called by 857
dinky-core/src/main/java/org/dinky/data/result/ResultPool.java
add
called by 742
dinky-function/src/main/java/org/dinky/function/util/ZipWriter.java
format
called by 609
e2e_test/tools/logger.py
key
called by 479
dinky-common/src/main/java/org/dinky/data/model/Configuration.java
append
called by 447
dinky-admin/src/main/java/org/dinky/sse/LogSseAppender.java

Shape

Method 8,121
Function 1,407
Class 1,281
Interface 234
Enum 101

Languages

Java86%
TypeScript14%
Python1%

Modules by API surface

dinky-client/dinky-client-1.20/src/main/java/org/apache/flink/table/factories/FactoryUtil.java77 symbols
dinky-client/dinky-client-1.19/src/main/java/org/apache/flink/table/factories/FactoryUtil.java77 symbols
dinky-client/dinky-client-1.18/src/main/java/org/apache/flink/table/factories/FactoryUtil.java77 symbols
dinky-client/dinky-client-1.20/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java68 symbols
dinky-client/dinky-client-1.19/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java68 symbols
dinky-client/dinky-client-1.17/src/main/java/org/apache/flink/table/factories/FactoryUtil.java67 symbols
dinky-client/dinky-client-1.16/src/main/java/org/apache/flink/table/factories/FactoryUtil.java67 symbols
dinky-client/dinky-client-1.15/src/main/java/org/apache/flink/table/factories/FactoryUtil.java67 symbols
dinky-client/dinky-client-1.18/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java63 symbols
dinky-client/dinky-client-1.17/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java62 symbols
dinky-client/dinky-client-1.16/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java62 symbols
dinky-client/dinky-client-1.15/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java60 symbols

Datastores touched

(mysql)Database · 1 repos
dlinkDatabase · 1 repos
dinky_logicDatabase · 1 repos
dataDatabase · 1 repos
dinkyDatabase · 1 repos
dbDatabase · 1 repos
mydatabaseDatabase · 1 repos
dimDatabase · 1 repos

For agents

$ claude mcp add dinky \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact