Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
gkysaad committed Jul 14, 2021
1 parent 7757065 commit 5024f68
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 4 deletions.
Expand Up @@ -8,6 +8,7 @@
"type_field": "_class"
},
"mapping": {
"analysis": {}.
"default_analyzer": "standard",
"default_datetime_parser": "dateTimeOptional",
"default_field": "_all",
Expand All @@ -29,7 +30,7 @@
},
"store": {
"indexType": "scorch",
"kvStoreName": ""
"segmentVersion": 15
}
},
"sourceType": "couchbase",
Expand Down
Expand Up @@ -1750,7 +1750,7 @@ _%>
// Wait for the <%= entityInstance %> to be indexed
// TestUtil.retryUntilNotEmpty(() -> <%= entityInstance %>Repository.search(<%= entityClass %>.PREFIX, "id:" + <%= entityInstance %>.get<%= primaryKey.nameCapitalized %>())<% if (reactive) { %>.collectList().block()<% } %>);
// <%= entityInstance %>Repository.search(<%= entityClass %>.PREFIX, "id:" + <%= entityInstance %>.get<%= primaryKey.nameCapitalized %>())<% if (reactive) { %>.collectList().block()<% } %>;
TimeUnit.SECONDS.sleep(2);
TimeUnit.SECONDS.sleep(1);
<%_ } _%>

// Search the <%= entityInstance %>
Expand Down
Expand Up @@ -72,7 +72,7 @@ public class CustomCouchbaseRepository<T, ID extends Serializable> extends Simpl
<%_ if (searchEngine === 'couchbase') { _%>
public Page<T> search(String indexName, String request, Pageable pageable) {
SearchQuery searchQuery = SearchQuery.queryString(request);
SearchQuery searchQuery = queryString(request);
SearchOptions searchOptions = SearchOptions.searchOptions()
.limit(pageable.getPageSize())
.skip((int) pageable.getOffset());
Expand All @@ -83,7 +83,7 @@ public class CustomCouchbaseRepository<T, ID extends Serializable> extends Simpl
@Override
public List<T> search(String indexName, String request) {
SearchQuery searchQuery = SearchQuery.queryString(request);
SearchQuery searchQuery = queryString(request);
return extractResults(couchbaseOperations.getCouchbaseClientFactory().getCluster().searchQuery(indexName, searchQuery));
}
Expand Down

0 comments on commit 5024f68

Please sign in to comment.