in modules/core/src/main/java/org/apache/fluo/recipes/core/export/FluentConfigurator.java [67:91]
void save(SimpleConfiguration appConfig) {
appConfig.setProperty(PREFIX + queueId + ".buckets", buckets + "");
appConfig.setProperty(PREFIX + queueId + ".key", keyType);
appConfig.setProperty(PREFIX + queueId + ".val", valueType);
if (exporterType != null) {
appConfig.setProperty(PREFIX + queueId + ".exporter", exporterType);
}
if (bufferSize != null) {
appConfig.setProperty(PREFIX + queueId + ".bufferSize", bufferSize);
}
if (bucketsPerTablet != null) {
appConfig.setProperty(PREFIX + queueId + ".bucketsPerTablet", bucketsPerTablet);
}
Bytes exportRangeStart = Bytes.of(queueId + ExportQueue.RANGE_BEGIN);
Bytes exportRangeStop = Bytes.of(queueId + ExportQueue.RANGE_END);
new TransientRegistry(appConfig).addTransientRange("exportQueue." + queueId,
new RowRange(exportRangeStart, exportRangeStop));
TableOptimizations.registerOptimization(appConfig, queueId, Optimizer.class);
}