0
点赞
收藏
分享

微信扫一扫

scala本地调试函数

圣杰 2022-05-14 阅读 42
val conf = new SparkConf().setAppName("ProductPrivilege").setMaster("local[1]")
//创建spark执行的入口
val sc = new SparkContext(conf)

val session = SparkSession
.builder()
.enableHiveSupport()
.getOrCreate()

val rdd = sc.textFile("/Users/admin/.../product_info_test.txt")

val rddSolve = rdd.map(x => {
val item = x.split(",").toList
val productId = item.head.toLong
val shopId = item.apply(1).toLong
val status = item.apply(2).toInt
Row(productId, shopId, status)
})

时间会记录下一切。




举报

相关推荐

0 条评论