Package org.apache.ignite.table

Class DataStreamerOptions.Builder

java.lang.Object
org.apache.ignite.table.DataStreamerOptions.Builder
Enclosing class:
DataStreamerOptions
public static class DataStreamerOptions.Builder extends Object
Builder.

  • Constructor Details

    • Builder

      public Builder()

  • Method Details

    • pageSize

      public DataStreamerOptions.Builder pageSize(int pageSize)
      Sets the page size (the number of entries that will be sent to the cluster in one network call).
      Parameters:
      pageSize - Page size.
      Returns:
      This builder instance.

    • perPartitionParallelOperations

      public DataStreamerOptions.Builder perPartitionParallelOperations(int perPartitionParallelOperations)
      Sets the number of parallel operations per partition (how many in-flight requests can be active for a given partition).
      Parameters:
      perPartitionParallelOperations - Per partition parallel operations.
      Returns:
      This builder instance.

    • autoFlushInterval

      public DataStreamerOptions.Builder autoFlushInterval(int autoFlushInterval)
      Sets the auto flush interval, in milliseconds (the period of time after which the streamer will flush the per-node buffer even if it is not full).
      Parameters:
      autoFlushInterval - Auto flush interval, in milliseconds. 0 or less means no auto flush.
      Returns:
      This builder instance.

    • retryLimit

      public DataStreamerOptions.Builder retryLimit(int retryLimit)
      Sets the retry limit for a page. If a page fails to be sent to the cluster, the streamer will retry it a number of times. If all retries fail, the streamer will be aborted.
      Parameters:
      retryLimit - Retry limit.
      Returns:
      This builder instance.

    • sameKeyUpdateMode

      public DataStreamerOptions.Builder sameKeyUpdateMode(DataStreamerSameKeyUpdateMode sameKeyUpdateMode)
      Sets the mode controlling how same-key updates within one batch are handled.

      DataStreamerSameKeyUpdateMode.SQUASH (default) conflates duplicate-key updates within a batch — Continuous Query observes one event per affected key per batch.

      DataStreamerSameKeyUpdateMode.PRESERVE splits the batch on duplicate-key boundaries so each update lands in its own implicit transaction — Continuous Query observes one event per update, at the cost of additional transactions.

      Parameters:
      sameKeyUpdateMode - Same-key update mode.
      Returns:
      This builder instance.

    • build

      public DataStreamerOptions build()
      Builds the options.
      Returns:
      Data streamer options.