关闭数据清洗

qg-data-service/pom.xml

@@ -5,7 +5,7 @@
 
     <groupId>cn.quantgroup</groupId>
     <artifactId>qg-data-service</artifactId>
-    <version>1.1.6-SNAPSHOT</version>
+    <version>1.2.0-SNAPSHOT</version>
     <packaging>jar</packaging>
     <name>qg-data-service</name>
 

qg-data-service/src/main/java/cn/quantgroup/qgdataservice/service/hbase/OperatorInfoService.java

@@ -49,7 +49,7 @@ public class OperatorInfoService {
         else
             SpiderUserItemDataService.put(spiderUserItemDataRow);
 
-        OperatorInfoCleaningService.cleaningAndSaveUserInfo(spiderUserItemDataRow, uuid, ka);
+//        OperatorInfoCleaningService.cleaningAndSaveUserInfo(spiderUserItemDataRow, uuid, ka);
 
     }
 
@@ -66,7 +66,7 @@ public class OperatorInfoService {
         else
             MobileCallInfoDataService.put(mobileCallInfoRows);
 
-        OperatorInfoCleaningService.cleaningAndSaveMobileCallDetailInfo(mobileCallInfoRows, uuid, ka);
+//        OperatorInfoCleaningService.cleaningAndSaveMobileCallDetailInfo(mobileCallInfoRows, uuid, ka);
 
     }
 
@@ -83,7 +83,7 @@ public class OperatorInfoService {
         else
             MobileSmsInfoDataService.put(mobileSmsInfoRows);
 
-        OperatorInfoCleaningService.cleaningAndSaveMobileSmsDetainInfo(mobileSmsInfoRows, uuid, ka);
+//        OperatorInfoCleaningService.cleaningAndSaveMobileSmsDetainInfo(mobileSmsInfoRows, uuid, ka);
 
     }
 
@@ -100,7 +100,7 @@ public class OperatorInfoService {
         else
             MobileFlowInfoDataService.put(mobileFlowInfoRows);
 
-        OperatorInfoCleaningService.cleaningAndSaveMobileFlowDetailInfo(mobileFlowInfoRows, uuid, ka);
+//        OperatorInfoCleaningService.cleaningAndSaveMobileFlowDetailInfo(mobileFlowInfoRows, uuid, ka);
 
     }
 
@@ -117,7 +117,7 @@ public class OperatorInfoService {
         else
             TelecomCallInfoDataService.put(telecomCallInfoRows);
 
-        OperatorInfoCleaningService.cleaningAndSaveTelecomCallDetailInfo(telecomCallInfoRows, uuid, ka);
+//        OperatorInfoCleaningService.cleaningAndSaveTelecomCallDetailInfo(telecomCallInfoRows, uuid, ka);
 
     }
 
@@ -134,7 +134,7 @@ public class OperatorInfoService {
         else
             TelecomSmsInfoDataService.put(telecomSmsInfoRows);
 
-        OperatorInfoCleaningService.cleaningAndSaveTelecomSmsDetailInfo(telecomSmsInfoRows, uuid, ka);
+//        OperatorInfoCleaningService.cleaningAndSaveTelecomSmsDetailInfo(telecomSmsInfoRows, uuid, ka);
 
     }
 
@@ -151,7 +151,7 @@ public class OperatorInfoService {
         else
             TelecomFlowInfoDataService.put(telecomFlowInfoRows);
 
-        OperatorInfoCleaningService.cleaningAndSaveTelecomFlowDetailInfo(telecomFlowInfoRows, uuid, ka);
+//        OperatorInfoCleaningService.cleaningAndSaveTelecomFlowDetailInfo(telecomFlowInfoRows, uuid, ka);
 
     }
 
@@ -168,7 +168,7 @@ public class OperatorInfoService {
         else
             UnicomCallInfoDataService.put(unicomCallInfoRows);
 
-        OperatorInfoCleaningService.cleaningAndSaveUnicomCallDetailInfo(unicomCallInfoRows, uuid, ka);
+//        OperatorInfoCleaningService.cleaningAndSaveUnicomCallDetailInfo(unicomCallInfoRows, uuid, ka);
 
     }
 
@@ -185,7 +185,7 @@ public class OperatorInfoService {
         else
             UnicomSmsInfoDataService.put(unicomSmsInfoRows);
 
-        OperatorInfoCleaningService.cleaningAndSaveUnicomSmsDetailInfo(unicomSmsInfoRows, uuid, ka);
+//        OperatorInfoCleaningService.cleaningAndSaveUnicomSmsDetailInfo(unicomSmsInfoRows, uuid, ka);
 
     }
 
@@ -202,7 +202,7 @@ public class OperatorInfoService {
         else
             UnicomFlowInfoDataService.put(unicomFlowInfoRows);
 
-        OperatorInfoCleaningService.cleaningAndSaveUnicomFlowDetailInfo(unicomFlowInfoRows, uuid, ka);
+//        OperatorInfoCleaningService.cleaningAndSaveUnicomFlowDetailInfo(unicomFlowInfoRows, uuid, ka);
 
     }
 
@@ -219,7 +219,7 @@ public class OperatorInfoService {
         else
             PhoneBillDataService.put(phoneBillDataRow);
 
-        OperatorInfoCleaningService.cleaningAndSavePhoneBillInfo(phoneBillDataRow, uuid, ka);
+//        OperatorInfoCleaningService.cleaningAndSavePhoneBillInfo(phoneBillDataRow, uuid, ka);
 
     }
 
@@ -233,7 +233,7 @@ public class OperatorInfoService {
 
         PhonePaymentDataService.put(phonePaymentDataRow);
 
-        OperatorInfoCleaningService.cleaningAndSaveRechargeInfo(phonePaymentDataRow, uuid, ka);
+//        OperatorInfoCleaningService.cleaningAndSaveRechargeInfo(phonePaymentDataRow, uuid, ka);
 
     }