· 8 years ago · May 28, 2018, 09:52 AM
1drop table "cabinet"."aggregate_event_fact";
2CREATE TABLE IF NOT EXISTS "cabinet"."aggregate_event_fact" (
3 "ad_campaign_id" LONG,
4 "ad_campaign_type" STRING,
5 "ad_city_id" INTEGER,
6 "ad_clicks" DOUBLE,
7 "ad_conversions" DOUBLE,
8 "ad_cost" DOUBLE,
9 "ad_country_id" INTEGER,
10 "ad_device_type" STRING,
11 "ad_group_id" LONG,
12 "ad_id" LONG,
13 "ad_impressions" DOUBLE,
14 "ad_phrase" STRING,
15 "ad_phrase_id" LONG,
16 "ad_position" INTEGER,
17 "ad_provider_id" STRING,
18 "ad_provider_region_id" INTEGER,
19 "ad_region_id" INTEGER,
20 "ad_source" STRING,
21 "ad_source_type" STRING,
22 "advertiser_approved" INTEGER,
23 "advertiser_id" INTEGER,
24 "advertiser_pending" INTEGER,
25 "advertiser_rejected" INTEGER,
26 "aff_sub1" STRING,
27 "aff_sub2" STRING,
28 "aff_sub3" STRING,
29 "aff_sub4" STRING,
30 "aff_sub5" STRING,
31 "affiliate_approved" INTEGER,
32 "affiliate_employee_id" INTEGER,
33 "affiliate_id" INTEGER,
34 "affiliate_pending" INTEGER,
35 "affiliate_rejected" INTEGER,
36 "browser_app" STRING,
37 "browser_device" STRING,
38 "browser_format" STRING,
39 "browser_type" STRING,
40 "city_id" INTEGER,
41 "click_id" STRING,
42 "clicks_total" INTEGER,
43 "clicks_unique" INTEGER,
44 "conversion_approved" INTEGER,
45 "conversion_id" LONG,
46 "conversion_pending" INTEGER,
47 "conversion_rejected" INTEGER,
48 "conversion_source" STRING,
49 "conversion_total" INTEGER,
50 "country_id" INTEGER,
51 "current_affiliate_employee_id" INTEGER,
52 "default_payout" DOUBLE,
53 "default_revenue" DOUBLE,
54 "device_type" STRING,
55 "domain" STRING,
56 "event_http_host" STRING,
57 "file_id" INTEGER,
58 "file_type" STRING,
59 "goal_id" INTEGER,
60 "has_personal_payout" INTEGER,
61 "hour" TIMESTAMP,
62 "http_host" STRING,
63 "id" LONG,
64 "ip_addr" STRING,
65 "is_test" INTEGER,
66 "is_unique_conversion" INTEGER,
67 "keyword" STRING,
68 "lead_id" LONG,
69 "lead_offer_id" INTEGER,
70 "lead_total" INTEGER,
71 "offer_employee_id" INTEGER,
72 "offer_id" INTEGER,
73 "offer_url_id" INTEGER,
74 "os" STRING,
75 "os_company" STRING,
76 "os_description" STRING,
77 "os_family" STRING,
78 "os_name" STRING,
79 "payout" DOUBLE,
80 "platform_id" INTEGER,
81 "preoffer_url_id" INTEGER,
82 "protocol_type" STRING,
83 "referrer" STRING,
84 "region_id" INTEGER,
85 "revenue" DOUBLE,
86 "rotator_id" INTEGER,
87 "row_type" STRING,
88 "search_engine" STRING,
89 "source" STRING,
90 "status" STRING,
91 "status_advertiser" STRING,
92 "status_affiliate" STRING,
93 "sys_sub1" STRING,
94 "sys_sub2" STRING,
95 "sys_sub3" STRING,
96 "sys_sub4" STRING,
97 "sys_sub5" STRING,
98 "ua_company" STRING,
99 "ua_family" STRING,
100 "ua_major_version" STRING,
101 "ua_name" STRING,
102 "ua_version" STRING,
103 "user_agent" STRING,
104 "utm_campaign" STRING,
105 "utm_content" STRING,
106 "utm_medium" STRING,
107 "utm_referrer" STRING,
108 "utm_source" STRING,
109 "utm_term" STRING,
110 "valuta_id" INTEGER,
111 "valuta_payout" DOUBLE,
112 "valuta_rate_id" INTEGER,
113 "valuta_revenue" DOUBLE,
114 "views_total" INTEGER,
115 "views_unique" INTEGER,
116 PRIMARY KEY ("id")
117)
118CLUSTERED BY ("id") INTO 4 SHARDS
119WITH (
120 "allocation.max_retries" = 5,
121 "blocks.metadata" = false,
122 "blocks.read" = false,
123 "blocks.read_only" = false,
124 "blocks.write" = false,
125 column_policy = 'strict',
126 "mapping.total_fields.limit" = 1000,
127 number_of_replicas = '0',
128 "recovery.initial_shards" = 'quorum',
129 refresh_interval = 1000,
130 "routing.allocation.enable" = 'all',
131 "routing.allocation.total_shards_per_node" = -1,
132 "translog.durability" = 'REQUEST',
133 "translog.flush_threshold_size" = 536870912,
134 "translog.sync_interval" = 5000,
135 "unassigned.node_left.delayed_timeout" = 60000,
136 "warmer.enabled" = true,
137 "write.wait_for_active_shards" = 'all'
138)