会员标签4.0

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

@@ -84,7 +84,8 @@ public class TagProcess {
         mysqlRddManager=member4Datasource.buildRddManager();
 
         Dataset<TabSceneCrowd>sceneCrowdDataset=mysqlRddManager.getPojo("tab_scene_crowd", TabSceneCrowd.class,null)
-                                                                .filter(new Column("valid_flag").equalTo(1));
+                                                                .filter(new Column("valid_flag").equalTo(1))
+                                                                .filter(new Column("real_time").equalTo(2));
         List<TabSceneCrowd> sceneCrowdList=sceneCrowdDataset.collectAsList();
         for(TabSceneCrowd sceneCrowd:sceneCrowdList){
             LinkedList<TagConditionGroupDTO>conditionGroupDTOList=JSONObject.parseObject(sceneCrowd.getTag_Condition_Group_Info(),  new TypeReference<LinkedList<TagConditionGroupDTO>>(){});