Skip to content
Snippets Groups Projects
Commit ac412e93 authored by mbrodhu's avatar mbrodhu
Browse files

add class SetDeliverer.java to path

parent abbfb0fd
No related branches found
No related tags found
No related merge requests found
package info.textgrid.middleware;
import info.textgrid.middleware.oaipmh.ListSetsType;
import info.textgrid.middleware.oaipmh.SetType;
import java.util.LinkedHashSet;
import java.util.Set;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.QueryStringQueryBuilder;
import org.elasticsearch.search.SearchHit;
public class SetDeliverer {
ListSetsType setList = new ListSetsType();
private OAI_ESClient oaiEsClient;
public SetDeliverer(OAI_ESClient oaiEsClient) {
this.oaiEsClient = oaiEsClient;
}
private Set<String> projects = new LinkedHashSet<String>();
public ListSetsType setListBuilder(){
QueryStringQueryBuilder aggQuery = QueryBuilders.queryString("*");
SearchRequestBuilder request = oaiEsClient.getOaiESClient()
.prepareSearch(oaiEsClient.getEsIndex())
.setTypes(oaiEsClient.getEsType())
.setQuery(aggQuery)
.addField("project.value")
.setSize(100000);
SearchResponse getRecordListItems = request.execute().actionGet();
for (SearchHit hit : getRecordListItems.getHits().getHits()){
projects.add(hit.getFields().get("project.value").values().get(0)
.toString());
}
for (String project : projects){
SetType set = new SetType();
set.setSetName("project");
set.setSetSpec("project:" + project);
setList.getSet().add(set);
}
return setList;
}
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment