会员标签4.0

292c03a3 · guos · 9056b73b · 292c03a3
Commit 292c03a3 authored Sep 30, 2020 by guos
Hide whitespace changes
Inline Side-by-side

Showing with 1 additions and 0 deletions

TagProcessManager.java src/main/java/com/gic/spark/tag/TagProcessManager.java +1 -0

No files found.
--- a/src/main/java/com/gic/spark/tag/TagProcessManager.java
+++ b/src/main/java/com/gic/spark/tag/TagProcessManager.java
@@ -213,6 +213,7 @@ public class TagProcessManager {

                        JavaPairRDD<Long, String> filterRdd = tagFilter.filterValidMember(enterpriseId,filterRequest).mapToPair(data-> Tuple2.apply(data,groupId));

+                        System.out.println("filterRdd==>"+filterRdd.count());
                        if(null==memberGroupRdd){
                            memberGroupRdd=filterRdd;
                        }else{