ΔΗΜΙΟΥΡΓΗΣΤΕ ΠΙΝΑΚΑ raw.local_transactions ΣΤΟ CLUSTER cluster_4x2 (
transaction_id String,
user_id String,
amount Float64,
created_at DateTime
) ΜΗΧΑΝΗ = ReplicatedMergeTree()
ΔΙΑΜΕΡΙΣΜΑΤΙΣΜΟΣ ΜΕ βάση το amount
ΤΑΞΙΝΟΜΗΣΤΕ ΜΕ (transaction_id);
ΔΗΜΙΟΥΡΓΗΣΤΕ ΠΙΝΑΚΑ raw.transactions ΣΤΟ CLUSTER cluster_4x2 (
transaction_id String,
user_id String,
amount Float64,
created_at DateTime
) ΜΗΧΑΝΗ = Distributed('cluster_4x2', 'raw', 'local_transactions', cityHash64(user_id));