hive_raw_es.sql 861 B

12345678910111213141516171819202122
  1. -- 埋点 raw 层(ES SparkSQL 直读路径冒烟)
  2. -- 表结构:顶层 11 列全 STRING;lib / properties 嵌套整层 to_json 存字符串
  3. -- 不展开嵌套字段——避免随事件类型 / SDK 升级带来 schema 漂移;解析延后到 ods
  4. -- 临时表名 _es 后缀,与现有单字段表 test.raw_usr_traces_apd_d 并存
  5. CREATE EXTERNAL TABLE IF NOT EXISTS test.raw_usr_traces_apd_d_es (
  6. _class STRING,
  7. anonymousId STRING,
  8. distinctId STRING,
  9. event STRING,
  10. flushTime STRING,
  11. lib STRING,
  12. loginId STRING,
  13. productInstock STRING,
  14. properties STRING,
  15. `time` STRING,
  16. type STRING
  17. )
  18. COMMENT '埋点贴源表(ES SparkSQL 直读冒烟,11 列 STRING,嵌套字段 JSON 字符串)'
  19. PARTITIONED BY (dt STRING COMMENT 'yyyymmdd')
  20. STORED AS ORC
  21. LOCATION '/user/hive/warehouse/test.db/raw_usr_traces_apd_d_es';