scala - 从案例类集合创建 Flink DataStream 时“未找到隐含”
问题描述
我正在尝试做一个scala api hello world 但无法复制从https://www.slideshare.net/dataArtisans/apache-flink-datastream-api-basics/20flink
看到的开始教程片段
我尝试的副本是:
val env = StreamExecutionEnvironment.getExecutionEnvironment
case class Order(user: String, product: String, amount: Double, proctime: Int, rowtime: Int)
def basic() = {
val seq = (1 to 50).map { i => Order(s"User" + (i % 10).toString, "Product" + (i % 20), 2.0 * (4 * i +.5 * i * i -.1 * i * i * i), i * 10, i * 3) }
val ds: DataStream[Order] = env.fromElements(seq:_*)
然而,隐含的不起作用,给
错误:(21, 30) 找不到类型为 org.apache.flink.api.common.typeinfo.TypeInformation[com.blazedb.spark.FlinkDemo.Order] 的证据参数的隐式值
这里需要改变什么?
解决方案
做就是了
import org.apache.flink.streaming.api.scala._
为了导入隐式TypeInformation[T]
推荐阅读
- python - 在帖子列表中显示用户帖子
- python - 查询字典列表,返回具体字典?
- angular - 从列表页面到主页的 Ionic 3 侧边菜单不去
- list - 综合列表上的动态函数(Haskell)
- google-cloud-platform - 查看用户何时添加到 GCP 项目的方法
- r - for 循环不通过下一个元素
- python - 任务计划程序批处理文件启动 Python 脚本并且随机不产生输出 ~20% 的时间
- reactjs - 当我运行命令纱线时,我不断得到未满足的对等依赖。如何摆脱那些警告
- swiftui - SwiftUI:将 Binding 转换为另一个 Binding
- python - UnicodeEncodeError:“latin-1”编解码器无法在位置 693195 编码字符“\u25bc”:序数不在范围内(256)