Skip to content

Commit

Permalink
tweak set usage
Browse files Browse the repository at this point in the history
  • Loading branch information
tb06904 committed Jan 21, 2025
1 parent 46b32d3 commit 2b911f2
Showing 1 changed file with 16 additions and 16 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -429,7 +429,7 @@ public Iterator<Vertex> vertices(final Object... vertexIds) {
.first(getOperation)
.then(new Limit<>(variables.getElementsLimit(), true))
.build();
final Set<Element> result = new HashSet<>(IterableUtils.toList(execute(chain)));
final List<? extends Element> result = IterableUtils.toList(execute(chain));

// Warn of truncation
if (result.size() >= variables.getElementsLimit()) {
Expand All @@ -440,11 +440,11 @@ public Iterator<Vertex> vertices(final Object... vertexIds) {

// Translate results to GafferPop elements
final GafferPopElementGenerator generator = new GafferPopElementGenerator(this);
final Set<Vertex> translatedResults = StreamSupport.stream(result.spliterator(), false)
final List<Vertex> translatedResults = StreamSupport.stream(result.spliterator(), false)
.map(generator::_apply)
.filter(Vertex.class::isInstance)
.map(e -> (Vertex) e)
.collect(Collectors.toSet());
.collect(Collectors.toList());

// Check for seeds that are not entities but are vertices on an edge (orphan vertices)
if (variables.getIncludeOrphanedVertices()) {
Expand Down Expand Up @@ -597,16 +597,16 @@ public Iterator<Edge> edges(final Object... elementIds) {
}

// Run requested chain on the graph and buffer to set to avoid reusing iterator
final Set<Element> result = new HashSet<>(IterableUtils.toList(execute(getOperation)));
final List<? extends Element> result = IterableUtils.toList(execute(getOperation));

// Translate results to Gafferpop elements
final GafferPopElementGenerator generator = new GafferPopElementGenerator(this);
final Set<Edge> translatedResults = StreamSupport.stream(result.spliterator(), false)
final List<Edge> translatedResults = StreamSupport.stream(result.spliterator(), false)
.map(generator::_apply)
.filter(Edge.class::isInstance)
.map(e -> (Edge) e)
.limit(variables.getElementsLimit())
.collect(Collectors.toSet());
.collect(Collectors.toList());

if (translatedResults.size() >= variables.getElementsLimit()) {
LOGGER.warn(
Expand Down Expand Up @@ -819,15 +819,15 @@ private Iterator<GafferPopVertex> verticesWithSeedsAndView(final List<ElementSee
.first(getOperation)
.then(new Limit<>(variables.getElementsLimit(), true))
.build();
final Set<Element> result = new HashSet<>(IterableUtils.toList(execute(chain)));
final List<? extends Element> result = IterableUtils.toList(execute(chain));

// Translate results to Gafferpop elements
final GafferPopElementGenerator generator = new GafferPopElementGenerator(this);
final Set<GafferPopVertex> translatedResults = StreamSupport.stream(result.spliterator(), false)
final List<GafferPopVertex> translatedResults = StreamSupport.stream(result.spliterator(), false)
.map(generator::_apply)
.filter(GafferPopVertex.class::isInstance)
.map(e -> (GafferPopVertex) e)
.collect(Collectors.toSet());
.collect(Collectors.toList());

return translatedResults.iterator();
}
Expand Down Expand Up @@ -855,16 +855,16 @@ private Iterator<Vertex> adjVerticesWithSeedsAndView(final List<ElementSeed> see
}

// GetAdjacentIds provides list of entity seeds so run a GetElements to get the actual Entities
final Set<Element> result = new HashSet<>(IterableUtils.toList(
execute(new OperationChain.Builder().first(builder.build()).build())));
final List<? extends Element> result = IterableUtils.toList(
execute(new OperationChain.Builder().first(builder.build()).build()));

// Translate results to Gafferpop elements
final GafferPopElementGenerator generator = new GafferPopElementGenerator(this);
final Set<Vertex> translatedResults = StreamSupport.stream(result.spliterator(), false)
final List<Vertex> translatedResults = StreamSupport.stream(result.spliterator(), false)
.map(generator::_apply)
.filter(Vertex.class::isInstance)
.map(e -> (Vertex) e)
.collect(Collectors.toSet());
.collect(Collectors.toList());

// Check for seeds that are not entities but are vertices on an edge (orphan vertices)
if (variables.getIncludeOrphanedVertices()) {
Expand Down Expand Up @@ -909,16 +909,16 @@ private Iterator<Edge> edgesWithSeedsAndView(final List<ElementSeed> seeds, fina
}

// Run requested chain on the graph
final Set<Element> result = new HashSet<>(IterableUtils.toList(execute(getOperation)));
final List<? extends Element> result = IterableUtils.toList(execute(getOperation));

// Translate results to Gafferpop elements
final GafferPopElementGenerator generator = new GafferPopElementGenerator(this, true);
final Set<Edge> translatedResults = StreamSupport.stream(result.spliterator(), false)
final List<Edge> translatedResults = StreamSupport.stream(result.spliterator(), false)
.map(generator::_apply)
.filter(Edge.class::isInstance)
.map(e -> (Edge) e)
.limit(variables.getElementsLimit())
.collect(Collectors.toSet());
.collect(Collectors.toList());

return translatedResults.iterator();
}
Expand Down

0 comments on commit 2b911f2

Please sign in to comment.