flink-hello-world

Flink 示例程序包（自定义函数 UDF、自定义 Source 和 Sink 等），可扩展 Flink 程序的功能。

Flink 程序示例

WordCount

UDF 示例

DecodeLatin1
EncodeLatin1
PrintChar
EnhancedSplitIndex
ArrayAgg (示例参考 IntArrayAgg, RowArrayAgg1)
Exploded
StrToArray

Sink 示例

LoggerTableSinkFactory