Skip to content

Commit 2f633b9

Browse files
committed
revert vertical pagination count logic
1 parent a239c6a commit 2f633b9

File tree

1 file changed

+2
-19
lines changed

1 file changed

+2
-19
lines changed

repository/src/main/java/org/apache/atlas/discovery/EntityLineageService.java

+2-19
Original file line numberDiff line numberDiff line change
@@ -592,7 +592,7 @@ private boolean incrementAndCheckIfRelationsLimitReached(AtlasEdge atlasEdge, bo
592592

593593
setHorizontalPaginationFlags(isInput, atlasLineageOnDemandContext, ret, depth, entitiesTraversed, inVertex, inGuid, outVertex, outGuid, inLineageInfo, outLineageInfo);
594594

595-
boolean hasRelationsLimitReached = setVerticalPaginationFlags(depth, atlasLineageOnDemandContext, isInput, entitiesTraversed, inLineageInfo, outLineageInfo, inVertex, outVertex);
595+
boolean hasRelationsLimitReached = setVerticalPaginationFlags(entitiesTraversed, inLineageInfo, outLineageInfo);
596596
if (!hasRelationsLimitReached) {
597597
ret.getRelationsOnDemand().put(inGuid, inLineageInfo);
598598
ret.getRelationsOnDemand().put(outGuid, outLineageInfo);
@@ -602,29 +602,12 @@ private boolean incrementAndCheckIfRelationsLimitReached(AtlasEdge atlasEdge, bo
602602
return hasRelationsLimitReached;
603603
}
604604

605-
private boolean setVerticalPaginationFlags(int depth, AtlasLineageOnDemandContext atlasLineageOnDemandContext, boolean isInput, AtomicInteger entitiesTraversed, LineageInfoOnDemand inLineageInfo, LineageInfoOnDemand outLineageInfo, AtlasVertex inVertex, AtlasVertex outVertex) {
605+
private boolean setVerticalPaginationFlags(AtomicInteger entitiesTraversed, LineageInfoOnDemand inLineageInfo, LineageInfoOnDemand outLineageInfo) {
606606
boolean hasRelationsLimitReached = false;
607607
if (inLineageInfo.isInputRelationsReachedLimit() || outLineageInfo.isOutputRelationsReachedLimit() || isEntityTraversalLimitReached(entitiesTraversed)) {
608608
inLineageInfo.setHasMoreInputs(true);
609609
outLineageInfo.setHasMoreOutputs(true);
610610
hasRelationsLimitReached = true;
611-
612-
if (depth >= 0) {
613-
boolean inIsProcess = Objects.equals(AtlasGraphUtilsV2.getTypeName(inVertex), PROCESS_SUPER_TYPE);
614-
AtlasEdgeDirection inDirection = inIsProcess ? OUT: IN; // Process Node edges always points outwards
615-
AtlasEdgeDirection outDirection = !inIsProcess ? OUT: IN; // Data Node edges always points inwards
616-
String edgeLabel = isInput ? PROCESS_INPUTS_EDGE : PROCESS_OUTPUTS_EDGE;
617-
618-
if (outLineageInfo.getTotalOutputRelationsCount() == 0) {
619-
List<AtlasEdge> outFilteredEdges = getFilteredAtlasEdges(outVertex, outDirection, edgeLabel, atlasLineageOnDemandContext, false);
620-
outLineageInfo.setTotalOutputRelationsCount(outFilteredEdges.size());
621-
}
622-
623-
if (inLineageInfo.getTotalInputRelationsCount() == 0) {
624-
List<AtlasEdge> inFilteredEdges = getFilteredAtlasEdges(inVertex, inDirection, edgeLabel, atlasLineageOnDemandContext, false);
625-
inLineageInfo.setTotalInputRelationsCount(inFilteredEdges.size());
626-
}
627-
}
628611
}
629612

630613
if (!hasRelationsLimitReached) {

0 commit comments

Comments
 (0)