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.

    • build

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