删除没必要的文件

src/main/scala/qm/flink/Analysis.scala

@@ -71,7 +71,7 @@ object Analysis {
     val eventTuple = new ArrayBuffer[(String, String)]()
 
     //数组不为空
-    if (!projects.isEmpty) {
+    if (projects.nonEmpty) {
       val eventMap = new util.HashMap[String, Any]()
       for (project <- projects) {
         Jackson.autoParseJson(project.toString, eventMap)

src/main/scala/qm/flink/FlinkEntry.scala

@@ -35,7 +35,11 @@ object FlinkEntry {
       .flatMap(x => x)
       //过滤掉不合理的数据
       .filter(x => x.eventName.nonEmpty)
+      .map(item => {
 
+        // TODO:  事件后续处理
+        item
+      })
       .executeAndCollect()
       .foreach(println)