ajantha-bhat commented on a change in pull request #3913: URL: https://github.com/apache/carbondata/pull/3913#discussion_r486048413
########## File path: integration/presto/src/main/prestodb/org/apache/carbondata/presto/CarbondataSplitManager.java ########## @@ -117,6 +122,16 @@ public ConnectorSplitSource getSplits(ConnectorTransactionHandle transactionHand // file metastore case tablePath can be null, so get from location location = table.getStorage().getLocation(); } + List<PartitionSpec> filteredPartitions = new ArrayList<>(); + if (layout.getPartitionColumns().size() > 0 && layout.getPartitions().isPresent()) { + List<String> colNames = + layout.getPartitionColumns().stream().map(x -> ((HiveColumnHandle) x).getName()) + .collect(Collectors.toList()); + for (HivePartition partition : layout.getPartitions().get()) { + filteredPartitions.add(new PartitionSpec(colNames, Review comment: ``` presto:redods> select dtm,hh from dw_log_ubt_partition_carbon_neww; dtm | hh -------------+------------ part_dtm_01 | part_hh_01 part_dtm_01 | part_hh_01 part_dtm_01 | part_hh_02 part_dtm_20 | part_hh_21 part_dtm_01 | part_hh_03 part_dtm_21 | NULL (6 rows) Query 20200910_035416_00017_wv9qh, FINISHED, 3 nodes Splits: 22 total, 22 done (100.00%) 0:01 [6 rows, 176B] [9 rows/s, 282B/s] presto:redods> select dtm,hh from dw_log_ubt_partition_carbon_neww where (dtm = 'part_dtm_01' and hh = 'part_hh_03') or dtm='part_dtm_21'; dtm | hh -------------+------------ part_dtm_01 | part_hh_03 part_dtm_21 | NULL (2 rows) Query 20200910_035548_00018_wv9qh, FINISHED, 3 nodes Splits: 18 total, 18 done (100.00%) 0:01 [2 rows, 0B] [1 rows/s, 0B/s] ``` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org