Buffer 表引擎简介

  • 只写内存,无持久化存储
  • 缓冲高并发写入,满足条件时,Buffer 表会把数据刷新到目标表

创建 Join 引擎表

  • 声明

     1
     2
     3
     4
     5
     6
     7
     8
     9
    10
    11
    
    ENGINE = Buffer(
        database,
        table,
        num_layers,
        min_time,
        max_time,
        min_rows,
        max_rows,
        min_bytes,
        max_bytes
    )
  • database: 目标表所在数据库

  • table: 目标表名

  • num_layers: 刷新数据到目标表时开启的线程数,官方建议 16

  • min_time 和 max_time: 时间条件,单位秒

  • min_rows 和 max_rows: 数据行数条件

  • min_bytes 和 max_bytes: 数据体量条件,单位字节

  • 所有最小阈值都满足时,触发刷新

  • 至少一个最大阈值满足时,触发刷新

  • 如果一批数据的行数大于 max_rows,或体量大于 max_bytes,则数据直接写入目标表

  • 各线程(num_layers)单独计算刷新规则