소스 검색

feat:修改无回传判断逻辑

zhaohaipeng 6 달 전
부모
커밋
ef0a8cba2c
1개의 변경된 파일4개의 추가작업 그리고 1개의 파일을 삭제
  1. 4 1
      src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_31_originData_20240718.scala

+ 4 - 1
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_31_originData_20240718.scala

@@ -57,7 +57,10 @@ object makedata_ad_31_originData_20240718 {
           .filter(record => {
             val extendAlg: JSONObject = if (record.isNull("extend_alg")) new JSONObject() else
               JSON.parseObject(record.getString("extend_alg"))
-            val isApi = extendAlg.getString("is_api")
+            var isApi = extendAlg.getString("is_api")
+            if (extendAlg.containsKey("extinfo")) {
+              isApi = extendAlg.getJSONObject("extinfo").getString("isApi")
+            }
             "1".equals(isApi)
           })
           .map(record => {