Skip to content

Commit

Permalink
[minor](scan) Delete unused function in ScanNode
Browse files Browse the repository at this point in the history
  • Loading branch information
Gabriel39 committed Nov 28, 2024
1 parent d77bfa0 commit 9cf52aa
Showing 1 changed file with 0 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -727,15 +727,6 @@ public static TScanRangeLocations createSingleScanRangeLocations(FederationBacke
return scanRangeLocation;
}

public boolean ignoreStorageDataDistribution(ConnectContext context, int numBackends) {
return context != null
&& context.getSessionVariable().isIgnoreStorageDataDistribution()
&& !fragment.hasNullAwareLeftAntiJoin()
&& getScanRangeNum()
< ConnectContext.get().getSessionVariable().getParallelExecInstanceNum()
* (numScanBackends() > 0 ? numScanBackends() : numBackends);
}

public int numScanBackends() {
return scanBackendIds.size();
}
Expand Down

0 comments on commit 9cf52aa

Please sign in to comment.