0%

[原理]Flink-内置函数

org.apache.flink.table.functions

所有的内置函数

org.apache.flink.table.functions.BuiltInFunctionDefinitions

以Date_Format为例

1
2
3
4
5
6
7
8
9
// 类型为SCALAR函数
// TypeStrategies: 推断函数调用的输出或累加器数据类型的策略。
// 输出类型为空
public static final BuiltInFunctionDefinition DATE_FORMAT =
new BuiltInFunctionDefinition.Builder()
.name("dateFormat")
.kind(SCALAR)
.outputTypeStrategy(TypeStrategies.MISSING)
.build();

image-20210605110135752