Skip to content

Commit

Permalink
Updated to override the transformIterator to avoid failures when filt…
Browse files Browse the repository at this point in the history
…ered (#2101)

* Updated to override the transformIterator to avoid failures when filtered
Conflicts:
	web-services/query/src/main/java/datawave/webservice/query/logic/filtered/FilteredQueryLogic.java
  • Loading branch information
ivakegg authored and hgklohr committed Sep 28, 2023
1 parent e8851ba commit 8a97485
Showing 1 changed file with 11 additions and 0 deletions.
Expand Up @@ -6,9 +6,11 @@

import org.apache.accumulo.core.client.AccumuloClient;
import org.apache.accumulo.core.security.Authorizations;
import org.apache.commons.collections4.iterators.TransformIterator;

import datawave.webservice.query.Query;
import datawave.webservice.query.configuration.GenericQueryConfiguration;
import datawave.webservice.query.iterator.DatawaveTransformIterator;
import datawave.webservice.query.logic.DelegatingQueryLogic;
import datawave.webservice.query.logic.QueryLogic;

Expand Down Expand Up @@ -88,4 +90,13 @@ public Iterator<Object> iterator() {
public Object clone() throws CloneNotSupportedException {
return new FilteredQueryLogic(this);
}

@Override
public TransformIterator getTransformIterator(Query settings) {
if (!filtered) {
return super.getTransformIterator(settings);
} else {
return new DatawaveTransformIterator(iterator());
}
}
}

0 comments on commit 8a97485

Please sign in to comment.