Flink流计算可视化平台

github 地址 https://github.com/zhp8341/flink-streaming-platform-web (建议)

国内 gitee 地址 https://gitee.com/zhuhuipei/flink-streaming-platform-web

一、简介
flink-streaming-platform-web 系统是基于Apache Flink 封装的一个可视化的、轻量级的 flink web 客户端系统，用户只需在 web 界面进行 sql 配置就能完成流计算任务。

主要功能:包含任务配置、启/停任务、告警、日志等功能，支持 sql 语法提示，格式化、sql 语句校验。

目的:减少开发、降低成本完全实现 sql 化流计算任务。

1、主要功能
[1] 任务支持单流、双流、单流与维表等。

[2] 支持本地模式、yarn-per 模式、STANDALONE 模式。

[3] 支持 catalog、hive。

[4] 支持自定义 udf、连接器等,完全兼容官方连接器。

[5] 支持 sql 的在线开发，语法提示，格式化。

[6] 支持钉钉告警、自定义回调告警、自动拉起任务。

[7] 支持自定义 Jar 提交任务。

[8] 支持多版本 flink 版本（需要用户编译对应 flink 版本）。

[9] 支持自动、手动 savepoint 备份，并且从 savepoint 恢复任务。

目前 flink 版本已经升级到 1.12

如果您觉得还不错请在右上角点一下 star 谢谢

Flink流计算可视化平台相关推荐

基于 Flink 流计算实现的股票交易实时资产应用
01 背景本次赛题思路源自于真实工作场景的一个线上项目,该项目在经过一系列优化后已稳定上线,在该项目开发的过程中数据平台组和技术负责人提供了许多资源和指导意见,而项目的结果也让我意识到了流计算在实际 ...
Flink流计算WordCount代码示例
代码 package com.zxl.flinkimport org.apache.flink.streaming.api.scala.StreamExecutionEnvironment/*** f ...
Flink SQL 流计算可视化 UI 平台
点击上方 "zhisheng"关注, 星标或置顶一起成长 Flink 从入门到精通系列文章一.简介 flink-streaming-platform-web系统是基于flink ...
Flink流计算编程--在WindowedStream中体会EventTime与ProcessingTime
一.Flink流处理简介 Flink流处理的API叫做DataStream,可以在保证Exactly-Once的前提下提供高吞吐.低延时的实时流处理. 二.Flink中的Time模型 Flink中提供 ...
Flink流计算引擎
伴随着海量增长的数据,数字化时代的未来感扑面而至.不论是结绳记事的小数据时代,还是我们正在经历的大数据时代,计算的边界正在被无限拓宽,而数据的价值再也难以被计算.时下,谈及大数据,不得不提到热门的下一 ...
7、Flink 流计算处理和批处理平台
一.Flink 基本概念 Flink 是一个批处理和流处理结合的统一计算框架,其核心是一个提供了数据分发以及并行化计算的流数据处理引擎.它的最大亮点是流处理,是业界最顶级的开源流处理引擎.Flink ...
【Flink】Flink 流计算容错 source节点进行数据容错
1.概述本博客是视频的笔记:Apache Flink 知其然,知其所以然(原理&实战) 就是当流任务失败的时候,如何让flink从数据源上次消费的位置开始消费. 2.案例 2.1 没有che ...
Flink流计算处理-旁路输出
使用Flink做流数据处理时,除了主流数据输出,还自定义侧流输出即旁路输出,以实现灵活的数据拆分. 定义旁路输出标签首先需要定义一个OutputTag,代码如下: // 这需要是一个匿名的内部类,以 ...
flink流计算随笔（6）
生成,编译模板工程 MacBook-Air:SocketWindowWordCount myhaspl$ bash <(curl https://flink.apache.org/q/sbt- ...

Flink流计算可视化平台

Flink流计算可视化平台相关推荐

最新文章

热门文章