Skip to content

G
gic-spark-tag-4.0
Commit a8c4252c by guos
Options

会员标签4.0

parent 4fa3059d
Showing with 2 additions and 2 deletions
src/main/java/com/gic/spark/tag/TagProcessManager.java
...@@ -213,9 +213,9 @@ public class TagProcessManager { ...@@ -213,9 +213,9 @@ public class TagProcessManager {
JavaPairRDD<Long,String>memberGroupRdd=null; JavaPairRDD<Long,String>memberGroupRdd=null;
for(JavaPairRDD<Long,String>rdd:filterRddList){ for(JavaPairRDD<Long,String>rdd:filterRddList){
if(null==memberGroupRdd){ if(null==memberGroupRdd){
rdd=memberGroupRdd; memberGroupRdd=rdd;
}else{ }else{
memberGroupRdd.union(rdd); memberGroupRdd=memberGroupRdd.union(rdd);
} }
} }
JavaPairRDD<Long,Long>userRdd=memberSharding4Datasource.getDatasetByEnterpriseId(enterpriseId).select("id").javaRDD() JavaPairRDD<Long,Long>userRdd=memberSharding4Datasource.getDatasetByEnterpriseId(enterpriseId).select("id").javaRDD()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment