public static void configure()

in modules/core/src/main/java/org/apache/fluo/recipes/core/map/CollisionFreeMap.java [378:394]

• 15 lines of code
• 3 McCabe index (conditional complexity)

  public static void configure(FluoConfiguration fluoConfig, Options opts) {
    org.apache.fluo.recipes.core.combine.CombineQueue.FluentOptions cqopts =
        CombineQueue.configure(opts.mapId).keyType(opts.keyType).valueType(opts.valueType)
            .buckets(opts.numBuckets);
    if (opts.bucketsPerTablet != null) {
      cqopts.bucketsPerTablet(opts.bucketsPerTablet);
    }
    if (opts.bufferSize != null) {
      cqopts.bufferSize(opts.bufferSize);
    }
    cqopts.save(fluoConfig);

    opts.save(fluoConfig.getAppConfiguration());

    fluoConfig.addObserver(new org.apache.fluo.api.config.ObserverSpecification(
        CollisionFreeMapObserver.class.getName(), Map.of("mapId", opts.mapId)));
  }