会员标签4.0

src/main/java/com/gic/spark/entity/TagGroupInfo.java

@@ -19,4 +19,28 @@ public class TagGroupInfo implements Serializable{
         this.enterprise_id = enterprise_id;
         this.tag_group_info = tag_group_info;
     }
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public Integer getEnterprise_id() {
+        return enterprise_id;
+    }
+
+    public void setEnterprise_id(Integer enterprise_id) {
+        this.enterprise_id = enterprise_id;
+    }
+
+    public String getTag_group_info() {
+        return tag_group_info;
+    }
+
+    public void setTag_group_info(String tag_group_info) {
+        this.tag_group_info = tag_group_info;
+    }
 }

src/main/java/com/gic/spark/tag/TagProcessManager.java

@@ -274,6 +274,7 @@ public class TagProcessManager {
                                                 }
                                                 return tagGroupInfoList.iterator();
                                             });
+        System.out.println("tagGroupInfoRDD.count==>"+tagGroupInfoRDD.count());
         SparkSession sparkSession=SparkEnvManager.getInstance().getSparkSession();
         Dataset<Row>tagGroupInfoDataset=sparkSession.createDataFrame(tagGroupInfoRDD,TagGroupInfo.class);
         tagGroupInfoDataset.createOrReplaceTempView("tag_group_info_tmp");
@@ -319,7 +320,6 @@ public class TagProcessManager {
         try {
             ps= DaoHelper.getPreparedStatement(connection,"update tab_scene_crowd set update_group_time=? where id=?");
             for(Long id:sceneCrowdIdList){
-                System.out.println("sceneCrowdId==>"+id);
                 ps.setTimestamp(1,new Timestamp(System.currentTimeMillis()));
                 ps.setLong(2,id);
                 ps.addBatch();