ClickHouse Materialized Views Tức Thời: Định Cỡ `AggregatingMergeTree` Trên ClickHouseCalc

CREATE TABLE market.ohlcv_1m_target
(
  symbol LowCardinality(String),
  bucket DateTime CODEC(DoubleDelta, LZ4),
  open_price AggregateFunction(argMin, Float64, DateTime64(9)),
  high_price SimpleAggregateFunction(max, Float64),
  low_price SimpleAggregateFunction(min, Float64),
  close_price AggregateFunction(argMax, Float64, DateTime64(9)),
  volume SimpleAggregateFunction(sum, Float64)
)
ENGINE = AggregatingMergeTree
PARTITION BY toYYYYMM(bucket)
ORDER BY (symbol, bucket);

CREATE MATERIALIZED VIEW market.ohlcv_1m_mv TO market.ohlcv_1m_target AS
SELECT
  symbol,
  toStartOfMinute(exchange_ts) AS bucket,
  argMinState(price, exchange_ts) AS open_price,
  max(price) AS high_price,
  min(price) AS low_price,
  argMaxState(price, exchange_ts) AS close_price,
  sum(qty) AS volume
FROM market.raw_ticks
GROUP BY symbol, bucket;