update sink

d26b6d25 · 刘喆 · b4d5a5a9 · d26b6d25
Commit d26b6d25 authored Jan 14, 2020 by 刘喆
Hide whitespace changes
Inline Side-by-side

Showing with 9 additions and 9 deletions

PreciseExposureStreaming.java ...ain/java/com/gmei/streaming/PreciseExposureStreaming.java +9 -9

No files found.
--- a/bl_et_pe_preciseexposure_inc_d_distinct/src/main/java/com/gmei/streaming/PreciseExposureStreaming.java
+++ b/bl_et_pe_preciseexposure_inc_d_distinct/src/main/java/com/gmei/streaming/PreciseExposureStreaming.java
@@ -141,15 +141,15 @@ public class PreciseExposureStreaming {
        /*
        BL层数据下发
         */
-        blPreciseExposureStreamBF.print();
-//                .addSink(new BlPreciseExposureMysqlSink(sinkJdbcUrl, sinkBFBlTableName))
-//                .uid("id_blpreciseexposurebf_sink")
-//                .setParallelism(parallelism);
-
-        blPreciseExposureStreamHLL.print();
-//                .addSink(new BlPreciseExposureMysqlSink(sinkJdbcUrl, sinkHLLBlTableName))
-//                .uid("id_blpreciseexposurehll_sink")
-//                .setParallelism(parallelism);
+        blPreciseExposureStreamBF
+                .addSink(new BlPreciseExposureMysqlSink(sinkJdbcUrl, sinkBFBlTableName))
+                .uid("id_blpreciseexposurebf_sink")
+                .setParallelism(parallelism);
+
+        blPreciseExposureStreamHLL
+                .addSink(new BlPreciseExposureMysqlSink(sinkJdbcUrl, sinkHLLBlTableName))
+                .uid("id_blpreciseexposurehll_sink")
+                .setParallelism(parallelism);

 //        //测试打印
 //        blPreciseExposureStreamBF.print();