8xpeRUHJ

1create table if not exists secure_developer_platform.kafka_hp_srlog_logstash_uberinternal_com_access_nodedup
2(dc STRING,
3hadoop_data_source STRING,
4hadoop_datacenter STRING,
5hadoop_host STRING,
6hadoop_ref_key_version INT,
7hadoop_ref_key BIGINT,
8hadoop_row_key STRING,
9hadoop_timestamp BIGINT,
10host STRING,
11level STRING,
12msg_app STRING,
13msg_bytes_sent BIGINT,
14msg_cert_cn STRING,
15msg_cert_serial STRING,
16msg_cert_validate STRING,
17msg_host STRING,
18msg_http_method STRING,
19msg_http_ver STRING,
20msg_meta MAP(STRING, STRING),
21msg_raw STRING,
22msg_referer STRING,
23msg_remote_ip STRING,
24msg_remote_user STRING,
25msg_request_headers STRING,
26msg_request_time DOUBLE,
27msg_response_time DOUBLE,
28msg_statuscode STRING,
29msg_ts BIGINT,
30msg_uri STRING
31msg_useragent STRING,
32offset_msg BIGINT,
33schema_id INT,
34ts DOUBLE,
35uuid STRING)
36
37PARTITIONED BY
38(hadoop_row_partition_datetime_str STRING)