大数据任务迁移
Showing
Pyspark_job/LocalTest.py
0 → 100644
Pyspark_job/__init__.py
0 → 100644
File added
Pyspark_job/clean/__init__.py
0 → 100644
Pyspark_job/clean/clean_weight.py
0 → 100644
Pyspark_job/ct/__init__.py
0 → 100644
Pyspark_job/ct/aba_2023_10_12_export.py
0 → 100644
Pyspark_job/ct/aba_re_run_month.py
0 → 100644
Pyspark_job/ct/asin_to_number.py
0 → 100644
Pyspark_job/ct/es_to_hive.py
0 → 100644
Pyspark_job/ct/export_dwt_flow_asin.py
0 → 100644
Pyspark_job/ct/merchantwords_hive_to_pg16.py
0 → 100644
Pyspark_job/ct/merchantwords_sr_to_pg16.py
0 → 100644
Pyspark_job/ct/ods_asin_detail_sr_to_hive.py
0 → 100644
Pyspark_job/ct/ods_asin_detail_to_sr.py
0 → 100644
Pyspark_job/ct/re_run_aba_2022.py
0 → 100644
Pyspark_job/ct/re_run_aba_2023.py
0 → 100644
Pyspark_job/ct/re_run_aba_2024.py
0 → 100644
Pyspark_job/ct/spark_pg2pg.py
0 → 100644
Pyspark_job/ct/test.py
0 → 100644
Pyspark_job/ct/test1.py
0 → 100644
Pyspark_job/ct/test2.py
0 → 100644
Pyspark_job/ct/test_translate.py
0 → 100644
Pyspark_job/ct/test_udf.py
0 → 100644
Pyspark_job/ct/test_vertify.py
0 → 100644
Pyspark_job/ct/test_word_tokenize.py
0 → 100644
Pyspark_job/ct/us_st_keepa_syn_2024.py
0 → 100644
Pyspark_job/ct/verify_rank.py
0 → 100644
Pyspark_job/datahub_script/__init__.py
0 → 100644
Pyspark_job/datahub_script/dim_asin_label.py
0 → 100644
Pyspark_job/datahub_script/dim_brand_info.py
0 → 100644
Pyspark_job/demo_sqoop/__init__.py
0 → 100644
Pyspark_job/demo_sqoop/export_aba_4_week.sh
0 → 100644
Pyspark_job/demo_sqoop/export_dwt_st_info.py
0 → 100644
Pyspark_job/demo_sqoop/export_st_info.py
0 → 100644
Pyspark_job/demo_sqoop/export_st_info.sh
0 → 100644
Pyspark_job/demo_sqoop/templates_mysql.py
0 → 100644
Pyspark_job/dim/__init__.py
0 → 100644
Pyspark_job/dim/dim_asin_amorders_info.py
0 → 100644
Pyspark_job/dim/dim_asin_bs_category.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_asin_bs_category_desc.py
0 → 100644
Pyspark_job/dim/dim_asin_bs_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_asin_buy_data.py
0 → 100644
Pyspark_job/dim/dim_asin_detail.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_asin_err_state.py
0 → 100644
Pyspark_job/dim/dim_asin_history_info.py
0 → 100644
Pyspark_job/dim/dim_asin_image_info.py
0 → 100644
Pyspark_job/dim/dim_asin_img_info.py
0 → 100644
Pyspark_job/dim/dim_asin_img_info_old.py
0 → 100644
Pyspark_job/dim/dim_asin_img_path.py
0 → 100644
Pyspark_job/dim/dim_asin_label.py
0 → 100644
Pyspark_job/dim/dim_asin_launchtime_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_asin_stable_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_asin_stable_info_old.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_asin_title_info.py
0 → 100644
Pyspark_job/dim/dim_asin_title_info_old.py
0 → 100644
Pyspark_job/dim/dim_asin_title_parse.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_asin_variation_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_asin_volume.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_asin_volume_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_asin_weight_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_bs_asin_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_bs_detail.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_bsr_asin_rank_history.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_bsr_category_tree.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_cal_asin_truncate.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_category_desc_id.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_fd_asin_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_m_word_frequency.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_nsr_asin_rank_history.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_nsr_category_tree.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_profit_config.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_seller_asin_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_st_asin_detail.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_st_asin_history_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_st_asin_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_st_brand_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_st_detail.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_st_detail_old.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dim/dim_st_year_week.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_all_syn_asin.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_amazon_report.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_asin_and_st_counts.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_asin_title_number.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_asin_to_pg.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_asin_variat.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_bsr_asin_rank.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_bulk_market.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_buyer_st.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_day_asin.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_feedback.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_merchantwords_measure.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_nsr_asin_rank.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_st_asin_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_st_asin_measure.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_st_asin_measure_new.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_st_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_st_info_day.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_st_info_day_word.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_st_volume_fba.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_st_volume_fba_old.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwd/dwd_title_matching_degree.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dws/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dws/dws_aba_st_analytics_day.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/dws/dws_st_brand_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dws/dws_st_num_stats.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dws/dws_st_theme.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dws/dws_top100_asin_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_aba_analytics_temp.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_aba_keyword_analytics.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_aba_last365.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_aba_last_change_rate.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_aba_st_analytics.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_aba_year_week.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_amazon_report.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_asin_title_history.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_brand_st_top3_asin.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_bsr_asin_detail.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_bsr_asin_detail_all.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_bulk_market.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_bulk_market_pg.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_fb_base_report.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_fb_category_report.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_fb_top20_asin_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_fd_category_agg.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_flow_asin.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_keepa_asin_bsr_rank.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_merchantwords_merge.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_nsr_asin_detail.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_nsr_asin_detail_all.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_st_asin_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_st_asin_measure_new.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_st_asin_reverse.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_st_base_report.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_st_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_st_market.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_st_pcp_current.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_st_sv_last365.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_st_theme_agg.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_st_top_asin_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_theme_bs_orders.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_theme_bsr_orders_new.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_theme_st_asin.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_title_matching_degree.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_top100.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/dwt/dwt_zr_asin_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/es_handle/es_update_with_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/export_es/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/export_es/es_flow_asin.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/export_other/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/export_other/self_asin_redis.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/auto_index.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/autofaiss_use.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/create_index.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/create_parquet.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/extract.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/extract_features.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/flask_test_file.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/get_pics_to_h7.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/image_flask_api.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/image_hdfs_index.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/img_dwd_id_index.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/img_hdfs_index.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/pictures_search.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/search.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/search_01.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/search_02.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/search_data.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/temu_search.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/image_search/vgg_model.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/listen_program/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/listen_program/listen_program.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/my_kafka/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/my_kafka/add_fileds.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/my_kafka/get_redis_data.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/my_kafka/kafka_asin_detail.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/my_kafka/kafka_test.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/my_kafka/keyword_pcp_listener.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/my_kafka/spider_asin_detail.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/my_kafka/spider_asin_image.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/my_kafka/spider_asin_search.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/ods/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/ods/ods_brand_analytics.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/ods/ods_import.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/ods/ods_st_key.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/ods/ods_st_type_move.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/orc存储格式.txt
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/requirements.txt
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/script/asin_img_parse_sender.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/asin_img_parse_server.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/auto_desploy.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/bsr_nsr_day_check.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/bsr_nsr_recalc.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/bsr_rank_recalc.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/check_hadoop_part.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/export_asin_desc.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/script/export_title_tmp.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/script/hadoop_health_check.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/keyword_check.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/match_test.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/match_test01.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/match_test02.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/pg14_to_pg6.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/post_to_dolphin.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/re-run.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/rerun_demo.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/rerun_dim_st_detail.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/rerun_dwt_flow_asin.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/site_search_term.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/script/test.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/test_match.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/test_np.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/script/tmp_recalc.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/tmp_recalc_bsr.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/update_st_keepa_syn.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/us_asin_image_copy2.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/us_st_keepa_syn_2023.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/usr_mask_update.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/script/其他脚本
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sparkTest/Main_test.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sparkTest/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sparkTest/sql_export_csv.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sparkTest/test_array.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sparkTest/test_df.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sparkTest/test_export_es.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sparkTest/test_pivot.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sparkTest/test_read_hive.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sparkTest/test_udf.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sparkTest/tmp.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_ct/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_ct/asin_state.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_ct/st_2110_2208_in.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_ct/st_2110_2208_out.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_ct/st_2209_2303_in.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_ct/st_2209_2303_out.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_ct/test.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_ct/test_import.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_ct/test_utils.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_ct/us_asin_image_pg14.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_ct/z_asin_state_copy.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_ct/z_de_asin_image.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_ct/z_us_asin_image.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_ct/z_us_st_year_week.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_export/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_export/aba_report_tmp.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_export/dim_st_year_week.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_export/dwd_all_syn_asin.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_export/dwd_asin_to_pg.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_export/dwd_buyer_st_pg.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_export/dwd_day_asin.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_export/dwd_st_to_pg.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_export/dws_st_theme.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_export/dwt_aba_last365.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_export/dwt_fb_asin_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_export/dwt_st_market_pg.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_export/dwt_st_theme_agg.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_export/export_template.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_export/ods_st_key_to_pg.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_export/导出脚本
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_import/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_import/import_template.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_import/ods_adv_keyword.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_import/ods_asin_detail.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_import/ods_asin_image.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_import/ods_asin_variat.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_import/ods_asin_weight.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_import/ods_bs_category.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_import/ods_bsr_end.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_import/ods_bulk_market.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_import/ods_rank_flow.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_import/ods_self_asin.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_import/ods_theme.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_import/导入脚本
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_py/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_py/aba_365_recalc.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_py/aba_old_month.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_py/dwd_st_volume_fba.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_py/dwt_aba_last365.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_py/dwt_aba_st_analytics.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_py/dwt_st_base_report.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_py/dwt_st_market_pg.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_py/dwt_st_sv_last365.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_py/export_dwd_feedback.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_py/export_template.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/sqoop_py/此文件夹废弃
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/amazon_bsr_selection.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/ao_check.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/asin_brand.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/asin_find_bsr.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/asin_find_st.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/avg_volume_prive_weight.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/clean_data/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/clean_data/clean_weight.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/comment_analytics.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/delete_dir.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/derby.log
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/dim/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/dim/dim_st_detail.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/dim_st_detail_old.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/dwd/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/dwd/dwd_st_asin_measure.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/dwd_st_asin_info_new.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/dwd_st_asin_measure_old.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/dwt_st_info.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/es_aba_base_year.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/es_asin_detail.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/es_brand_analytics.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/es_st_detail.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/export_st_rank_to_pg.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/faiss_search.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/get_us_asin.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/hivedb_to_bighive.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/import_rank_repeat.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/kafka_test.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/kafka_test2.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/keepa_test.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/db.lck
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/log/log.ctrl
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/log/log1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c10.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c101.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c111.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c121.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c130.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c141.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c150.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c161.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c171.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c180.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c191.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c1a1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c1b1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c1c0.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c1d1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c1e0.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c1f1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c20.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c200.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c211.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c221.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c230.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c241.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c251.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c260.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c271.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c281.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c290.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c2a1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c2b1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c2c1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c2d0.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c2e1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c2f0.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c300.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c31.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c311.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c321.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c331.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c340.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c351.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c361.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c371.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c380.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c391.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c3a1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c3b1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c3c0.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c3d1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c3e1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c3f1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c400.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c41.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c411.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c421.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c430.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c441.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c451.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c461.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c470.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c481.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c490.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c4a1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c4b0.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c4c1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c4d1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c4e1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c4f0.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c501.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c51.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c510.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c521.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c530.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c541.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c550.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c561.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c570.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c581.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c590.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c5a1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c5b0.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c5c1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c5d0.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c5e1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c5f0.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c60.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c601.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c610.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c621.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c630.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c641.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c650.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c661.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c670.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c681.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c690.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c6a1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c6b0.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c6c1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c6d0.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c6e1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c6f0.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c701.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c71.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c711.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c721.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c731.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c741.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c751.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c761.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c771.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c781.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c791.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c7a1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c7b1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c7c1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c7d1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c7e1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c7f1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c801.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c81.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c811.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c821.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c831.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c840.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c851.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c860.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c871.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c880.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c891.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c8a0.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c8b1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c8c1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c8d1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c8e1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c8f1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c90.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c901.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c911.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c920.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c931.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c941.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c951.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c961.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c971.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c980.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/c991.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/ca1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/cb1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/cc0.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/cd1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/ce1.dat
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/metastore_db/seg0/cf0.dat
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/minhasd.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/my_kafka/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/ods/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/ods/ods_brand_analytics.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/st_rank.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/st_rank_old_and_new.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/st_rank_to_pg.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/st_test.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/t1.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/temp_cate_brand.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/test.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/test/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/test/temu.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/test_git_branch.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/tmp_self_asin_detail.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/tmp_st_lang.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/tmp_word_frequency.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/word_extract.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/xx.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/temp/临时测试脚本
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/DolphinschedulerHelper.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/DorisHelper.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/StarRocksHelper.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/adv_doris_stream_load.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/alter_col_script.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/common_util.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/datahub_util.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/db_util.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/es_util.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/hdfs_utils.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/io_util.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/mysql_db.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/redis_utils.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/script_template.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/spark_util.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/ssh_util.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/templates.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/templates_mysql.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/templates_rerun.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/utils/utils.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/workflow/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/workflow/judge.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/workflow/monitor_export_tasks.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/yswg_utils/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Pyspark_job/yswg_utils/common_df.py
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/yswg_utils/common_udf.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This source diff could not be displayed because it is too large.
You can
view the blob
instead.
Pyspark_job/yswg_utils/readme.txt
0 → 100644
This diff is collapsed.
Click to expand it.
Pyspark_job/yswg_utils/udf_util.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/comment_analytics/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
py_gpt/app/config.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/context.py
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
py_gpt/app/image_parse/ImageRecognized.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/image_parse/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/image_parse/requirements.txt
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/image_parse/start_documents.txt
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/log.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/main.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/models/Resp.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/models/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/models/asin_comment.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/routes/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/routes/ai.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/routes/comment_api.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/routes/exception.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/routes/index.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/routes/log_list.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/static/script.js
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/static/style.css
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
py_gpt/app/templates/log_list.html
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/templates/message.html
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/util/__init__.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/util/common_util.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/app/util/openai_session.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/desploy.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/gunicorn.conf.py
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/gunicorn.pid
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/requirements.txt
0 → 100644
This diff is collapsed.
Click to expand it.
py_gpt/script/run.sh
0 → 100644
This diff is collapsed.
Click to expand it.
run_shell/es_shell/es_brand_analytics.sh
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
run_shell/sqoop_shell/templates.sh
0 → 100644
This diff is collapsed.
Click to expand it.
run_shell/workflow_shell/dwd_asin_to_pg.sh
0 → 100644
This diff is collapsed.
Click to expand it.
run_shell/workflow_shell/test.sh
0 → 100644
This diff is collapsed.
Click to expand it.
sqoop_plugin/pom.xml
0 → 100644
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
This diff is collapsed.
Click to expand it.
Please
register
or
sign in
to comment