会员标签4.0

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

@@ -132,6 +132,8 @@ public class TagLowestSingleConsumptionMoneyFilter extends AbstractTagConsumReco
                                     }
                                     return result.iterator();
                                 });
+
+        ecuRdd.foreach(data->System.out.println("ecuId==>"+data));
         return ecuRdd;
     }
 }