以 1.12 版本为例,记录一些 Flink 使用过程中的知识点。
语法
- FlinkSQL 在某种程度上不支持
!=
,使用时会报org.apache.flink.table.api.SqlParserException: SQL parse failed. Bang equal '!=' is not allowed under the current SQL conformance level
异常,可使用<>
代替。
函数
全量函数用法可参考 Apache Flink 1.12 Documentation: System (Built-in) Functions。
- 尝试实现类似 Hive 中
concat_ws('-', collect_set(列名))
的聚合后行转列的操作,发现 Flink 似乎不支持collect_set
函数,但可以选择listagg(列名, 分隔符)
直接完成转换和拼接。
文档信息
- 本文作者:unigeorge
- 本文链接:https://unigeorge.github.io//notes/flink/
- 版权声明:自由转载-非商用-非衍生-保持署名(创意共享3.0许可证)