update bl_et_pe_preciseexposure_inc_d_bm

9160dff4 · 刘喆 · 6d3e06dc · 9160dff4
Commit 9160dff4 authored Jan 17, 2020 by 刘喆
Show whitespace changes
Inline Side-by-side

Showing with 4 additions and 4 deletions

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

No files found.
--- a/bl_et_pe_preciseexposure_inc_d_bm/src/main/java/com/gmei/streaming/PreciseExposureStreaming.java
+++ b/bl_et_pe_preciseexposure_inc_d_bm/src/main/java/com/gmei/streaming/PreciseExposureStreaming.java
@@ -157,10 +157,10 @@ public class PreciseExposureStreaming {
 //                .setParallelism(parallelism);

        blPreciseExposureStreamBM
-                .print();
-//                .addSink(new BlPreciseExposureMysqlSink(sinkJdbcUrl, sinkBMBlTableName))
-//                .uid("id_blpreciseexposurebm_sink")
-//                .setParallelism(parallelism);
+//                .print();
+                .addSink(new BlPreciseExposureMysqlSink(sinkJdbcUrl, sinkBMBlTableName))
+                .uid("id_blpreciseexposurebm_sink")
+                .setParallelism(parallelism);
 //        //测试打印
 //        blPreciseExposureStreamBF.print();
 //        blPreciseExposureStreamHLL.print();