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;
}