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

Flink流水线任务在线演示

Flink流水线在线演示

1. 登录系统

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


2. 创建任务

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

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

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


3. 配置任务

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

  2. 添加数据生成节点

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

    • Schema配置

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

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

        在这里插入图片描述

  3. 添加数据展示节点

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

在这里插入图片描述


4. 运行任务

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

flink流水线运行


🔗 平台体验地址:DataStudio

http://www.xdnf.cn/news/3959.html

相关文章:

  • C++类和对象之默认成员函数
  • 基于 Spark 和 Hadoop 的空气质量数据分析与预测系统
  • 【AI提示词】AARRR 模型执行者
  • Google-chrome版本升级后sogou输入法不工作了
  • Cisco NDO - Nexus Dashboard Orchestrator
  • 202533 | SpringBoot集成RocketMQ
  • 2025 年 408 真题及答案
  • 深入探索Anthropic Claude与Spring AI的融合应用
  • 虚幻引擎5-Unreal Engine笔记之显卡环境设置使开发流畅
  • 【LaTeX+VSCode本地Win11编译教程】
  • Debezium TableSchemaBuilder详解
  • (一)Modular Monolith Architecture(项目结构/.net项目初始化/垂直切片架构)
  • 洛谷 P1440 求m区间内的最小值
  • 8.5/Q1,Charls高分经典文章解读
  • 【Web3】上市公司利用RWA模式融资和促进业务发展案例
  • Spring Boot多模块划分设计
  • C++访问MySQL
  • 《Python星球日记》第31天:Django 框架入门
  • opencv+opencv_contrib+cuda和VS2022编译
  • 202531 | RocketMQ 消息过滤 + 消息重试机制 + 死信消息 + 重复消费问题
  • zotero pdf中英翻译插件使用
  • epub格式转txt格式工具,txt批量转PDF
  • 设计模式(结构型)-组合模式
  • 【Java ee初阶】多线程(6)
  • item_get_app_pro - 获得淘宝app商品详情原数据操作流程
  • 使用 vllm 部署 Llama3-8b-Instruct
  • 【C++】grpc(一):安装
  • 【Python】Python好玩的第三方库之二维码生成,操作xlsx文件,以及音频控制器
  • 从零开始学Flink:开启实时计算的魔法之旅
  • CSS知识总结