public void save()

in modules/core/src/main/java/org/apache/fluo/recipes/core/combine/CqConfigurator.java [108:127]

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

  public void save(FluoConfiguration fluoConfig) {
    SimpleConfiguration appConfig = fluoConfig.getAppConfiguration();
    appConfig.setProperty(PREFIX + cqId + ".buckets", numBuckets + "");
    appConfig.setProperty(PREFIX + cqId + ".key", keyType);
    appConfig.setProperty(PREFIX + cqId + ".val", valueType);
    if (bufferSize != null) {
      appConfig.setProperty(PREFIX + cqId + ".bufferSize", bufferSize);
    }
    if (bucketsPerTablet != null) {
      appConfig.setProperty(PREFIX + cqId + ".bucketsPerTablet", bucketsPerTablet);
    }

    Bytes dataRangeEnd = Bytes.of(cqId + DATA_RANGE_END);
    Bytes updateRangeEnd = Bytes.of(cqId + UPDATE_RANGE_END);

    new TransientRegistry(fluoConfig.getAppConfiguration()).addTransientRange("cfm." + cqId,
        new RowRange(dataRangeEnd, updateRangeEnd));

    TableOptimizations.registerOptimization(appConfig, cqId, CombineQueue.Optimizer.class);
  }