标签：status 本地 val scala item conf new apply 调试

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)
})

标签：status,本地,val,scala,item,conf,new,apply,调试
来源： https://www.cnblogs.com/bincoding/p/16160998.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。