会员标签4.0

src/main/java/com/gic/spark/filter/TagLowestSingleConsumptionMoneyFilter.java

@@ -130,9 +130,10 @@ public class TagLowestSingleConsumptionMoneyFilter extends AbstractTagConsumReco
                                             default:break;
                                         }
                                     }
+                                    System.out.println("result==>"+result.size());
                                     return result.iterator();
                                 });
-
+        System.out.println("ecuRdd.count==>"+ecuRdd.count());
         ecuRdd.foreach(data->System.out.println("ecuId==>"+data));
         return ecuRdd;
     }