Module ojalgo
Package org.ojalgo.data.batch

Class BatchNode.Builder<T>

java.lang.Object
org.ojalgo.data.batch.BatchNode.Builder<T>
Enclosing class:
BatchNode<T>
public static final class BatchNode.Builder<T> extends Object

  • Method Details

    • build

      public BatchNode<T> build()

    • distributor

      public BatchNode.Builder<T> distributor(ToIntFunction<T> distributor)
      The default is to distribute randomly. Most likely you want to distribute based on some property of the item/type – extract that property and get its hash code. That causes all items with same value on that property to end up in the same shard, and that you can exploit when processing the data.

    • executor

      public BatchNode.Builder<T> executor(ExecutorService executor)

    • fragmentation

      public BatchNode.Builder<T> fragmentation(int fragmentation)
      The number of underlying files/shards. Increasing the fragmentation (the number of shards) typically reduces memory requirements when processong. The value set here is only an indication of the desired order of magnitude. The exact number of shards actually used is a derived property.

    • managed

      public BatchNode.Builder<T> managed(boolean managed)
      Do you want a JMX bean to keep track of throughput?

    • parallelism

      public BatchNode.Builder<T> parallelism(int parallelism)
      See Also:

    • parallelism

      public BatchNode.Builder<T> parallelism(IntSupplier parallelism)
      How many worker threads should process data in parallel?

    • queue

      public BatchNode.Builder<T> queue(int capacity)
      When reading and/or writing data from/to disk data is temporarily queued. This specifies the total maximum number of items kept in the queues.