static FluentConfigurator load()

in modules/core/src/main/java/org/apache/fluo/recipes/core/export/FluentConfigurator.java [98:108]


  static FluentConfigurator load(String queueId, SimpleConfiguration appConfig) {
    FluentConfigurator fc = new FluentConfigurator(queueId);
    fc.buckets = appConfig.getInt(PREFIX + queueId + ".buckets");
    fc.keyType = appConfig.getString(PREFIX + queueId + ".key");
    fc.valueType = appConfig.getString(PREFIX + queueId + ".val");
    fc.bufferSize = appConfig.getLong(PREFIX + queueId + ".bufferSize", DEFAULT_BUFFER_SIZE);
    fc.bucketsPerTablet =
        appConfig.getInt(PREFIX + queueId + ".bucketsPerTablet", DEFAULT_BUCKETS_PER_TABLET);
    fc.exporterType = appConfig.getString(PREFIX + queueId + ".exporter", null);
    return fc;
  }