自定义算子

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

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

Python Flink UDF

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

示例：

python

@udf(result_type=DataTypes.STRING(), input_types=[DataTypes.STRING(), DataTypes.BIGINT()])
def my_add_udf(i, j):
    return i + str(j)

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