add count labels cursor

YANG-DB · Oct 28, 2019 · 9295001 · 9295001
1 parent 16ba1dd
commit 9295001
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 0 deletions.
diff --git a/...resources/assembly/Knowledge/config/application.test.engine3.m1.dfs.knowledge.public.conf b/...resources/assembly/Knowledge/config/application.test.engine3.m1.dfs.knowledge.public.conf
@@ -36,6 +36,7 @@ elasticsearch.default_search_size = 10000000
 elasticsearch.max_search_size = 1000000000
 elasticsearch.scroll_size = 10000
 elasticsearch.scroll_time = 600000
+elasticsearch.search.max_open_scroll_context = 1000
 
 unipop.bulk.max = 1000
 unipop.bulk.start = 1000

diff --git a/...urces/assembly/Knowledge/config/application.test.engine3mock.m1.dfs.knowledge.public.conf b/...urces/assembly/Knowledge/config/application.test.engine3mock.m1.dfs.knowledge.public.conf
@@ -32,6 +32,7 @@ elasticsearch.default_search_size = 5000
 elasticsearch.max_search_size = 1000000000
 elasticsearch.scroll_size = 1000
 elasticsearch.scroll_time = 60000
+elasticsearch.search.max_open_scroll_context = 1000
 
 unipop.bulk.max = 1000
 unipop.bulk.start = 1000

diff --git a/...-dv-unipop/src/main/java/com/yangdb/fuse/unipop/controller/ElasticGraphConfiguration.java b/...-dv-unipop/src/main/java/com/yangdb/fuse/unipop/controller/ElasticGraphConfiguration.java
@@ -125,6 +125,10 @@ public int getElasticGraphScrollTime() {
         return super.getInt(ELASTIC_GRAPH_SCROLL_TIME, 60000);
     }
 
+    public int getElasticSearchScrollMaxOpen() {
+        return super.getInt(ELASTIC_SEARCH_SCROLL_MAX_OPEN, 1000);
+    }
+
     public void setElasticGraphScrollTime(int value) {
         super.addProperty(ELASTIC_GRAPH_SCROLL_TIME, value);
     }
@@ -226,6 +230,7 @@ public void setElasticGraphAggregationsDefaultTermsExecutonHint(String value) {
     public static final String ELASTIC_GRAPH_SCHEMA_PROVIDER_FACTORY = "elastic.graph.schema_provider_factory";
     public static final String ELASTIC_GRAPH_SCHEMA_PROVIDER_FACTORY_CLASS = "elastic.graph.schema_provider_factory.class";
     public static final String ELASTIC_GRAPH_SCROLL_TIME = "elastic.graph.scroll_time";
+    public static final String ELASTIC_SEARCH_SCROLL_MAX_OPEN = "elasticsearch.search.max_open_scroll_context";
     public static final String ELASTIC_GRAPH_SCROLL_SIZE = "elastic.graph.scroll_size";
     public static final String ELASTIC_GRAPH_DEFAULT_SEARCH_SIZE = "elastic.graph.default_search_size";
     public static final String ELASTIC_GRAPH_MAX_SEARCH_SIZE = "elastic.graph.max_search_size";