数据处理用于执行数据研发过程中的实时计算任务,同时管理数据研发过程中使用的任务、文件、元表、模板。

Dataphin支持创建Flink_SQLFLINK_TEMPLATE_SQLFLINK_DATASTREAM类型的实时计算任务,详细内容请参见新建Flink_SQL实时计算任务新建Flink_Template_SQL实时计算任务新建Flink_DataStream实时计算任务

实时计算任务的研发流程:
  1. 请参见新建资源,完成资源的创建。
  2. 请参见新建用户自定义函数,完成实时计算函数的创建。
  3. 请参见新建实时计算元表,完成实时计算元表的创建。
  4. (可选)请参见新建实时计算模板,完成实时计算模板的创建。
  5. 请参见新建Flink_SQL实时计算任务新建Flink_Template_SQL实时计算任务新建Flink_DataStream实时计算任务,完成实时计算任务的创建。
说明 实时计算模板仅支持被FLINK_TEMPLATE_SQL类型的实时计算任务引用。