Skip to content

F
flink_warehouse_rt
Commit d42caa20 authored by 徐伟's avatar 徐伟
Browse files
Options

code clean

parent b52936f2
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 10 deletions
bl_hdfs_maidian_open/src/main/java/com/gmei/map/GainValueMap.java
View file @ d42caa20
...@@ -59,17 +59,10 @@ public class GainValueMap implements MapFunction<String, MaidianEtl> { ...@@ -59,17 +59,10 @@ public class GainValueMap implements MapFunction<String, MaidianEtl> {
} else { } else {
new_params = params; new_params = params;
} }
if (action.equals("page_view")) { JSONObject paramsObject = JSON.parseObject(new_params);
JSONObject paramsObject = JSON.parseObject(new_params); if (paramsObject != null) {
String in = StringUtils.changeNullTolength0(paramsObject.get("in")); duration = StringUtils.isNullToDouble(paramsObject.get("duration"));
String out = StringUtils.changeNullTolength0(paramsObject.get("in"));
} else {
JSONObject paramsObject = JSON.parseObject(params);
if (paramsObject != null) {
duration = StringUtils.isNullToDouble(paramsObject.get("duration"));
}
} }
MaidianEtl maidianEtl = new MaidianEtl(create_at, MaidianEtl maidianEtl = new MaidianEtl(create_at,
gm_nginx_timestamp, gm_nginx_timestamp,
action, action,
......
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