update user type

src/main/scala/com.gmei.up/Main.scala

@@ -51,22 +51,22 @@ object Main {
 
     val stream: DataStream[UserInfo] = env.addSource(kafkaConsumer)
 
-    // stream.map { user =>
-    //   val projects = user.projects.toList
-    //   val secondDemands = user.secondDemands.toList
-    //   println(user.deviceId)
-    //   println(projects.mkString(" "))
+    stream.map { user =>
+      val projects = user.projects.toList
+      val secondDemands = user.secondDemands.toList
+      println(user.deviceId)
+      println(projects.mkString(" "))
 
-    //   val diaryReq = ES.generateDiaryRequest(projects, secondDemands, user.cityId)
-    //   val tractateReq = ES.generateTractateRequest(projects, secondDemands)
-    //   val answerReq = ES.generateAnswerRequest(projects, secondDemands)
-    //   ES.test(diaryReq, tractateReq, answerReq)
+      val diaryReq = ES.generateDiaryRequest(projects, secondDemands, user.cityId)
+      val tractateReq = ES.generateTractateRequest(projects, secondDemands)
+      val answerReq = ES.generateAnswerRequest(projects, secondDemands)
+      ES.test(diaryReq, tractateReq, answerReq)
 
-    //   println("########################")
-    //   user.deviceId
-    // }
+      println("########################")
+      user.deviceId
+    }
 
-    stream.print
+    // stream.print
     env.execute("flink streaming user portrait")
   }
 }

src/main/scala/com.gmei.up/utils/User.scala

@@ -8,5 +8,5 @@ case class UserInfo(
     cityId: Int,
     secondDemands: Array[String],
     projects: Array[String],
-    bussinessTags: Array[String]
+    businessTags: Array[String]
 )