add printer

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

@@ -53,9 +53,10 @@ object Main {
     val stream: DataStream[UserInfo] = env.addSource(kafkaConsumer)
 
     stream.map { user =>
-      println(user.deviceId)
       val projects = user.projects.toList
       val secondDemands = user.secondDemands.toList
+      println(user.deviceId)
+      println(projects.mkString(" "))
       if ((projects.size > 0) || (secondDemands.size > 0)) {
         val diaryQuery = ES.generateDiaryQuery(projects, secondDemands, -1)
         val tractateQuery = ES.generateTractateQuery(projects, secondDemands)

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

@@ -42,12 +42,12 @@ object ESClient {
 }
 
 object ES {
-  case class Character(id: String, index: String)
+  case class Character(id: String, index: String, projects: Array[String])
 
   implicit object CharacterHitReader extends HitReader[Character] {
     override def read(hit: Hit): Try[Character] = {
       val source = hit.sourceAsMap
-      Try(Character(source("id").toString, hit.index))
+      Try(Character(source("id").toString, hit.index, source("tags_v3").asInstanceOf[Array[String]]))
     }
   }
 
@@ -71,7 +71,9 @@ object ES {
 
     println("%%%%%%%%%%%")
     println(a.size)
-    a.foreach(x => println(x.id, x.index))
+    a.foreach { x =>
+      println(x.id, x.index, x.projects.mkString(" "))
+    }
     println("%%%%%%%%%%%")
 
     resp