Commit d2879174 authored by 赵建伟's avatar 赵建伟

update codes

parent f65b1d02
......@@ -142,7 +142,8 @@ public class CtrEstimateClkOperator implements BaseOperator{
return estimateClickEtl.getDeviceId() + "_" + estimateClickEtl.getEstimateType();
}
})
.timeWindow(Time.minutes(5), Time.minutes(5))
//.timeWindow(Time.minutes(5), Time.minutes(5))
.timeWindow(Time.seconds(5), Time.seconds(5))
.process(new ProcessWindowFunction<CtrEstimateClkEtl, DeviceCurrentEstimateClk, String, TimeWindow>() {
@Override
public void process(String key, Context context, Iterable<CtrEstimateClkEtl> estimateClickEtls, Collector<DeviceCurrentEstimateClk> out) {
......
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