开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

请教个问题,这个语句在 flinksql执行提示解析失败, hive 中没问题, select

请教个问题,这个语句在 flinksql执行提示解析失败, hive 中没问题, select a.c_usernum as c_usernum,vid_key as c_attribute_name,vid_value as c_attribute_value,a.c_capturetime as c_timestamp from (select c_msisdn as c_usernum ,c_capturetime,map('key1','value1','key2','value2') as info_map from tab1)a LATERAL VIEW explode (info_map)tmp AS vid_key,vid_value where vid_key is not null and vid_value is not null

是flinksql 不支持这种语法是吧, 如果不支持, 有没有可以下替代的方案, 大概就是在一条数据里面 提出多个 key-value , 最后展开成多行

展开
收起
绿子直子 2023-02-07 16:29:16 692 0
3 条回答
写回答
取消 提交回答
  • 公众号:网络技术联盟站,InfoQ签约作者,阿里云社区签约作者,华为云 云享专家,BOSS直聘 创作王者,腾讯课堂创作领航员,博客+论坛:https://www.wljslmz.cn,工程师导航:https://www.wljslmz.com

    在hive中执行没问题的话,可以将hive集成到flinksql中。

    2023-02-08 09:47:55
    赞同 展开评论 打赏
  • 在flink sql中加载hive的模块,或者使用hive 方言。使用flink sql 是可以使用hive方言的额,处理实时也没问题。

    此答案来自钉钉群“【2】Apache Flink China 社区”

    2023-02-07 17:32:52
    赞同 展开评论 打赏
  • Flink SQL 不支持这种语法,您可以尝试使用Flink Table API来实现您的需求,具体的实现方式可以参考官方文档。

    2023-02-07 17:29:39
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关电子书

更多
神龙云服务器产品及技术深度解析 立即下载
弹性创造价值:基于ECS的最佳性价比实践解析 立即下载
又快又稳:阿里云下一代虚拟交换机解析 立即下载

相关镜像