当前位置: 首页 > news >正文

Flink流水线任务在线演示

Flink流水线在线演示

1. 登录系统

访问系统登录页面,输入账号密码完成身份验证。
在这里插入图片描述


2. 创建任务

  • 入口:通过顶部菜单栏选择 任务开发,或通过快捷入口 快速创建任务

  • 任务类型:选择 FlinkPipeline
    在这里插入图片描述

    在这里插入图片描述
    在这里插入图片描述


3. 配置任务

  1. 进入配置界面
    点击任务名称,进入任务详情页。
    在这里插入图片描述

  2. 添加数据生成节点

    • 拖入 DataGen 节点(模拟数据生成)。

    • Schema配置

      • 支持通过AI生成数据表结构(需人工校验并微调字段类型或格式)。

      • 示例调整:修正时间戳格式、字段长度等。
        在这里插入图片描述
        在这里插入图片描述

        在这里插入图片描述

  3. 添加数据展示节点

    • 拖入 ShowData 节点,并将其与 DataGen 节点连接,用于实时查看生成的数据。
      在这里插入图片描述
  4. 保存任务
    完成配置后,点击 保存 按钮。

在这里插入图片描述


4. 运行任务

  • 点击 运行 按钮启动任务。
  • 通过 ShowData 节点可实时监控数据流。

flink流水线运行


🔗 平台体验地址:DataStudio

http://www.dtcms.com/a/172632.html

相关文章:

  • 《类和对象(上)》
  • Python 整理3种查看神经网络结构的方法
  • 虚幻引擎作者采访
  • 什么是原码、反码与补码?
  • 2025流感疫苗指南+卫健委诊疗方案|高危人群防护+并发症处理 慢性肾脏病饮食指南2025卫健委版|低盐低磷食谱+中医调理+PDF 网盘下载 pdf下载
  • 牛客1018逆序数-归并排序
  • 金融的本质是智融、融资的实质是融智、投资的关键是投智,颠覆传统金融学的物质资本中心论,构建了以智力资本为核心的新范式
  • PyTorch 张量与自动微分操作
  • 全球化电商平台Azure云架构设计
  • 期末代码Python
  • iptables的基本选项及概念
  • 串 Part 1
  • 数据链路层(MAC 地址)
  • Gemini 解释蓝图节点的提示词
  • STC单片机与淘晶驰串口屏通讯例程之04【密码登录与修改】
  • 有哪些场景不适合使用Java反射机制
  • 基于C++实现的深度学习(cnn/svm)分类器Demo
  • H3C无线控制器自动信道功率调整典型配置实验
  • 数据结构小扫尾——栈
  • JAVA:使用 Maven Assembly 创建自定义打包的技术指南
  • Kubernetes(k8s)学习笔记(七)--KubeSphere 最小化安装
  • 音频感知动画新纪元:Sonic让你的作品更生动
  • 矩阵置零(中等)
  • 五一假期集训【补题】
  • 研0大模型学习(第12天)
  • 【C++】智能指针RALL实现shared_ptr
  • android-ndk开发(1): 搭建环境
  • 基于SpringBoot的漫画网站设计与实现
  • flink rocksdb状态说明
  • 组合两个表 --- MySQL [Leetcode 题目详解]