jffwang
/
hetu-core
0
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

[I4CEKZ] fixed dynamic filter invocation criteria in HivePageSource

This commit is contained in:
Nitin Kashyap 2021-09-29 13:30:33 +05:30
parent 4e6c3fdcf3
commit 1b4fa7e30d
No known key found for this signature in database
GPG Key ID: 7C4222EE7DDEFC35
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
presto-hive/src/main/java/io/prestosql/plugin/hive/HivePageSource.java
View File

@ -307,6 +307,7 @@ public class HivePageSource
private List<Map<Integer, ColumnHandle>> getEligibleColumnsForRowFiltering(int channelCount, List<Map<ColumnHandle, DynamicFilter>> dynamicFilters)
{
boolean eligibleFilterFound = false;
List<Map<Integer, ColumnHandle>> eligibleColumnsList = new ArrayList<>();
for (Map<ColumnHandle, DynamicFilter> dynamicFilter : dynamicFilters) {
Map<Integer, ColumnHandle> eligibleColumns = new HashMap<>();
@ -319,8 +320,15 @@ public class HivePageSource
}
}
if (eligibleColumns.size() > 0) {
eligibleFilterFound = true;
}
eligibleColumnsList.add(eligibleColumns);
}
if (eligibleFilterFound == false) {
return new ArrayList<>();
}
return eligibleColumnsList;
}