zoukankan      html  css  js  c++  java
  • spark2.1:flatMap的用法

    代码示例:

     val sample_data_combine_result=List(
    (0,(List(FitModel(4022,1447.92,-8.38983306721434,2.0)),1)),
    (1,(List(FitModel(1083,389.88,-11.057139857142857,3.0)),1)),
    (2,(List(FitModel(4022,1447.92,-8.38983306721434,2.0)),1))
    )
    
    
    scala> val fitResult = sample_data_combine_result.flatMap(s => {
         |       var fitResultItems: ListBuffer[FitModelWithSceneType] = null
         |       if(s._1==0){
         |         fitResultItems=ListBuffer(
         |           FitModelWithSceneType(0,1,3.0,-3.9110667661835516,0.6989700043360189),
         |           FitModelWithSceneType(0,51,3.0,-3.9110667661835516,1.1760912590556813)
         |         )
         |       }
         |       if(s._1==1){
         |         fitResultItems=ListBuffer(
         |           FitModelWithSceneType(1,1,3.0,-3.9110667661835516,0.6989700043360189),
         |           FitModelWithSceneType(1,51,3.0,-3.9110667661835516,1.1760912590556813),
         |           FitModelWithSceneType(1,101,3.0,-3.9110667661835516,1.3979400086720377)
         |         )
         |       }
         |       if(s._1==2){
         |         fitResultItems=ListBuffer(
         |           FitModelWithSceneType(2,1,3.0,-3.9110667661835516,0.6989700043360189),
         |           FitModelWithSceneType(2,51,3.0,-3.9110667661835516,1.1760912590556813),
         |           FitModelWithSceneType(2,101,3.0,-3.9110667661835516,1.3979400086720377),
         |           FitModelWithSceneType(2,101,3.0,-3.9110667661835516,1.3979400086720377),
         |           FitModelWithSceneType(2,101,3.0,-3.9110667661835516,1.3979400086720377)
         |         )
         |       }
         | 
         |       fitResultItems
         |     })
    fitResult: List[FitModelWithSceneType] = 
    List(
    FitModelWithSceneType(0,1,3.0,-3.9110667661835516,0.6989700043360189), 
    FitModelWithSceneType(0,51,3.0,-3.9110667661835516,1.1760912590556813), 
    FitModelWithSceneType(1,1,3.0,-3.9110667661835516,0.6989700043360189), 
    FitModelWithSceneType(1,51,3.0,-3.9110667661835516,1.1760912590556813), 
    FitModelWithSceneType(1,101,3.0,-3.9110667661835516,1.3979400086720377), 
    FitModelWithSceneType(2,1,3.0,-3.9110667661835516,0.6989700043360189), 
    FitModelWithSceneType(2,51,3.0,-3.9110667661835516,1.1760912590556813), 
    FitModelWithSceneType(2,101,3.0,-3.9110667661835516,1.3979400086720377), 
    FitModelWithSceneType(2,101,3.0,-3.9110667661835516,1.3979400086720377), 
    FitModelWithSceneType(2,101,3.0,-3.9110667661835516,1.3979400086720377)
    )
  • 相关阅读:
    win10系统打印图片中间空白的解决办法
    DELPHI SOKET 编程--使用TServerSocket和TClientSocket
    因为未启用行移动功能 不能闪回表
    oracle闪退(回退)功能
    查看oracle数据库的数据文件的目录
    Oracle
    Delphi : keydown与keypress的区别,组合键
    Delphi Xe 中如何把日期格式统一处理,玩转 TDatetime
    移除 IIS 的各种头信息
    sql server 通过 sql 查询数据库状态
  • 原文地址:https://www.cnblogs.com/yy3b2007com/p/8515564.html
Copyright © 2011-2022 走看看