自定义算子 ​

DataSpring 为你提供自定义算子的功能，使你能够在转换器的公式中使用自定义算子，在数据处理时更加随心所欲，不必受限于系统的内置函数，大大扩展了公式的表达能力。

系统支持两种类型的自定义算子：

• Python Flink UDF
• 表达式算子

Python Flink UDF ​

要求你有一定的代码编写能力。数据类型请参照：

Python Flink UDF 数据类型及映射关系

示例：

@udf

(

result_type

=

DataTypes.STRING(), 

input_types

=

[DataTypes.STRING(), DataTypes.BIGINT()])




def

 my_add_udf

(i, j):




    return

 i 

+

 str

(j)

表达式算子 ​

表达式算子集成了Focus Search 的公式辅助功能。 输入公式时，拥有代码补全功能。