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

!1140 [I4CEKZ] fix dynamic filtering invoke criteria in hive pagesource 

Merge pull request !1140 from Nitin-Kashyap/fix.dynamicfilter.I4CEKZ
This commit is contained in:
i-robot 2021-09-29 10:47:47 +00:00 committed by Gitee
parent e7a7e5f53e 1b4fa7e30d
commit 8744e16e9f
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;
}