本章节为您介绍与算子相关的基本概念。

算子

任务由多个算子构成,各算子通过逻辑表串联,算子类型包含数据导入算子、数据加工算子、数据目标算子三种。

说明 使用算子与逻辑表时请注意以下几点:
  • 数据导入算子、目标算子只能有一个。
  • 流计算任务加工算子可以是多个,索引迁移任务不支持数据加工处理。
  • 产出的所有逻辑表都必须使用到。

数据导入算子

配置拉取数据的数据源,产出是逻辑表,详情请参见数据导入算子

数据加工算子(非必须)

对逻辑表进行加工处理,例如对逻辑表进行数据过滤、对逻辑表中的某些字段通过加工函数进行转换,产出是逻辑表,详情请参见数据加工算子

数据目标算子

设置导入到目标Elasticsearch实例中的逻辑表,详情请参见数据目标算子

逻辑表

逻辑表由字段构成,是一个虚拟的概念,类似数据库视图。