Class WriteCoalescer.Builder<K,V>

java.lang.Object
cloud.opencode.base.cache.write.WriteCoalescer.Builder<K,V>
Type Parameters:
K - key type | 键类型
V - value type | 值类型
Enclosing class:
WriteCoalescer<K,V>
public static class WriteCoalescer.Builder<K,V> extends Object
Builder for WriteCoalescer WriteCoalescer 构建器
Since:
JDK 25, opencode-base-cache V2.0.5
Author:
Leon Soo www.LeonSoo.com

  • Constructor Details

    • Builder

      public Builder()
      Creates a new Builder instance | 创建新的 Builder 实例

  • Method Details

    • writer

      public WriteCoalescer.Builder<K,V> writer(WriteCoalescer.BatchWriter<K,V> writer)
      Set batch writer 设置批量写入器
      Parameters:
      writer - the batch writer | 批量写入器
      Returns:
      this builder | 此构建器

    • writer

      public WriteCoalescer.Builder<K,V> writer(Consumer<Map<K,V>> consumer)
      Set batch writer from simple consumer 从简单消费者设置批量写入器
      Parameters:
      consumer - the consumer | 消费者
      Returns:
      this builder | 此构建器

    • batchSize

      public WriteCoalescer.Builder<K,V> batchSize(int size)
      Set batch size 设置批次大小
      Parameters:
      size - batch size | 批次大小
      Returns:
      this builder | 此构建器

    • flushInterval

      public WriteCoalescer.Builder<K,V> flushInterval(Duration interval)
      Set flush interval 设置刷新间隔
      Parameters:
      interval - flush interval | 刷新间隔
      Returns:
      this builder | 此构建器

    • deduplicateWrites

      public WriteCoalescer.Builder<K,V> deduplicateWrites(boolean deduplicate)
      Enable/disable write deduplication 启用/禁用写去重
      Parameters:
      deduplicate - true to deduplicate | true 表示去重
      Returns:
      this builder | 此构建器

    • errorHandler

      public WriteCoalescer.Builder<K,V> errorHandler(WriteCoalescer.WriteErrorHandler<K,V> handler)
      Set error handler 设置错误处理器
      Parameters:
      handler - the error handler | 错误处理器
      Returns:
      this builder | 此构建器

    • build

      public WriteCoalescer<K,V> build()
      Build the write coalescer 构建写合并器
      Returns:
      write coalescer | 写合并器