Skip to content

Q
qg-dbc-spark
Commit 65e558ee authored by data爬虫-冯 军凯's avatar data爬虫-冯 军凯
Browse files
Options

申请单数据清洗test

parent 97c6a01b
Hide whitespace changes
Inline Side-by-side
Showing with 20 additions and 20 deletions
src/main/java/cn/quantgroup/dbc/spark/applyList/ApplyListExportToBizFlowMain.java
View file @ 65e558ee
...@@ -127,31 +127,31 @@ public class ApplyListExportToBizFlowMain { ...@@ -127,31 +127,31 @@ public class ApplyListExportToBizFlowMain {
// JdbcExecuters.prepareBatchUpdateExecuteApply(sql, applyListRows); // JdbcExecuters.prepareBatchUpdateExecuteApply(sql, applyListRows);
// applyListRows.clear(); // applyListRows.clear();
// } // }
Object channel = result.getAs("channel"); // Object channel = result.getAs("channel");
if(Objects.isNull(channel)){ // if(Objects.isNull(channel)){
System.out.println("channel 为空--->"+result.toString()); // System.out.println("channel 为空--->"+result.toString());
channelLongAccumulator.add(1); // channelLongAccumulator.add(1);
} // }
Object product_type = result.getAs("product_type"); // Object product_type = result.getAs("product_type");
if(Objects.isNull(product_type)){ // if(Objects.isNull(product_type)){
System.out.println("product_type 为空--->"+result.toString()); // System.out.println("product_type 为空--->"+result.toString());
productTypeLongAccumulator.add(1); // productTypeLongAccumulator.add(1);
} // }
Object uuid = result.getAs("uuid"); Object uuid = result.getAs("uuid");
if(Objects.isNull(uuid)){ if(Objects.isNull(uuid)){
System.out.println("uuid 为空--->"+result.toString()); System.out.println("uuid 为空--->"+result.toString());
uuidLongAccumulator.add(1); uuidLongAccumulator.add(1);
} }
Object order_no = result.getAs("order_no"); // Object order_no = result.getAs("order_no");
if(Objects.isNull(order_no)){ // if(Objects.isNull(order_no)){
System.out.println("order_no 为空--->"+result.toString()); // System.out.println("order_no 为空--->"+result.toString());
orderNoLongAccumulator.add(1); // orderNoLongAccumulator.add(1);
} // }
Object credit_status = result.getAs("credit_status"); // Object credit_status = result.getAs("credit_status");
if(Objects.isNull(credit_status)){ // if(Objects.isNull(credit_status)){
System.out.println("apply_status 为空--->"+result.toString()); // System.out.println("apply_status 为空--->"+result.toString());
creditStatusLongAccumulator.add(1); // creditStatusLongAccumulator.add(1);
} // }
} catch (Exception e) { } catch (Exception e) {
......
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