:) CREATE DATABASE IF NOT EXISTS fazze_youtube_parser ON CLUSTER fornex_cluster; CREATE DATABASE IF NOT EXISTS fazze_youtube_parser ON CLUSTER fornex_cluster ┌─host──────────────────┬─port─┬─status─┬─error─┬─num_hosts_remaining─┬─num_hosts_active─┐ │ f-clickhouse-n5.local │ 9000 │ 0 │ │ 5 │ 0 │ │ f-clickhouse-n2.local │ 9000 │ 0 │ │ 4 │ 0 │ │ f-clickhouse-n3.local │ 9000 │ 0 │ │ 3 │ 0 │ │ f-clickhouse-n4.local │ 9000 │ 0 │ │ 2 │ 0 │ │ f-clickhouse-n1.local │ 9000 │ 0 │ │ 1 │ 0 │ │ f-clickhouse-n6.local │ 9000 │ 0 │ │ 0 │ 0 │ └───────────────────────┴──────┴────────┴───────┴─────────────────────┴──────────────────┘ 6 rows in set. Elapsed: 0.133 sec. :) CREATE DATABASE IF NOT EXISTS fazze_youtube_parser_buffer ON CLUSTER fornex_cluster; CREATE DATABASE IF NOT EXISTS fazze_youtube_parser_buffer ON CLUSTER fornex_cluster ┌─host──────────────────┬─port─┬─status─┬─error─┬─num_hosts_remaining─┬─num_hosts_active─┐ │ f-clickhouse-n5.local │ 9000 │ 0 │ │ 5 │ 0 │ │ f-clickhouse-n2.local │ 9000 │ 0 │ │ 4 │ 0 │ │ f-clickhouse-n3.local │ 9000 │ 0 │ │ 3 │ 0 │ │ f-clickhouse-n4.local │ 9000 │ 0 │ │ 2 │ 0 │ │ f-clickhouse-n1.local │ 9000 │ 0 │ │ 1 │ 0 │ │ f-clickhouse-n6.local │ 9000 │ 0 │ │ 0 │ 0 │ └───────────────────────┴──────┴────────┴───────┴─────────────────────┴──────────────────┘ 6 rows in set. Elapsed: 0.115 sec. :) CREATE DATABASE IF NOT EXISTS fazze_youtube_parser_shard ON CLUSTER fornex_cluster; CREATE DATABASE IF NOT EXISTS fazze_youtube_parser_shard ON CLUSTER fornex_cluster ┌─host──────────────────┬─port─┬─status─┬─error─┬─num_hosts_remaining─┬─num_hosts_active─┐ │ f-clickhouse-n5.local │ 9000 │ 0 │ │ 5 │ 0 │ │ f-clickhouse-n2.local │ 9000 │ 0 │ │ 4 │ 0 │ │ f-clickhouse-n3.local │ 9000 │ 0 │ │ 3 │ 0 │ │ f-clickhouse-n1.local │ 9000 │ 0 │ │ 2 │ 0 │ │ f-clickhouse-n4.local │ 9000 │ 0 │ │ 1 │ 0 │ │ f-clickhouse-n6.local │ 9000 │ 0 │ │ 0 │ 0 │ └───────────────────────┴──────┴────────┴───────┴─────────────────────┴──────────────────┘ 6 rows in set. Elapsed: 0.107 sec. :) CREATE TABLE fazze_youtube_parser.channel ON CLUSTER fornex_cluster ( :-] channel_id String, :-] name String, :-] description String, :-] image String, :-] country String, :-] subscribers UInt64, :-] views UInt64, :-] videos UInt64, :-] created_at_date Date, :-] created_at_time DateTime) ENGINE = Distributed(fornex_cluster, fazze_youtube_parser_buffer, channel, rand()); CREATE TABLE fazze_youtube_parser.channel ON CLUSTER fornex_cluster ( channel_id String, name String, description String, image String, country String, subscribers UInt64, views UInt64, videos UInt64, created_at_date Date, created_at_time DateTime ) ENGINE = Distributed(fornex_cluster, fazze_youtube_parser_buffer, channel, rand()) ┌─host──────────────────┬─port─┬─status─┬─error─┬─num_hosts_remaining─┬─num_hosts_active─┐ │ f-clickhouse-n5.local │ 9000 │ 0 │ │ 5 │ 0 │ │ f-clickhouse-n2.local │ 9000 │ 0 │ │ 4 │ 0 │ │ f-clickhouse-n3.local │ 9000 │ 0 │ │ 3 │ 0 │ │ f-clickhouse-n4.local │ 9000 │ 0 │ │ 2 │ 0 │ │ f-clickhouse-n1.local │ 9000 │ 0 │ │ 1 │ 0 │ │ f-clickhouse-n6.local │ 9000 │ 0 │ │ 0 │ 0 │ └───────────────────────┴──────┴────────┴───────┴─────────────────────┴──────────────────┘ 6 rows in set. Elapsed: 0.108 sec. :) CREATE TABLE fazze_youtube_parser.video ON CLUSTER fornex_cluster ( :-] video_id String, :-] channel_id String, :-] name String, :-] description String, :-] category String, :-] likes UInt64, :-] dislikes UInt64, :-] views UInt64, :-] publication_date Date, :-] created_at_date Date, :-] created_at_time DateTime) ENGINE = Distributed(fornex_cluster, fazze_youtube_parser_buffer, video, rand()); CREATE TABLE fazze_youtube_parser.video ON CLUSTER fornex_cluster ( video_id String, channel_id String, name String, description String, category String, likes UInt64, dislikes UInt64, views UInt64, publication_date Date, created_at_date Date, created_at_time DateTime ) ENGINE = Distributed(fornex_cluster, fazze_youtube_parser_buffer, video, rand()) ┌─host──────────────────┬─port─┬─status─┬─error─┬─num_hosts_remaining─┬─num_hosts_active─┐ │ f-clickhouse-n5.local │ 9000 │ 0 │ │ 5 │ 0 │ │ f-clickhouse-n2.local │ 9000 │ 0 │ │ 4 │ 0 │ │ f-clickhouse-n3.local │ 9000 │ 0 │ │ 3 │ 0 │ │ f-clickhouse-n4.local │ 9000 │ 0 │ │ 2 │ 0 │ │ f-clickhouse-n1.local │ 9000 │ 0 │ │ 1 │ 0 │ │ f-clickhouse-n6.local │ 9000 │ 0 │ │ 0 │ 0 │ └───────────────────────┴──────┴────────┴───────┴─────────────────────┴──────────────────┘ 6 rows in set. Elapsed: 0.108 sec. :) CREATE TABLE fazze_youtube_parser.url ON CLUSTER fornex_cluster ( :-] channel_id String, :-] video_id String, :-] short_url String, :-] final_url String, :-] created_at_date Date, :-] created_at_time DateTime) ENGINE = Distributed(fornex_cluster, fazze_youtube_parser_buffer, url, rand()); CREATE TABLE fazze_youtube_parser.url ON CLUSTER fornex_cluster ( channel_id String, video_id String, short_url String, final_url String, created_at_date Date, created_at_time DateTime ) ENGINE = Distributed(fornex_cluster, fazze_youtube_parser_buffer, url, rand()) ┌─host──────────────────┬─port─┬─status─┬─error─┬─num_hosts_remaining─┬─num_hosts_active─┐ │ f-clickhouse-n5.local │ 9000 │ 0 │ │ 5 │ 0 │ │ f-clickhouse-n2.local │ 9000 │ 0 │ │ 4 │ 0 │ │ f-clickhouse-n3.local │ 9000 │ 0 │ │ 3 │ 0 │ │ f-clickhouse-n1.local │ 9000 │ 0 │ │ 2 │ 0 │ │ f-clickhouse-n4.local │ 9000 │ 0 │ │ 1 │ 0 │ │ f-clickhouse-n6.local │ 9000 │ 0 │ │ 0 │ 0 │ └───────────────────────┴──────┴────────┴───────┴─────────────────────┴──────────────────┘ 6 rows in set. Elapsed: 0.108 sec. :) CREATE TABLE fazze_youtube_parser.url_dirty ON CLUSTER fornex_cluster ( :-] durl_url String, :-] video_id String, :-] created_at_date Date, :-] created_at_time DateTime) ENGINE = Distributed(fornex_cluster, fazze_youtube_parser_buffer, url_dirty, rand()); CREATE TABLE fazze_youtube_parser.url_dirty ON CLUSTER fornex_cluster ( durl_url String, video_id String, created_at_date Date, created_at_time DateTime ) ENGINE = Distributed(fornex_cluster, fazze_youtube_parser_buffer, url_dirty, rand()) ┌─host──────────────────┬─port─┬─status─┬─error─┬─num_hosts_remaining─┬─num_hosts_active─┐ │ f-clickhouse-n5.local │ 9000 │ 0 │ │ 5 │ 0 │ │ f-clickhouse-n2.local │ 9000 │ 0 │ │ 4 │ 0 │ │ f-clickhouse-n3.local │ 9000 │ 0 │ │ 3 │ 0 │ │ f-clickhouse-n4.local │ 9000 │ 0 │ │ 2 │ 0 │ │ f-clickhouse-n1.local │ 9000 │ 0 │ │ 1 │ 0 │ │ f-clickhouse-n6.local │ 9000 │ 0 │ │ 0 │ 0 │ └───────────────────────┴──────┴────────┴───────┴─────────────────────┴──────────────────┘ 6 rows in set. Elapsed: 0.109 sec. :) CREATE TABLE fazze_youtube_parser_shard.channel ON CLUSTER fornex_cluster AS fazze_youtube_parser.channel (ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/fazze_youtube_parser_shard/channel', '{replica}', created_at_date, (channel_id, name), 8192); Syntax error: failed at position 107: CREATE TABLE fazze_youtube_parser_shard.channel ON CLUSTER fornex_cluster AS fazze_youtube_parser.channel (ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/fazze_youtube_parser_shard/channel', '{replica}', created_at_date, (channel_id, name), 8192); Unmatched parentheses: ( :) CREATE TABLE fazze_youtube_parser_shard.channel ON CLUSTER fornex_cluster AS fazze_youtube_parser.channel (ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/fazze_youtube_parser_shard/channel', '{replica}', created_at_date, (channel_id, name), 8192); Syntax error: failed at position 107: CREATE TABLE fazze_youtube_parser_shard.channel ON CLUSTER fornex_cluster AS fazze_youtube_parser.channel (ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/fazze_youtube_parser_shard/channel', '{replica}', created_at_date, (channel_id, name), 8192); Unmatched parentheses: ( :) CREATE TABLE fazze_youtube_parser_shard.channel ON CLUSTER fornex_cluster AS fazze_youtube_parser.channel ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/fazze_youtube_parser_shard/channel', '{replica}', created_at_date, (channel_id, name), 8192); CREATE TABLE fazze_youtube_parser_shard.channel ON CLUSTER fornex_cluster AS fazze_youtube_parser.channel ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/fazze_youtube_parser_shard/channel', '{replica}', created_at_date, (channel_id, name), 8192) ┌─host──────────────────┬─port─┬─status─┬─error─┬─num_hosts_remaining─┬─num_hosts_active─┐ │ f-clickhouse-n5.local │ 9000 │ 0 │ │ 5 │ 2 │ │ f-clickhouse-n3.local │ 9000 │ 0 │ │ 4 │ 2 │ │ f-clickhouse-n4.local │ 9000 │ 0 │ │ 3 │ 2 │ │ f-clickhouse-n6.local │ 9000 │ 0 │ │ 2 │ 2 │ └───────────────────────┴──────┴────────┴───────┴─────────────────────┴──────────────────┘ ┌─host──────────────────┬─port─┬─status─┬─error─┬─num_hosts_remaining─┬─num_hosts_active─┐ │ f-clickhouse-n2.local │ 9000 │ 0 │ │ 1 │ 0 │ │ f-clickhouse-n1.local │ 9000 │ 0 │ │ 0 │ 0 │ └───────────────────────┴──────┴────────┴───────┴─────────────────────┴──────────────────┘ 6 rows in set. Elapsed: 0.279 sec. :) CREATE TABLE fazze_youtube_parser_shard.video ON CLUSTER fornex_cluster AS fazze_youtube_parser.video ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/fazze_youtube_parser_shard/video', '{replica}', created_at_date, (video_id, name), 8192); CREATE TABLE fazze_youtube_parser_shard.video ON CLUSTER fornex_cluster AS fazze_youtube_parser.video ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/fazze_youtube_parser_shard/video', '{replica}', created_at_date, (video_id, name), 8192) ┌─host──────────────────┬─port─┬─status─┬─error─┬─num_hosts_remaining─┬─num_hosts_active─┐ │ f-clickhouse-n5.local │ 9000 │ 0 │ │ 5 │ 0 │ │ f-clickhouse-n2.local │ 9000 │ 0 │ │ 4 │ 0 │ │ f-clickhouse-n3.local │ 9000 │ 0 │ │ 3 │ 0 │ │ f-clickhouse-n4.local │ 9000 │ 0 │ │ 2 │ 0 │ │ f-clickhouse-n1.local │ 9000 │ 0 │ │ 1 │ 0 │ │ f-clickhouse-n6.local │ 9000 │ 0 │ │ 0 │ 0 │ └───────────────────────┴──────┴────────┴───────┴─────────────────────┴──────────────────┘ 6 rows in set. Elapsed: 0.107 sec. :) CREATE TABLE fazze_youtube_parser_shard.url ON CLUSTER fornex_cluster AS fazze_youtube_parser.url ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/fazze_youtube_parser_shard/url', '{replica}', created_at_date, (short_url, video_id), 8192); CREATE TABLE fazze_youtube_parser_shard.url ON CLUSTER fornex_cluster AS fazze_youtube_parser.url ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/fazze_youtube_parser_shard/url', '{replica}', created_at_date, (short_url, video_id), 8192) ┌─host──────────────────┬─port─┬─status─┬─error─┬─num_hosts_remaining─┬─num_hosts_active─┐ │ f-clickhouse-n5.local │ 9000 │ 0 │ │ 5 │ 0 │ │ f-clickhouse-n2.local │ 9000 │ 0 │ │ 4 │ 0 │ │ f-clickhouse-n3.local │ 9000 │ 0 │ │ 3 │ 0 │ │ f-clickhouse-n4.local │ 9000 │ 0 │ │ 2 │ 0 │ │ f-clickhouse-n1.local │ 9000 │ 0 │ │ 1 │ 0 │ │ f-clickhouse-n6.local │ 9000 │ 0 │ │ 0 │ 0 │ └───────────────────────┴──────┴────────┴───────┴─────────────────────┴──────────────────┘ 6 rows in set. Elapsed: 0.111 sec. :) CREATE TABLE fazze_youtube_parser_shard.url_dirty ON CLUSTER fornex_cluster AS fazze_youtube_parser.url_dirty ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/fazze_youtube_parser_shard/url_dirty', '{replica}', created_at_date, (durl_url, video_id), 8192); CREATE TABLE fazze_youtube_parser_shard.url_dirty ON CLUSTER fornex_cluster AS fazze_youtube_parser.url_dirty ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/fazze_youtube_parser_shard/url_dirty', '{replica}', created_at_date, (durl_url, video_id), 8192) ┌─host──────────────────┬─port─┬─status─┬─error─┬─num_hosts_remaining─┬─num_hosts_active─┐ │ f-clickhouse-n5.local │ 9000 │ 0 │ │ 5 │ 0 │ │ f-clickhouse-n2.local │ 9000 │ 0 │ │ 4 │ 0 │ │ f-clickhouse-n3.local │ 9000 │ 0 │ │ 3 │ 0 │ │ f-clickhouse-n4.local │ 9000 │ 0 │ │ 2 │ 0 │ │ f-clickhouse-n1.local │ 9000 │ 0 │ │ 1 │ 0 │ │ f-clickhouse-n6.local │ 9000 │ 0 │ │ 0 │ 0 │ └───────────────────────┴──────┴────────┴───────┴─────────────────────┴──────────────────┘ 6 rows in set. Elapsed: 0.107 sec. :)