会员标签4.0

0c5f50db · guos · 9c9a0bb0 · 0c5f50db
Commit 0c5f50db authored Aug 21, 2020 by guos
Hide whitespace changes
Inline Side-by-side

Showing with 3 additions and 1 deletions

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

No files found.
--- a/src/main/java/com/gic/spark/tag/TagProcessManager.java
+++ b/src/main/java/com/gic/spark/tag/TagProcessManager.java
@@ -265,7 +265,9 @@ public class TagProcessManager {
        SparkSession sparkSession=SparkEnvManager.getInstance().getSparkSession();
        Dataset<Row>tagGroupInfoDataset=sparkSession.createDataFrame(tagGroupInfoRDD,TagGroupInfo.class);
        tagGroupInfoDataset.createOrReplaceTempView("tag_group_info_tmp");
-        sparkSession.sql(String.format("INSERT overwrite table %s.tag_group_info PARTITION(enterprise_id = '%s') SELECT id,tag_group_info from tag_group_info_tmp",isProduction?"tag4_prod":"tag4_test", enterpriseId));
+
+        tagGroupInfoDataset.show();
+//        sparkSession.sql(String.format("INSERT overwrite table %s.tag_group_info PARTITION(enterprise_id = '%s') SELECT id,tag_group_info from tag_group_info_tmp",isProduction?"tag4_prod":"tag4_test", enterpriseId));

    }