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

Flink流水线任务在线演示

Flink流水线在线演示

1. 登录系统

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


2. 创建任务

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

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

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


3. 配置任务

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

  2. 添加数据生成节点

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

    • Schema配置

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

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

        在这里插入图片描述

  3. 添加数据展示节点

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

在这里插入图片描述


4. 运行任务

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

flink流水线运行


🔗 平台体验地址:DataStudio

相关文章:

  • 《类和对象(上)》
  • 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 创建自定义打包的技术指南
  • 抗战回望18︱《广西学生军》:“广西的政治基础是青年”
  • 巴基斯坦宣布禁止印度船只入港
  • 新加坡国会选举投票抽样结果公布,执政党已获超半数议席
  • 跳水世界杯女子单人10米台决赛,陈芋汐、全红婵包揽金银牌
  • 马上评|提供情绪价值,也是文旅经济的软实力
  • 乘客被困停滞车厢超4小时,哈尔滨铁路局客服:列车晚点,表示歉意