1. 新手站长_郑州云淘科技有限公司首页
  2. 阿里云

flink sql执行的时候，如果不用实体对象去封装有什么解决办法吗？-[阿里云_云淘科技]

匿名 • • 阿里云

flink sql执行的时候，接收到上游的datastream数据对象是用map封装的，然后执行时报错：Column ‘o7’ not found in any table 如果不用实体对象去封装有什么解决办法吗？

以下为热心网友提供的参考意见

你可以使用 map() 函数对数据进行转换，如下所示：

val data = env.readTextFile(“path/to/file”)
val mappedData = data.map { record =>
val key = record.split(“,”)(0)
val value = record.split(“,”)(1)
(key, value)
}

本文来自投稿，不代表新手站长_郑州云淘科技有限公司立场，如若转载，请注明出处：https://www.cnzhanzhang.com/18656.html

赞 (0)
匿名
上一篇 2023年12月25日 上午8:06
下一篇 2023年12月25日

相关推荐

新手站长从“心”出发，感谢16年您始终不离不弃。