Skip to content

S
streamingUserPortrait
Commit 95580d2b authored by 赵威's avatar 赵威
Browse files
Options

add query

parent 15fd9489
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 3 deletions
src/main/scala/com.gmei.up/Main.scala
View file @ 95580d2b
...@@ -11,7 +11,7 @@ import org.apache.flink.streaming.connectors.kafka.{ ...@@ -11,7 +11,7 @@ import org.apache.flink.streaming.connectors.kafka.{
import org.apache.flink.api.common.typeinfo.{ TypeHint, TypeInformation, Types } import org.apache.flink.api.common.typeinfo.{ TypeHint, TypeInformation, Types }
import org.apache.kafka.clients.consumer.ConsumerRecord import org.apache.kafka.clients.consumer.ConsumerRecord
import com.alibaba.fastjson.JSON import com.alibaba.fastjson.JSON
import com.gmei.up.utils.{ UserInfo, ES } import com.gmei.up.utils.{ UserInfo }
class UserInfoDeserializationSchema extends KafkaDeserializationSchema[UserInfo] { class UserInfoDeserializationSchema extends KafkaDeserializationSchema[UserInfo] {
override def isEndOfStream(t: UserInfo): Boolean = false override def isEndOfStream(t: UserInfo): Boolean = false
...@@ -52,8 +52,8 @@ object Main { ...@@ -52,8 +52,8 @@ object Main {
stream.map { user => stream.map { user =>
println(user.deviceId) println(user.deviceId)
val query = ES.generateDiaryQuery(-1, user.projects, user.secondDemands) // val query = ES.generateDiaryQuery(-1, user.projects, user.secondDemands)
println(query) // println(query)
// ES.test(query) // ES.test(query)
println("########################") println("########################")
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment