summaryrefslogtreecommitdiffstats
path: root/config-model/src/main/java/com/yahoo/vespa/model/search/StreamingSearchCluster.java
diff options
context:
space:
mode:
Diffstat (limited to 'config-model/src/main/java/com/yahoo/vespa/model/search/StreamingSearchCluster.java')
-rw-r--r--config-model/src/main/java/com/yahoo/vespa/model/search/StreamingSearchCluster.java71
1 files changed, 42 insertions, 29 deletions
diff --git a/config-model/src/main/java/com/yahoo/vespa/model/search/StreamingSearchCluster.java b/config-model/src/main/java/com/yahoo/vespa/model/search/StreamingSearchCluster.java
index 724ba70510f..79adfb2ea13 100644
--- a/config-model/src/main/java/com/yahoo/vespa/model/search/StreamingSearchCluster.java
+++ b/config-model/src/main/java/com/yahoo/vespa/model/search/StreamingSearchCluster.java
@@ -7,12 +7,15 @@ import com.yahoo.prelude.fastsearch.DocumentdbInfoConfig;
import com.yahoo.schema.Schema;
import com.yahoo.schema.derived.AttributeFields;
import com.yahoo.schema.derived.DerivedConfiguration;
+import com.yahoo.search.config.IndexInfoConfig;
+import com.yahoo.search.config.SchemaInfoConfig;
import com.yahoo.vespa.config.search.AttributesConfig;
import com.yahoo.vespa.config.search.RankProfilesConfig;
import com.yahoo.vespa.config.search.SummaryConfig;
import com.yahoo.vespa.config.search.SummarymapConfig;
import com.yahoo.vespa.config.search.vsm.VsmfieldsConfig;
import com.yahoo.vespa.config.search.vsm.VsmsummaryConfig;
+import com.yahoo.vespa.configdefinition.IlscriptsConfig;
/**
* A search cluster of type streaming.
@@ -20,8 +23,8 @@ import com.yahoo.vespa.config.search.vsm.VsmsummaryConfig;
* @author baldersheim
* @author vegardh
*/
-public class StreamingSearchCluster extends SearchCluster implements
- DocumentdbInfoConfig.Producer,
+public class StreamingSearchCluster extends SearchCluster implements
+ DocumentdbInfoConfig.Producer,
RankProfilesConfig.Producer,
VsmsummaryConfig.Producer,
VsmfieldsConfig.Producer,
@@ -31,7 +34,7 @@ public class StreamingSearchCluster extends SearchCluster implements
private final String storageRouteSpec;
private final AttributesProducer attributesConfig;
private final String docTypeName;
- private DerivedConfiguration schemaConfig = null;
+ private DerivedConfiguration derivedConfig = null;
public StreamingSearchCluster(AbstractConfigProducer<SearchCluster> parent,
String clusterName,
@@ -51,9 +54,9 @@ public class StreamingSearchCluster extends SearchCluster implements
protected IndexingMode getIndexingMode() { return IndexingMode.STREAMING; }
public final String getStorageRouteSpec() { return storageRouteSpec; }
- public String getDocTypeName() {
- return docTypeName;
- }
+ public String getDocTypeName() { return docTypeName; }
+
+ public DerivedConfiguration derived() { return derivedConfig; }
@Override
public int getRowBits() { return 0; }
@@ -61,10 +64,10 @@ public class StreamingSearchCluster extends SearchCluster implements
@Override
public void getConfig(DocumentdbInfoConfig.Builder builder) {
DocumentdbInfoConfig.Documentdb.Builder docDb = new DocumentdbInfoConfig.Documentdb.Builder();
- docDb.name(schemaConfig.getSchema().getName());
- SummaryConfig.Producer prod = schemaConfig.getSummaries();
+ docDb.name(derivedConfig.getSchema().getName());
+ SummaryConfig.Producer prod = derivedConfig.getSummaries();
convertSummaryConfig(prod, null, docDb);
- addRankProfilesConfig(schemaConfig.getSchema().getName(), docDb);
+ addRankProfilesConfig(derivedConfig.getSchema().getName(), docDb);
builder.documentdb(docDb);
}
@@ -77,46 +80,58 @@ public class StreamingSearchCluster extends SearchCluster implements
if ( ! schema.getName().equals(docTypeName))
throw new IllegalArgumentException("Document type name '" + docTypeName +
"' must be the same as the schema name '" + schema.getName() + "'");
- this.schemaConfig = new DerivedConfiguration(schema, deployState);
+ this.derivedConfig = new DerivedConfiguration(schema, deployState);
}
@Override
- public DerivedConfiguration getSchemaConfig() { return schemaConfig; }
+ public void defaultDocumentsConfig() { }
@Override
- public void defaultDocumentsConfig() { }
+ public void getConfig(IndexInfoConfig.Builder builder) {
+ derivedConfig.getIndexInfo().getConfig(builder);
+ }
+
+ @Override
+ public void getConfig(SchemaInfoConfig.Builder builder) {
+ derivedConfig.getSchemaInfo().getConfig(builder);
+ }
@Override
+ public void getConfig(IlscriptsConfig.Builder builder) {
+ derivedConfig.getIndexingScript().getConfig(builder);
+ }
+
public void getConfig(AttributesConfig.Builder builder) {
- if (getSchemaConfig() != null) getSchemaConfig().getConfig(builder);
+ derivedConfig.getConfig(builder);
}
-
+
+ @Override
+ public void getConfig(RankProfilesConfig.Builder builder) {
+ derivedConfig.getRankProfileList().getConfig(builder);
+ }
+
@Override
public void getConfig(VsmsummaryConfig.Builder builder) {
- if (getSchemaConfig() != null)
- if (getSchemaConfig().getVsmSummary() != null)
- getSchemaConfig().getVsmSummary().getConfig(builder);
+ if (derivedConfig.getVsmSummary() != null)
+ derivedConfig.getVsmSummary().getConfig(builder);
}
@Override
public void getConfig(VsmfieldsConfig.Builder builder) {
- if (getSchemaConfig() != null)
- if (getSchemaConfig().getVsmFields() != null)
- getSchemaConfig().getVsmFields().getConfig(builder);
+ if (derivedConfig.getVsmFields() != null)
+ derivedConfig.getVsmFields().getConfig(builder);
}
@Override
public void getConfig(SummarymapConfig.Builder builder) {
- if (getSchemaConfig() != null)
- if (getSchemaConfig().getSummaryMap() != null)
- getSchemaConfig().getSummaryMap().getConfig(builder);
+ if (derivedConfig.getSummaryMap() != null)
+ derivedConfig.getSummaryMap().getConfig(builder);
}
@Override
public void getConfig(SummaryConfig.Builder builder) {
- if (getSchemaConfig() != null)
- if (getSchemaConfig().getSummaries() != null)
- getSchemaConfig().getSummaries().getConfig(builder);
+ if (derivedConfig.getSummaries() != null)
+ derivedConfig.getSummaries().getConfig(builder);
}
private class AttributesProducer extends AbstractConfigProducer<AttributesProducer> implements AttributesConfig.Producer {
@@ -127,9 +142,7 @@ public class StreamingSearchCluster extends SearchCluster implements
@Override
public void getConfig(AttributesConfig.Builder builder) {
- if (getSchemaConfig() != null) {
- getSchemaConfig().getConfig(builder, AttributeFields.FieldSet.FAST_ACCESS);
- }
+ derivedConfig.getConfig(builder, AttributeFields.FieldSet.FAST_ACCESS);
}
}