scala - 如何设置每个分区缓存的行

Question

Phantom DSL 有没有办法指定每个分区缓存的行数？我可以：

.create.ifNotExists()。with（缓存 eqs Cache.RowsOnly()）

但我找不到如何指定缓存条件的方法，例如：所有键 + 每个分区 500 行。

Answer 1

table
  .create.ifNotExists()
  .with(
    caching eqs Cache.RowsOnly().rows_per_partition(CacheStrategies.ALL)
  )