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

cursorSize configurable

parent 94592129
Branches
Tags
No related merge requests found
...@@ -109,7 +109,7 @@ public class RecordListDeliverer { ...@@ -109,7 +109,7 @@ public class RecordListDeliverer {
private static Map<String, Integer> cursorCollector = new Hashtable<String, Integer >(); private static Map<String, Integer> cursorCollector = new Hashtable<String, Integer >();
private long searchResponseSize; private int searchResponseSize;
BigInteger valueToAdd = BigInteger.valueOf(searchResponseSize); BigInteger valueToAdd = BigInteger.valueOf(searchResponseSize);
ResumptionTokenType resTokenForResponse = new ResumptionTokenType(); ResumptionTokenType resTokenForResponse = new ResumptionTokenType();
...@@ -187,7 +187,7 @@ public class RecordListDeliverer { ...@@ -187,7 +187,7 @@ public class RecordListDeliverer {
.setTypes(OAI_ESClient.getEsType()) .setTypes(OAI_ESClient.getEsType())
.addFields(this.fields) .addFields(this.fields)
.setQuery(recordFilter) .setQuery(recordFilter)
.setSize((int)searchResponseSize) .setSize(searchResponseSize)
.execute() .execute()
.actionGet(); .actionGet();
...@@ -275,16 +275,16 @@ public class RecordListDeliverer { ...@@ -275,16 +275,16 @@ public class RecordListDeliverer {
System.out.println(cursorCollector); System.out.println(cursorCollector);
if(resumptionToken != null && cursorCollector.containsKey(resumptionToken)){ if(resumptionToken != null && cursorCollector.containsKey(resumptionToken)){
System.out.println("RESTOKEN FOUND: " + resumptionToken); System.out.println("RESTOKEN FOUND: " + resumptionToken);
cursor = cursorCollector.get(resumptionToken).intValue() + (int)searchResponseSize; cursor = cursorCollector.get(resumptionToken).intValue() + searchResponseSize;
System.out.println("CUROSOR: " + cursor); System.out.println("CUROSOR: " + cursor);
resTokenForResponse.setCursor(BigInteger.valueOf((long) cursor + (int)searchResponseSize)); resTokenForResponse.setCursor(BigInteger.valueOf((long) cursor + searchResponseSize));
System.out.println("withtoken" + cursorCollector.get(resumptionToken) + (int)searchResponseSize); System.out.println("withtoken" + cursorCollector.get(resumptionToken) + searchResponseSize);
//cursor = cursorCollector.get(resumptionToken) + (int)searchResponseSize; //cursor = cursorCollector.get(resumptionToken) + (int)searchResponseSize;
cursorCollector.put(scrollResp.getScrollId(), cursor); cursorCollector.put(scrollResp.getScrollId(), cursor);
}else { }else {
System.out.println("NO RESTOKEN FOUND"); System.out.println("NO RESTOKEN FOUND");
resTokenForResponse.setCursor(BigInteger.valueOf((int)searchResponseSize)); resTokenForResponse.setCursor(BigInteger.valueOf(searchResponseSize));
cursorCollector.put(scrollResp.getScrollId(), (int)searchResponseSize); cursorCollector.put(scrollResp.getScrollId(), searchResponseSize);
System.out.println(cursorCollector.get(scrollResp.getScrollId())); System.out.println(cursorCollector.get(scrollResp.getScrollId()));
//System.out.println("withOUTtoken" + cursorCollector.get(resumptionToken) + (int)searchResponseSize); //System.out.println("withOUTtoken" + cursorCollector.get(resumptionToken) + (int)searchResponseSize);
} }
...@@ -755,14 +755,18 @@ public class RecordListDeliverer { ...@@ -755,14 +755,18 @@ public class RecordListDeliverer {
this.identifierField = identifierField; this.identifierField = identifierField;
} }
public long getSearchResponseSize() { public int getSearchResponseSize() {
return searchResponseSize; return searchResponseSize;
} }
public void setIdentifierField(long searchResponseSize) { public void setSearchResponseSize(int searchResponseSize) {
this.searchResponseSize = searchResponseSize; this.searchResponseSize = searchResponseSize;
} }
/*public void setBlubb(String test) {
System.out.println("blubb: " + test);
}*/
/* /*
......
...@@ -109,7 +109,7 @@ ...@@ -109,7 +109,7 @@
<property name="types" value="${typeList}" /> <property name="types" value="${typeList}" />
<property name="modifiedField" value="${modifiedField}" /> <property name="modifiedField" value="${modifiedField}" />
<property name="identifierField" value="${identifierField}" /> <property name="identifierField" value="${identifierField}" />
<property name="searchResponseSize" value="searchResponseSize" /> <property name="searchResponseSize" value="${searchResponseSize}" />
</bean> </bean>
<bean id="Record" class="info.textgrid.middleware.RecordDeliverer"> <bean id="Record" class="info.textgrid.middleware.RecordDeliverer">
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment