فهرست منبع

feat(manual/trd): 订单全量 re-init 中转表 DDL(dump0722)

内部表 91 STRING 字段 + dt 分区 + ORC,对齐 raw_inc;供全量 dump 落地、ODS 重灌后 DROP。

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
tianyu.chu 2 هفته پیش
والد
کامیت
40731a791b
1فایلهای تغییر یافته به همراه36 افزوده شده و 0 حذف شده
  1. 36 0
      manual/ddl/raw/trd/tmp_trd_card_group_order_info_dump0722_create.sql

+ 36 - 0
manual/ddl/raw/trd/tmp_trd_card_group_order_info_dump0722_create.sql

@@ -0,0 +1,36 @@
+-- 作者:tianyu.chu
+-- 日期:2026-07-22
+-- 工单:(无)
+-- 目的:全量 re-init 中转表——落 PG 全表当前态(dt=20260722),供 ODS 活动日重灌后可 DROP
+-- 状态:[待执行]
+-- 生命周期:建表 → DataX 灌 dt=20260722(无边界全表当前态)→ ODS 读 WHERE dt='20260722' 重灌
+--           → 重灌并和 PG 验平后 DROP TABLE(内部表连数据一起清)
+-- 备注:内部表(managed),DROP 自动清 HDFS 无需 hdfs rm;91 字段全 STRING,对齐 raw_trd_card_group_order_info_inc_d;
+--       分区由 datax-hive-import-starter 预建(ALTER ADD PARTITION,见 dw_base/datax/partition.py),无需 MSCK。
+
+DROP TABLE IF EXISTS raw.tmp_trd_card_group_order_info_dump0722;
+
+CREATE TABLE IF NOT EXISTS raw.tmp_trd_card_group_order_info_dump0722 (
+    id STRING, group_info_id STRING, merchant_id STRING, user_id STRING, shipping_address_id STRING,
+    purchase_count STRING, order_no STRING, accounts_payable STRING, actual_payment STRING, payment_type STRING,
+    payment_time STRING, coupon STRING, discount STRING, status STRING, remark STRING,
+    create_time STRING, create_by STRING, update_time STRING, update_by STRING, payment_status STRING,
+    payment_status_desc STRING, payment_success_time STRING, del_flg STRING, curier_company STRING, refund_fee STRING,
+    refund_time STRING, anonymous STRING, pick_up_type STRING, ship_time STRING, refund_success_time STRING,
+    refund_recv_accout STRING, refund_account STRING, refund_request_source STRING, card_price STRING, act_price STRING,
+    goods_price_json STRING, payment_sub_type STRING, team_first STRING, refuse_status STRING, prop1 STRING,
+    prop2 STRING, prop3 STRING, point STRING, order_type STRING, trade_amount STRING,
+    refund_type STRING, refund_reason STRING, evaluation STRING, user_refund_time STRING, refund_status STRING,
+    merchant_refund_reason STRING, point_deduct STRING, shipping_cost STRING, merchant_remark STRING, pay_record STRING,
+    order_sub_type STRING, give_user_code STRING, give_order_id STRING, read_flag STRING, give_num STRING,
+    invoice_id STRING, combination_no STRING, open_self STRING, refund_desc STRING, goods_allocate STRING,
+    close_payment_status STRING, close_payment_time STRING, finished_time STRING, expire_time STRING, settlement_amount STRING,
+    platform_coupon STRING, platform_discount STRING, discount_amount STRING, member_discount STRING, shipping_free_id STRING,
+    shipping_free_amount STRING, discount_point STRING, un_shipped_num STRING, pre_un_shipped_num STRING, wait_shipped_num STRING,
+    pre_wait_shipped_num STRING, refuse_time STRING, refuse_notice STRING, pickup_time STRING, waring_type STRING,
+    waring_status STRING, point_type STRING, delivery_end_time STRING, serve_status STRING, self_pickup_time STRING,
+    act_discount STRING
+)
+COMMENT '订单全量 re-init 一次性中转表(dt=20260722 全表当前态),ODS 重灌验平后 DROP'
+PARTITIONED BY (dt STRING)
+STORED AS ORC;