建表映射slow query
CREATE EXTERNAL TABLE IF NOT EXISTS slow_query_logs (
  `id` BIGINT,
  `time` DOUBLE,
  `digest` STRING,
  `instance` STRING,
  `txn_start_ts` STRING,
  `user` STRING,
  `host` STRING,
  `conn_id` STRING,
  `session_alias` STRING,
  `exec_retry_count` STRING,
  `exec_retry_time` DOUBLE,
  `query_time` DOUBLE,
  `parse_time` DOUBLE,
  `compile_time` DOUBLE,
  `rewrite_time` DOUBLE,
  `preproc_subqueries` STRING,
  `preproc_subqueries_time` DOUBLE,
  `optimize_time` DOUBLE,
  `wait_ts` DOUBLE,
  `prewrite_time` DOUBLE,
  `wait_prewrite_binlog_time` DOUBLE,
  `commit_time` DOUBLE,
  `get_commit_ts_time` DOUBLE,
  `commit_backoff_time` DOUBLE,
  `backoff_types` STRING,
  `resolve_lock_time` DOUBLE,
  `local_latch_wait_time` DOUBLE,
  `write_keys` BIGINT,
  `write_size` BIGINT,
  `prewrite_region` BIGINT,
  `txn_retry` BIGINT,
  `cop_time` DOUBLE,
  `process_time` DOUBLE,
  `wait_time` DOUBLE,
  `backoff_time` DOUBLE,
  `lockkeys_time` DOUBLE,
  `request_count` STRING,
  `total_keys` STRING,
  `process_keys` STRING,
  `rocksdb_delete_skipped_count` STRING,
  `rocksdb_key_skipped_count` STRING,
  `rocksdb_block_cache_hit_count` STRING,
  `rocksdb_block_read_count` STRING,
  `rocksdb_block_read_byte` STRING,
  `db` STRING,
  `index_names` STRING,
  `is_internal` BOOLEAN,
  `stats` STRING,
  `cop_proc_avg` DOUBLE,
  `cop_proc_p90` DOUBLE,
  `cop_proc_max` DOUBLE,
  `cop_proc_addr` STRING,
  `cop_wait_avg` DOUBLE,
  `cop_wait_p90` DOUBLE,
  `cop_wait_max` DOUBLE,
  `cop_wait_addr` STRING,
  `mem_max` BIGINT,
  `disk_max` BIGINT,
  `kv_total` DOUBLE,
  `pd_total` DOUBLE,
  `backoff_total` DOUBLE,
  `write_sql_response_total` DOUBLE,
  `result_rows` BIGINT,
  `warnings` STRING,
  `backoff_detail` STRING,
  `prepared` BOOLEAN,
  `succ` BOOLEAN,
  `is_explicit_txn` BOOLEAN,
  `is_write_cache_table` BOOLEAN,
  `plan_from_cache` BOOLEAN,
  `plan_from_binding` BOOLEAN,
  `has_more_results` BOOLEAN,
  `resource_group` STRING,
  `request_unit_read` DOUBLE,
  `request_unit_write` DOUBLE,
  `time_queued_by_rc` DOUBLE,
  `plan_digest` STRING,
  `prev_stmt` STRING,
  `serverless_tenant_id` STRING,
  `serverless_project_id` STRING,
  `serverless_cluster_id` STRING,
  `worker_role` STRING,
  `is_tiflash` BOOLEAN,
  `query` STRING,
  `binary_plan` STRING,
  `plan` STRING,
  `decoded_plan` STRING
)
PARTITIONED BY (`date` STRING)
ROW FORMAT SERDE 'org.apache.hadoop.hive.ql.io.parquet.serde.ParquetHiveSerDe'
STORED AS INPUTFORMAT 'org.apache.hadoop.hive.ql.io.parquet.MapredParquetInputFormat'
OUTPUTFORMAT 'org.apache.hadoop.hive.ql.io.parquet.MapredParquetOutputFormat'
LOCATION 's3://o11y-prod-shared-ap-southeast-1/deltalake/1372813089209238420/11e824de-880e-4d20-8883-7a90e1b52d0e/slowlogs/'
TBLPROPERTIES (
  'parquet.compress'='ZSTD',
  'classification'='parquet'
);



添加分区
ALTER TABLE slow_query_org_1369847559691397282 
ADD IF NOT EXISTS PARTITION (
    cluster='10161159396122522375',
    instance='db-tikv-2.db-tikv-peer.tidb10161159396122522375.svc:20160',
    dt='2026-02-10'
)
LOCATION 's3://o11y-test-shared-us-west-2-staging/deltalake/org=1369847559691397282/cluster=10161159396122522375/type=topsql_tikv/instance=db-tikv-2.db-tikv-peer.tidb10161159396122522375.svc:20160/';