400-811-8890
核心功能1
设计即可执行，上手简单
产品内采用统一拖拉拽的画布式开发模式，设计即可执行，无额外的学习成本，简单易用
跨模块使用无割裂感，流批一体统一的开发体验
定时数据开发
实时数据开发
核心功能2
执行记录和性能监控让开发调试更直接
组件级、单元级的运维能力，运行日志、耗时、错误原因一目了然，
方便开发过程中进行测试判断是否达到流程、性能预期
方便开发过程中进行测试判断是否达到流程、性能预期
单元级-实时性能监控
- 执行单元对应的每秒输出的数据量
- 性能衡量可以细化到单元级别
组件级-实时性能监控
- 心跳检测
- 运行状态通知
- 日志读取时间
- 背压状态监测
灵活的任务控制策略，通过容错机制、任务优先级等设置，让任务管控更细致可靠
容错机制
- 脏数据容忍
- 超时中断
- 任务失败后自动重跑
结果通知
- 多终端预警通知，保障异常及时解决：短信通知、平台消息、邮件提醒、客户端提醒
- 可选择通知内容和用户
任务属性
- 设定优先级，重要业务重点保障
- 有依赖关系的任务自动继承父任务优先级
任务从开发模式发布到生产模式，可以避免开发操作中断业务，保证环境的稳定性
任务发布
任务从开发模式发布到生产模式，可以避免开发操作中断业务，保证环境的稳定性
- 开发模式和生产模式代码的隔离，可分别进行手动运行
- 发布后的任务，即可进行调度配置
任务版本管理，便于问题排查与回溯，提高团队配合的效率
版本管理
任务版本管理，便于问题排查与回溯，提高团队配合的效率
- 版本比对，包含节点信息、任务参数、任务控制等
- 版本回滚，可回滚到指定版本
核心功能3
报错日志、血缘，帮助快速定位问题、确认影响并修复
报错日志，方便用户在开发过程过程中定位问题原因；
血缘方便对影响范围进行快速确认，以便得到快速修正
智能化日志提醒
- 日志智能化展示，提供运行总览和执行时间、统计、
- 问题部分用颜色区分，日志问题描述提示优化，简单直接指出问题，方便进行问题定位
表级、任务级、组件级血缘
- 清晰展示组件间的任务血缘、可以根据对应的表、组件，跳转到详情，
- 进一步寻找根因，排错更加迅速
核心功能4
满足复杂不同数据处理场景
- 离线开发区分步骤流和数据流，让开发过程更清晰。
- 步骤流，像梳理脑图一样设计执行路径
- 循环容器，应对更多数据的循环遍历转换场景
- Spark SQL/Python/Shell等脚本类，支持更多灵活转换场景
- 数据流提供多种数据转换算子，满足复杂处理场景
- 半结构化数据处理，一键转化成其他格式或进行文件传输
- 消息通知，满足任务预警和数据预警需求
- 开发过程管理的三种方式，满足多样化调度需求
- 定时调度，支持执行一次、简单重复执行、明细频率设置、表达式设置
- 事件调度，提高多业务域、多任务数据开发的组织协调性
- 触发式调度，通过接口触发的方式供给外部系统进行任务调度
基础连接能力
CDC、MQTT、kafka、websocket等
进阶-转换算子
实时汇总、聚合计算
进阶-拓展算子
Flink 引擎、Flink SQL