Skip to content

C
ctr-estimate
Commit da4746f8 authored by 赵建伟's avatar 赵建伟
Browse files
Options

update codes

parent 74779c9d
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
src/main/java/com/gmei/data/ctr/operator/CtrEstimatePfrOperator.java
View file @ da4746f8
...@@ -112,7 +112,7 @@ public class CtrEstimatePfrOperator implements BaseOperator{ ...@@ -112,7 +112,7 @@ public class CtrEstimatePfrOperator implements BaseOperator{
return false; return false;
} }
}); });
filter.print(); //filter.print();
SingleOutputStreamOperator map = filter SingleOutputStreamOperator map = filter
.map(new MapFunction<JSONObject, CtrEstimatePfrEtl>() { .map(new MapFunction<JSONObject, CtrEstimatePfrEtl>() {
@Override @Override
...@@ -156,7 +156,7 @@ public class CtrEstimatePfrOperator implements BaseOperator{ ...@@ -156,7 +156,7 @@ public class CtrEstimatePfrOperator implements BaseOperator{
return ctrEstimatePfrEtl; return ctrEstimatePfrEtl;
} }
}); });
map.print(); //map.print();
DataStream<DeviceCurrentEstimatePfrTmp> tidbAsyncDataStream = AsyncDataStream DataStream<DeviceCurrentEstimatePfrTmp> tidbAsyncDataStream = AsyncDataStream
.unorderedWait(map, new TidbMysqlAsyncPfrSource(jerryJdbcUrl,jerryUsername,jerryPassword), 1, TimeUnit.MINUTES, 1000) .unorderedWait(map, new TidbMysqlAsyncPfrSource(jerryJdbcUrl,jerryUsername,jerryPassword), 1, TimeUnit.MINUTES, 1000)
.uid("tidbAsyncDataStream") .uid("tidbAsyncDataStream")
......
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