ref(migrations): squash some eap migrations#7730
Draft
MeredithAnya wants to merge 2 commits intomasterfrom
Draft
ref(migrations): squash some eap migrations#7730MeredithAnya wants to merge 2 commits intomasterfrom
MeredithAnya wants to merge 2 commits intomasterfrom
Conversation
MeredithAnya
force-pushed
the
meredith/squash-eap-migrations
branch
from
805db5f to
d42e5f2
Compare
|
This PR has a migration; here is the generated SQL for -- start migrations
-- forward migration events_analytics_platform : 0001_spans
-- end forward migration events_analytics_platform : 0001_spans
-- backward migration events_analytics_platform : 0001_spans
-- end backward migration events_analytics_platform : 0001_spans
-- forward migration events_analytics_platform : 0002_spans_attributes_mv
-- end forward migration events_analytics_platform : 0002_spans_attributes_mv
-- backward migration events_analytics_platform : 0002_spans_attributes_mv
-- end backward migration events_analytics_platform : 0002_spans_attributes_mv
-- forward migration events_analytics_platform : 0003_eap_spans_project_id_index
-- end forward migration events_analytics_platform : 0003_eap_spans_project_id_index
-- backward migration events_analytics_platform : 0003_eap_spans_project_id_index
-- end backward migration events_analytics_platform : 0003_eap_spans_project_id_index
-- forward migration events_analytics_platform : 0004_modify_sampling_weight
-- end forward migration events_analytics_platform : 0004_modify_sampling_weight
-- backward migration events_analytics_platform : 0004_modify_sampling_weight
-- end backward migration events_analytics_platform : 0004_modify_sampling_weight
-- forward migration events_analytics_platform : 0005_remove_attribute_mv
-- end forward migration events_analytics_platform : 0005_remove_attribute_mv
-- backward migration events_analytics_platform : 0005_remove_attribute_mv
-- end backward migration events_analytics_platform : 0005_remove_attribute_mv
-- forward migration events_analytics_platform : 0006_drop_attribute_key_project_id_indexes
-- end forward migration events_analytics_platform : 0006_drop_attribute_key_project_id_indexes
-- backward migration events_analytics_platform : 0006_drop_attribute_key_project_id_indexes
-- end backward migration events_analytics_platform : 0006_drop_attribute_key_project_id_indexes
-- forward migration events_analytics_platform : 0007_drop_project_id_index
-- end forward migration events_analytics_platform : 0007_drop_project_id_index
-- backward migration events_analytics_platform : 0007_drop_project_id_index
-- end backward migration events_analytics_platform : 0007_drop_project_id_index
-- forward migration events_analytics_platform : 0008_drop_index_attribute_key_bucket_0
-- end forward migration events_analytics_platform : 0008_drop_index_attribute_key_bucket_0
-- backward migration events_analytics_platform : 0008_drop_index_attribute_key_bucket_0
-- end backward migration events_analytics_platform : 0008_drop_index_attribute_key_bucket_0
-- forward migration events_analytics_platform : 0009_drop_index_attribute_key_buckets_1_19
-- end forward migration events_analytics_platform : 0009_drop_index_attribute_key_buckets_1_19
-- backward migration events_analytics_platform : 0009_drop_index_attribute_key_buckets_1_19
-- end backward migration events_analytics_platform : 0009_drop_index_attribute_key_buckets_1_19
-- forward migration events_analytics_platform : 0010_drop_indexes_on_attribute_values
-- end forward migration events_analytics_platform : 0010_drop_indexes_on_attribute_values
-- backward migration events_analytics_platform : 0010_drop_indexes_on_attribute_values
-- end backward migration events_analytics_platform : 0010_drop_indexes_on_attribute_values
-- forward migration events_analytics_platform : 0011_span_attribute_table
-- end forward migration events_analytics_platform : 0011_span_attribute_table
-- backward migration events_analytics_platform : 0011_span_attribute_table
-- end backward migration events_analytics_platform : 0011_span_attribute_table
-- forward migration events_analytics_platform : 0012_span_attribute_table_numeric
-- end forward migration events_analytics_platform : 0012_span_attribute_table_numeric
-- backward migration events_analytics_platform : 0012_span_attribute_table_numeric
-- end backward migration events_analytics_platform : 0012_span_attribute_table_numeric
-- forward migration events_analytics_platform : 0013_span_attribute_table_shard_keys
-- end forward migration events_analytics_platform : 0013_span_attribute_table_shard_keys
-- backward migration events_analytics_platform : 0013_span_attribute_table_shard_keys
-- end backward migration events_analytics_platform : 0013_span_attribute_table_shard_keys
-- forward migration events_analytics_platform : 0014_span_attribute_table_smaller
-- end forward migration events_analytics_platform : 0014_span_attribute_table_smaller
-- backward migration events_analytics_platform : 0014_span_attribute_table_smaller
-- end backward migration events_analytics_platform : 0014_span_attribute_table_smaller
-- forward migration events_analytics_platform : 0015_span_attribute_table_namespaced
-- end forward migration events_analytics_platform : 0015_span_attribute_table_namespaced
-- backward migration events_analytics_platform : 0015_span_attribute_table_namespaced
-- end backward migration events_analytics_platform : 0015_span_attribute_table_namespaced
-- forward migration events_analytics_platform : 0016_spans_v2
-- end forward migration events_analytics_platform : 0016_spans_v2
-- backward migration events_analytics_platform : 0016_spans_v2
-- end backward migration events_analytics_platform : 0016_spans_v2
-- forward migration events_analytics_platform : 0017_span_attribute_table_v3
-- end forward migration events_analytics_platform : 0017_span_attribute_table_v3
-- backward migration events_analytics_platform : 0017_span_attribute_table_v3
-- end backward migration events_analytics_platform : 0017_span_attribute_table_v3
-- forward migration events_analytics_platform : 0018_drop_unused_span_tables
-- end forward migration events_analytics_platform : 0018_drop_unused_span_tables
-- backward migration events_analytics_platform : 0018_drop_unused_span_tables
-- end backward migration events_analytics_platform : 0018_drop_unused_span_tables
-- forward migration events_analytics_platform : 0019_uptime_monitors_init
-- end forward migration events_analytics_platform : 0019_uptime_monitors_init
-- backward migration events_analytics_platform : 0019_uptime_monitors_init
-- end backward migration events_analytics_platform : 0019_uptime_monitors_init
-- forward migration events_analytics_platform : 0020_ourlogs_init
-- end forward migration events_analytics_platform : 0020_ourlogs_init
-- backward migration events_analytics_platform : 0020_ourlogs_init
-- end backward migration events_analytics_platform : 0020_ourlogs_init
-- forward migration events_analytics_platform : 0021_ourlogs_attrs
-- end forward migration events_analytics_platform : 0021_ourlogs_attrs
-- backward migration events_analytics_platform : 0021_ourlogs_attrs
-- end backward migration events_analytics_platform : 0021_ourlogs_attrs
-- forward migration events_analytics_platform : 0022_uptime_monitors_init_v2
-- end forward migration events_analytics_platform : 0022_uptime_monitors_init_v2
-- backward migration events_analytics_platform : 0022_uptime_monitors_init_v2
-- end backward migration events_analytics_platform : 0022_uptime_monitors_init_v2
-- forward migration events_analytics_platform : 0023_smart_autocomplete_mv
-- end forward migration events_analytics_platform : 0023_smart_autocomplete_mv
-- backward migration events_analytics_platform : 0023_smart_autocomplete_mv
-- end backward migration events_analytics_platform : 0023_smart_autocomplete_mv
-- forward migration events_analytics_platform : 0025_smart_autocomplete_index
-- end forward migration events_analytics_platform : 0025_smart_autocomplete_index
-- backward migration events_analytics_platform : 0025_smart_autocomplete_index
-- end backward migration events_analytics_platform : 0025_smart_autocomplete_index
-- forward migration events_analytics_platform : 0026_items_add_attributes_hash_map
-- end forward migration events_analytics_platform : 0026_items_add_attributes_hash_map
-- backward migration events_analytics_platform : 0026_items_add_attributes_hash_map
-- end backward migration events_analytics_platform : 0026_items_add_attributes_hash_map
-- forward migration events_analytics_platform : 0027_uptime_checks_add_column_in_incident
-- end forward migration events_analytics_platform : 0027_uptime_checks_add_column_in_incident
-- backward migration events_analytics_platform : 0027_uptime_checks_add_column_in_incident
-- end backward migration events_analytics_platform : 0027_uptime_checks_add_column_in_incident
-- forward migration events_analytics_platform : 0028_ourlogs_v3
-- end forward migration events_analytics_platform : 0028_ourlogs_v3
-- backward migration events_analytics_platform : 0028_ourlogs_v3
-- end backward migration events_analytics_platform : 0028_ourlogs_v3
-- forward migration events_analytics_platform : 0029_remove_smart_autocomplete_experimental
-- end forward migration events_analytics_platform : 0029_remove_smart_autocomplete_experimental
-- backward migration events_analytics_platform : 0029_remove_smart_autocomplete_experimental
-- end backward migration events_analytics_platform : 0029_remove_smart_autocomplete_experimental
-- forward migration events_analytics_platform : 0033_items_attribute_table_v1
-- end forward migration events_analytics_platform : 0033_items_attribute_table_v1
-- backward migration events_analytics_platform : 0033_items_attribute_table_v1
-- end backward migration events_analytics_platform : 0033_items_attribute_table_v1
-- forward migration events_analytics_platform : 0034_materialize_sampled_storage_views
-- end forward migration events_analytics_platform : 0034_materialize_sampled_storage_views
-- backward migration events_analytics_platform : 0034_materialize_sampled_storage_views
-- end backward migration events_analytics_platform : 0034_materialize_sampled_storage_views
-- forward migration events_analytics_platform : 0035_drop_item_attrs
-- end forward migration events_analytics_platform : 0035_drop_item_attrs
-- backward migration events_analytics_platform : 0035_drop_item_attrs
-- end backward migration events_analytics_platform : 0035_drop_item_attrs
-- forward migration events_analytics_platform : 0036_items_attribute_table_v1
-- end forward migration events_analytics_platform : 0036_items_attribute_table_v1
-- backward migration events_analytics_platform : 0036_items_attribute_table_v1
-- end backward migration events_analytics_platform : 0036_items_attribute_table_v1
-- forward migration events_analytics_platform : 0037_remove_items_attribute_mv_v1
-- end forward migration events_analytics_platform : 0037_remove_items_attribute_mv_v1
-- backward migration events_analytics_platform : 0037_remove_items_attribute_mv_v1
-- end backward migration events_analytics_platform : 0037_remove_items_attribute_mv_v1
-- forward migration events_analytics_platform : 0038_eap_items_add_sampling_factor
Local op: ALTER TABLE eap_items_1_local ON CLUSTER 'cluster_one_sh' ADD COLUMN IF NOT EXISTS sampling_factor Float64 CODEC (ZSTD(1)) AFTER sampling_weight;
Distributed op: ALTER TABLE eap_items_1_dist ON CLUSTER 'cluster_one_sh' ADD COLUMN IF NOT EXISTS sampling_factor Float64 CODEC (ZSTD(1)) AFTER sampling_weight;
Local op: ALTER TABLE eap_items_1_downsample_8_local ON CLUSTER 'cluster_one_sh' ADD COLUMN IF NOT EXISTS sampling_factor Float64 CODEC (ZSTD(1)) AFTER sampling_weight;
Local op: ALTER TABLE eap_items_1_downsample_64_local ON CLUSTER 'cluster_one_sh' ADD COLUMN IF NOT EXISTS sampling_factor Float64 CODEC (ZSTD(1)) AFTER sampling_weight;
Local op: ALTER TABLE eap_items_1_downsample_512_local ON CLUSTER 'cluster_one_sh' ADD COLUMN IF NOT EXISTS sampling_factor Float64 CODEC (ZSTD(1)) AFTER sampling_weight;
-- end forward migration events_analytics_platform : 0038_eap_items_add_sampling_factor
-- backward migration events_analytics_platform : 0038_eap_items_add_sampling_factor
Distributed op: ALTER TABLE eap_items_1_dist ON CLUSTER 'cluster_one_sh' DROP COLUMN IF EXISTS sampling_factor;
Local op: ALTER TABLE eap_items_1_local ON CLUSTER 'cluster_one_sh' DROP COLUMN IF EXISTS sampling_factor;
Local op: ALTER TABLE eap_items_1_downsample_8_local ON CLUSTER 'cluster_one_sh' DROP COLUMN IF EXISTS sampling_factor;
Local op: ALTER TABLE eap_items_1_downsample_64_local ON CLUSTER 'cluster_one_sh' DROP COLUMN IF EXISTS sampling_factor;
Local op: ALTER TABLE eap_items_1_downsample_512_local ON CLUSTER 'cluster_one_sh' DROP COLUMN IF EXISTS sampling_factor;
-- end backward migration events_analytics_platform : 0038_eap_items_add_sampling_factor
-- forward migration events_analytics_platform : 0039_update_mv_with_sampling_factor
-- end forward migration events_analytics_platform : 0039_update_mv_with_sampling_factor
-- backward migration events_analytics_platform : 0039_update_mv_with_sampling_factor
-- end backward migration events_analytics_platform : 0039_update_mv_with_sampling_factor
-- forward migration events_analytics_platform : 0041_hashed_attributes_index
-- end forward migration events_analytics_platform : 0041_hashed_attributes_index
-- backward migration events_analytics_platform : 0041_hashed_attributes_index
-- end backward migration events_analytics_platform : 0041_hashed_attributes_index
-- forward migration events_analytics_platform : 0042_remove_hashed_columns
-- end forward migration events_analytics_platform : 0042_remove_hashed_columns
-- backward migration events_analytics_platform : 0042_remove_hashed_columns
-- end backward migration events_analytics_platform : 0042_remove_hashed_columns
-- forward migration events_analytics_platform : 0043_remove_hashed_keys_column
-- end forward migration events_analytics_platform : 0043_remove_hashed_keys_column
-- backward migration events_analytics_platform : 0043_remove_hashed_keys_column
-- end backward migration events_analytics_platform : 0043_remove_hashed_keys_column
-- forward migration events_analytics_platform : 0044_remove_hash_map_columns_0_4
-- end forward migration events_analytics_platform : 0044_remove_hash_map_columns_0_4
-- backward migration events_analytics_platform : 0044_remove_hash_map_columns_0_4
-- end backward migration events_analytics_platform : 0044_remove_hash_map_columns_0_4
-- forward migration events_analytics_platform : 0047_use_downsampled_retention_for_downsampled_tables
-- end forward migration events_analytics_platform : 0047_use_downsampled_retention_for_downsampled_tables
-- backward migration events_analytics_platform : 0047_use_downsampled_retention_for_downsampled_tables
-- end backward migration events_analytics_platform : 0047_use_downsampled_retention_for_downsampled_tables
-- forward migration events_analytics_platform : 0049_use_client_and_server_sample_rates_in_materialized_views
Local op: CREATE MATERIALIZED VIEW IF NOT EXISTS eap_items_1_downsample_8_mv_4 ON CLUSTER 'cluster_one_sh' TO eap_items_1_downsample_8_local (organization_id UInt64, project_id UInt64, item_type UInt8, timestamp DateTime CODEC (DoubleDelta, ZSTD(1)), trace_id UUID, item_id UInt128, sampling_weight UInt64 CODEC (ZSTD(1)), sampling_factor Float64 CODEC (ZSTD(1)), retention_days UInt16 CODEC (T64, ZSTD(1)), attributes_bool Map(String, Bool), attributes_int Map(String, Int64), attributes_string_0 Map(String, String) CODEC (ZSTD(1)), attributes_string_1 Map(String, String) CODEC (ZSTD(1)), attributes_string_2 Map(String, String) CODEC (ZSTD(1)), attributes_string_3 Map(String, String) CODEC (ZSTD(1)), attributes_string_4 Map(String, String) CODEC (ZSTD(1)), attributes_string_5 Map(String, String) CODEC (ZSTD(1)), attributes_string_6 Map(String, String) CODEC (ZSTD(1)), attributes_string_7 Map(String, String) CODEC (ZSTD(1)), attributes_string_8 Map(String, String) CODEC (ZSTD(1)), attributes_string_9 Map(String, String) CODEC (ZSTD(1)), attributes_string_10 Map(String, String) CODEC (ZSTD(1)), attributes_string_11 Map(String, String) CODEC (ZSTD(1)), attributes_string_12 Map(String, String) CODEC (ZSTD(1)), attributes_string_13 Map(String, String) CODEC (ZSTD(1)), attributes_string_14 Map(String, String) CODEC (ZSTD(1)), attributes_string_15 Map(String, String) CODEC (ZSTD(1)), attributes_string_16 Map(String, String) CODEC (ZSTD(1)), attributes_string_17 Map(String, String) CODEC (ZSTD(1)), attributes_string_18 Map(String, String) CODEC (ZSTD(1)), attributes_string_19 Map(String, String) CODEC (ZSTD(1)), attributes_string_20 Map(String, String) CODEC (ZSTD(1)), attributes_string_21 Map(String, String) CODEC (ZSTD(1)), attributes_string_22 Map(String, String) CODEC (ZSTD(1)), attributes_string_23 Map(String, String) CODEC (ZSTD(1)), attributes_string_24 Map(String, String) CODEC (ZSTD(1)), attributes_string_25 Map(String, String) CODEC (ZSTD(1)), attributes_string_26 Map(String, String) CODEC (ZSTD(1)), attributes_string_27 Map(String, String) CODEC (ZSTD(1)), attributes_string_28 Map(String, String) CODEC (ZSTD(1)), attributes_string_29 Map(String, String) CODEC (ZSTD(1)), attributes_string_30 Map(String, String) CODEC (ZSTD(1)), attributes_string_31 Map(String, String) CODEC (ZSTD(1)), attributes_string_32 Map(String, String) CODEC (ZSTD(1)), attributes_string_33 Map(String, String) CODEC (ZSTD(1)), attributes_string_34 Map(String, String) CODEC (ZSTD(1)), attributes_string_35 Map(String, String) CODEC (ZSTD(1)), attributes_string_36 Map(String, String) CODEC (ZSTD(1)), attributes_string_37 Map(String, String) CODEC (ZSTD(1)), attributes_string_38 Map(String, String) CODEC (ZSTD(1)), attributes_string_39 Map(String, String) CODEC (ZSTD(1)), attributes_float_0 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_1 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_2 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_3 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_4 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_5 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_6 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_7 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_8 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_9 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_10 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_11 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_12 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_13 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_14 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_15 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_16 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_17 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_18 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_19 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_20 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_21 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_22 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_23 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_24 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_25 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_26 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_27 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_28 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_29 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_30 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_31 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_32 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_33 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_34 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_35 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_36 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_37 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_38 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_39 Map(String, Float64) CODEC (ZSTD(1))) AS SELECT organization_id, project_id, item_type, timestamp, trace_id, item_id, attributes_bool, attributes_int, attributes_string_0, attributes_string_1, attributes_string_2, attributes_string_3, attributes_string_4, attributes_string_5, attributes_string_6, attributes_string_7, attributes_string_8, attributes_string_9, attributes_string_10, attributes_string_11, attributes_string_12, attributes_string_13, attributes_string_14, attributes_string_15, attributes_string_16, attributes_string_17, attributes_string_18, attributes_string_19, attributes_string_20, attributes_string_21, attributes_string_22, attributes_string_23, attributes_string_24, attributes_string_25, attributes_string_26, attributes_string_27, attributes_string_28, attributes_string_29, attributes_string_30, attributes_string_31, attributes_string_32, attributes_string_33, attributes_string_34, attributes_string_35, attributes_string_36, attributes_string_37, attributes_string_38, attributes_string_39, attributes_float_0, attributes_float_1, attributes_float_2, attributes_float_3, attributes_float_4, attributes_float_5, attributes_float_6, attributes_float_7, attributes_float_8, attributes_float_9, attributes_float_10, attributes_float_11, attributes_float_12, attributes_float_13, attributes_float_14, attributes_float_15, attributes_float_16, attributes_float_17, attributes_float_18, attributes_float_19, attributes_float_20, attributes_float_21, attributes_float_22, attributes_float_23, attributes_float_24, attributes_float_25, attributes_float_26, attributes_float_27, attributes_float_28, attributes_float_29, attributes_float_30, attributes_float_31, attributes_float_32, attributes_float_33, attributes_float_34, attributes_float_35, attributes_float_36, attributes_float_37, attributes_float_38, attributes_float_39, downsampled_retention_days AS retention_days, sampling_weight * 8 AS sampling_weight, sampling_factor / 8 AS sampling_factor, client_sample_rate / 8 AS client_sample_rate, server_sample_rate / 8 AS server_sample_rate FROM eap_items_1_local WHERE (cityHash64(item_id + 8) % 8) = 0;
Local op: DROP TABLE IF EXISTS eap_items_1_downsample_8_mv_3 ON CLUSTER 'cluster_one_sh' SYNC;
Local op: CREATE MATERIALIZED VIEW IF NOT EXISTS eap_items_1_downsample_64_mv_4 ON CLUSTER 'cluster_one_sh' TO eap_items_1_downsample_64_local (organization_id UInt64, project_id UInt64, item_type UInt8, timestamp DateTime CODEC (DoubleDelta, ZSTD(1)), trace_id UUID, item_id UInt128, sampling_weight UInt64 CODEC (ZSTD(1)), sampling_factor Float64 CODEC (ZSTD(1)), retention_days UInt16 CODEC (T64, ZSTD(1)), attributes_bool Map(String, Bool), attributes_int Map(String, Int64), attributes_string_0 Map(String, String) CODEC (ZSTD(1)), attributes_string_1 Map(String, String) CODEC (ZSTD(1)), attributes_string_2 Map(String, String) CODEC (ZSTD(1)), attributes_string_3 Map(String, String) CODEC (ZSTD(1)), attributes_string_4 Map(String, String) CODEC (ZSTD(1)), attributes_string_5 Map(String, String) CODEC (ZSTD(1)), attributes_string_6 Map(String, String) CODEC (ZSTD(1)), attributes_string_7 Map(String, String) CODEC (ZSTD(1)), attributes_string_8 Map(String, String) CODEC (ZSTD(1)), attributes_string_9 Map(String, String) CODEC (ZSTD(1)), attributes_string_10 Map(String, String) CODEC (ZSTD(1)), attributes_string_11 Map(String, String) CODEC (ZSTD(1)), attributes_string_12 Map(String, String) CODEC (ZSTD(1)), attributes_string_13 Map(String, String) CODEC (ZSTD(1)), attributes_string_14 Map(String, String) CODEC (ZSTD(1)), attributes_string_15 Map(String, String) CODEC (ZSTD(1)), attributes_string_16 Map(String, String) CODEC (ZSTD(1)), attributes_string_17 Map(String, String) CODEC (ZSTD(1)), attributes_string_18 Map(String, String) CODEC (ZSTD(1)), attributes_string_19 Map(String, String) CODEC (ZSTD(1)), attributes_string_20 Map(String, String) CODEC (ZSTD(1)), attributes_string_21 Map(String, String) CODEC (ZSTD(1)), attributes_string_22 Map(String, String) CODEC (ZSTD(1)), attributes_string_23 Map(String, String) CODEC (ZSTD(1)), attributes_string_24 Map(String, String) CODEC (ZSTD(1)), attributes_string_25 Map(String, String) CODEC (ZSTD(1)), attributes_string_26 Map(String, String) CODEC (ZSTD(1)), attributes_string_27 Map(String, String) CODEC (ZSTD(1)), attributes_string_28 Map(String, String) CODEC (ZSTD(1)), attributes_string_29 Map(String, String) CODEC (ZSTD(1)), attributes_string_30 Map(String, String) CODEC (ZSTD(1)), attributes_string_31 Map(String, String) CODEC (ZSTD(1)), attributes_string_32 Map(String, String) CODEC (ZSTD(1)), attributes_string_33 Map(String, String) CODEC (ZSTD(1)), attributes_string_34 Map(String, String) CODEC (ZSTD(1)), attributes_string_35 Map(String, String) CODEC (ZSTD(1)), attributes_string_36 Map(String, String) CODEC (ZSTD(1)), attributes_string_37 Map(String, String) CODEC (ZSTD(1)), attributes_string_38 Map(String, String) CODEC (ZSTD(1)), attributes_string_39 Map(String, String) CODEC (ZSTD(1)), attributes_float_0 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_1 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_2 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_3 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_4 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_5 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_6 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_7 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_8 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_9 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_10 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_11 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_12 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_13 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_14 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_15 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_16 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_17 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_18 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_19 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_20 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_21 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_22 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_23 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_24 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_25 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_26 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_27 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_28 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_29 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_30 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_31 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_32 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_33 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_34 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_35 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_36 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_37 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_38 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_39 Map(String, Float64) CODEC (ZSTD(1))) AS SELECT organization_id, project_id, item_type, timestamp, trace_id, item_id, attributes_bool, attributes_int, attributes_string_0, attributes_string_1, attributes_string_2, attributes_string_3, attributes_string_4, attributes_string_5, attributes_string_6, attributes_string_7, attributes_string_8, attributes_string_9, attributes_string_10, attributes_string_11, attributes_string_12, attributes_string_13, attributes_string_14, attributes_string_15, attributes_string_16, attributes_string_17, attributes_string_18, attributes_string_19, attributes_string_20, attributes_string_21, attributes_string_22, attributes_string_23, attributes_string_24, attributes_string_25, attributes_string_26, attributes_string_27, attributes_string_28, attributes_string_29, attributes_string_30, attributes_string_31, attributes_string_32, attributes_string_33, attributes_string_34, attributes_string_35, attributes_string_36, attributes_string_37, attributes_string_38, attributes_string_39, attributes_float_0, attributes_float_1, attributes_float_2, attributes_float_3, attributes_float_4, attributes_float_5, attributes_float_6, attributes_float_7, attributes_float_8, attributes_float_9, attributes_float_10, attributes_float_11, attributes_float_12, attributes_float_13, attributes_float_14, attributes_float_15, attributes_float_16, attributes_float_17, attributes_float_18, attributes_float_19, attributes_float_20, attributes_float_21, attributes_float_22, attributes_float_23, attributes_float_24, attributes_float_25, attributes_float_26, attributes_float_27, attributes_float_28, attributes_float_29, attributes_float_30, attributes_float_31, attributes_float_32, attributes_float_33, attributes_float_34, attributes_float_35, attributes_float_36, attributes_float_37, attributes_float_38, attributes_float_39, downsampled_retention_days AS retention_days, sampling_weight * 64 AS sampling_weight, sampling_factor / 64 AS sampling_factor, client_sample_rate / 64 AS client_sample_rate, server_sample_rate / 64 AS server_sample_rate FROM eap_items_1_local WHERE (cityHash64(item_id + 64) % 64) = 0;
Local op: DROP TABLE IF EXISTS eap_items_1_downsample_64_mv_3 ON CLUSTER 'cluster_one_sh' SYNC;
Local op: CREATE MATERIALIZED VIEW IF NOT EXISTS eap_items_1_downsample_512_mv_4 ON CLUSTER 'cluster_one_sh' TO eap_items_1_downsample_512_local (organization_id UInt64, project_id UInt64, item_type UInt8, timestamp DateTime CODEC (DoubleDelta, ZSTD(1)), trace_id UUID, item_id UInt128, sampling_weight UInt64 CODEC (ZSTD(1)), sampling_factor Float64 CODEC (ZSTD(1)), retention_days UInt16 CODEC (T64, ZSTD(1)), attributes_bool Map(String, Bool), attributes_int Map(String, Int64), attributes_string_0 Map(String, String) CODEC (ZSTD(1)), attributes_string_1 Map(String, String) CODEC (ZSTD(1)), attributes_string_2 Map(String, String) CODEC (ZSTD(1)), attributes_string_3 Map(String, String) CODEC (ZSTD(1)), attributes_string_4 Map(String, String) CODEC (ZSTD(1)), attributes_string_5 Map(String, String) CODEC (ZSTD(1)), attributes_string_6 Map(String, String) CODEC (ZSTD(1)), attributes_string_7 Map(String, String) CODEC (ZSTD(1)), attributes_string_8 Map(String, String) CODEC (ZSTD(1)), attributes_string_9 Map(String, String) CODEC (ZSTD(1)), attributes_string_10 Map(String, String) CODEC (ZSTD(1)), attributes_string_11 Map(String, String) CODEC (ZSTD(1)), attributes_string_12 Map(String, String) CODEC (ZSTD(1)), attributes_string_13 Map(String, String) CODEC (ZSTD(1)), attributes_string_14 Map(String, String) CODEC (ZSTD(1)), attributes_string_15 Map(String, String) CODEC (ZSTD(1)), attributes_string_16 Map(String, String) CODEC (ZSTD(1)), attributes_string_17 Map(String, String) CODEC (ZSTD(1)), attributes_string_18 Map(String, String) CODEC (ZSTD(1)), attributes_string_19 Map(String, String) CODEC (ZSTD(1)), attributes_string_20 Map(String, String) CODEC (ZSTD(1)), attributes_string_21 Map(String, String) CODEC (ZSTD(1)), attributes_string_22 Map(String, String) CODEC (ZSTD(1)), attributes_string_23 Map(String, String) CODEC (ZSTD(1)), attributes_string_24 Map(String, String) CODEC (ZSTD(1)), attributes_string_25 Map(String, String) CODEC (ZSTD(1)), attributes_string_26 Map(String, String) CODEC (ZSTD(1)), attributes_string_27 Map(String, String) CODEC (ZSTD(1)), attributes_string_28 Map(String, String) CODEC (ZSTD(1)), attributes_string_29 Map(String, String) CODEC (ZSTD(1)), attributes_string_30 Map(String, String) CODEC (ZSTD(1)), attributes_string_31 Map(String, String) CODEC (ZSTD(1)), attributes_string_32 Map(String, String) CODEC (ZSTD(1)), attributes_string_33 Map(String, String) CODEC (ZSTD(1)), attributes_string_34 Map(String, String) CODEC (ZSTD(1)), attributes_string_35 Map(String, String) CODEC (ZSTD(1)), attributes_string_36 Map(String, String) CODEC (ZSTD(1)), attributes_string_37 Map(String, String) CODEC (ZSTD(1)), attributes_string_38 Map(String, String) CODEC (ZSTD(1)), attributes_string_39 Map(String, String) CODEC (ZSTD(1)), attributes_float_0 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_1 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_2 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_3 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_4 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_5 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_6 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_7 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_8 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_9 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_10 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_11 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_12 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_13 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_14 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_15 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_16 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_17 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_18 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_19 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_20 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_21 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_22 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_23 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_24 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_25 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_26 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_27 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_28 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_29 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_30 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_31 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_32 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_33 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_34 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_35 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_36 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_37 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_38 Map(String, Float64) CODEC (ZSTD(1)), attributes_float_39 Map(String, Float64) CODEC (ZSTD(1))) AS SELECT organization_id, project_id, item_type, timestamp, trace_id, item_id, attributes_bool, attributes_int, attributes_string_0, attributes_string_1, attributes_string_2, attributes_string_3, attributes_string_4, attributes_string_5, attributes_string_6, attributes_string_7, attributes_string_8, attributes_string_9, attributes_string_10, attributes_string_11, attributes_string_12, attributes_string_13, attributes_string_14, attributes_string_15, attributes_string_16, attributes_string_17, attributes_string_18, attributes_string_19, attributes_string_20, attributes_string_21, attributes_string_22, attributes_string_23, attributes_string_24, attributes_string_25, attributes_string_26, attributes_string_27, attributes_string_28, attributes_string_29, attributes_string_30, attributes_string_31, attributes_string_32, attributes_string_33, attributes_string_34, attributes_string_35, attributes_string_36, attributes_string_37, attributes_string_38, attributes_string_39, attributes_float_0, attributes_float_1, attributes_float_2, attributes_float_3, attributes_float_4, attributes_float_5, attributes_float_6, attributes_float_7, attributes_float_8, attributes_float_9, attributes_float_10, attributes_float_11, attributes_float_12, attributes_float_13, attributes_float_14, attributes_float_15, attributes_float_16, attributes_float_17, attributes_float_18, attributes_float_19, attributes_float_20, attributes_float_21, attributes_float_22, attributes_float_23, attributes_float_24, attributes_float_25, attributes_float_26, attributes_float_27, attributes_float_28, attributes_float_29, attributes_float_30, attributes_float_31, attributes_float_32, attributes_float_33, attributes_float_34, attributes_float_35, attributes_float_36, attributes_float_37, attributes_float_38, attributes_float_39, downsampled_retention_days AS retention_days, sampling_weight * 512 AS sampling_weight, sampling_factor / 512 AS sampling_factor, client_sample_rate / 512 AS client_sample_rate, server_sample_rate / 512 AS server_sample_rate FROM eap_items_1_local WHERE (cityHash64(item_id + 512) % 512) = 0;
Local op: DROP TABLE IF EXISTS eap_items_1_downsample_512_mv_3 ON CLUSTER 'cluster_one_sh' SYNC;
-- end forward migration events_analytics_platform : 0049_use_client_and_server_sample_rates_in_materialized_views
-- backward migration events_analytics_platform : 0049_use_client_and_server_sample_rates_in_materialized_views
Local op: DROP TABLE IF EXISTS eap_items_1_downsample_8_mv_4 ON CLUSTER 'cluster_one_sh' SYNC;
Local op: DROP TABLE IF EXISTS eap_items_1_downsample_64_mv_4 ON CLUSTER 'cluster_one_sh' SYNC;
Local op: DROP TABLE IF EXISTS eap_items_1_downsample_512_mv_4 ON CLUSTER 'cluster_one_sh' SYNC;
-- end backward migration events_analytics_platform : 0049_use_client_and_server_sample_rates_in_materialized_views |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
1 participant
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
No description provided.