Commit bb36836f authored by RingEric's avatar RingEric

数据处理flink入口

parent c462afc8
...@@ -6,6 +6,7 @@ import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer ...@@ -6,6 +6,7 @@ import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer
import qm.kafka.KafkaConsumer import qm.kafka.KafkaConsumer
/** /**
* @ClassName: Flink * @ClassName: Flink
* @Description: TODO * @Description: TODO
...@@ -30,9 +31,11 @@ object FlinkEntry { ...@@ -30,9 +31,11 @@ object FlinkEntry {
// 数据处理流程 // 数据处理流程
Analysis.analysis(x) Analysis.analysis(x)
}) })
.map(x => { //将数组压平
x.mkString("{", ",", "}") .flatMap(x => x)
}) //过滤掉不合理的数据
.filter(x => x.eventName.nonEmpty)
.executeAndCollect() .executeAndCollect()
.foreach(println) .foreach(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