Skip to content

Commit

Permalink
gh-2421: Made parquet-store consistent too to pass tests
Browse files Browse the repository at this point in the history
  • Loading branch information
t92549 committed Sep 17, 2021
1 parent 67d608a commit 7fd5c96
Showing 1 changed file with 4 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@

import uk.gov.gchq.gaffer.commonutil.pair.Pair;
import uk.gov.gchq.gaffer.data.element.id.DirectedType;
import uk.gov.gchq.gaffer.data.element.id.EdgeId;
import uk.gov.gchq.gaffer.data.element.id.ElementId;
import uk.gov.gchq.gaffer.data.element.id.EntityId;
import uk.gov.gchq.gaffer.data.elementdefinition.view.View;
Expand All @@ -32,8 +33,6 @@
import uk.gov.gchq.gaffer.operation.Operation;
import uk.gov.gchq.gaffer.operation.OperationException;
import uk.gov.gchq.gaffer.operation.SeedMatching;
import uk.gov.gchq.gaffer.operation.data.EdgeSeed;
import uk.gov.gchq.gaffer.operation.data.EntitySeed;
import uk.gov.gchq.gaffer.operation.graph.SeededGraphFilters;
import uk.gov.gchq.gaffer.operation.impl.get.GetAllElements;
import uk.gov.gchq.gaffer.operation.impl.get.GetElements;
Expand Down Expand Up @@ -279,11 +278,11 @@ private ParquetElementSeed seedToParquetObject(final ElementId seed, final Strin
} else {
column = ParquetStore.SOURCE;
}
if (seed instanceof EntitySeed) {
return new ParquetEntitySeed(seed, converter.gafferObjectToParquetObjects(column, ((EntitySeed) seed).getVertex()));
if (seed instanceof EntityId) {
return new ParquetEntitySeed(seed, converter.gafferObjectToParquetObjects(column, ((EntityId) seed).getVertex()));

} else {
return converter.edgeIdToParquetObjects((EdgeSeed) seed);
return converter.edgeIdToParquetObjects((EdgeId) seed);
}
}

Expand Down

0 comments on commit 7fd5c96

Please sign in to comment.