init id_mapping

azkaban/id_mapping/id_mapping.sh

@@ -14,7 +14,9 @@ check_await "${ADN_REQUEST_INPUT_PATH}/_SUCCESS"
 
 check_await "${DSP_INPUT_PATH}/_SUCCESS"
 
-OUTPUT_PATH=${ADS_DEVICE_ID_MAPPING}/${date_path}
+OUTPUT_PATH=${ADS_DEVICE_MID_ID_MAPPING}/${date_path}
+
+RESULT_OUTPUT_PATH=${ADS_DEVICE_ID_MAPPING}/${date_path}
 
 country="US"
 
@@ -28,7 +30,7 @@ spark-submit --class mobvista.dmp.datasource.id_mapping.IDMappingGraphx \
   --conf spark.default.parallelism=10000 \
   --conf spark.executor.extraJavaOptions="-XX:+UseG1GC" \
   --master yarn --deploy-mode cluster --executor-memory 12g --driver-memory 8g --executor-cores 5 --num-executors 100 \
-  ../${JAR} -date ${LOG_TIME} -country ${country} -platform ${platform} -output ${OUTPUT_PATH} -coalesce 500
+  ../${JAR} -date ${LOG_TIME} -country ${country} -platform ${platform} -output ${OUTPUT_PATH} -result_output ${RESULT_OUTPUT_PATH} -coalesce 500
 
 if [ $? -ne 0 ]; then
   exit 255

src/main/scala/mobvista/dmp/datasource/id_mapping/IDMappingGraphx.scala

@@ -31,6 +31,7 @@ class IDMappingGraphx extends CommonSparkJob with Serializable {
     options.addOption("date", true, "date")
     options.addOption("output", true, "output")
     options.addOption("coalesce", true, "coalesce")
+    options.addOption("result_output", true, "result_output")
     options
   }