presto-connector/src/main/java/com/facebook/presto/maxcompute/MaxComputeSplitManager.java [109:130]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private List<PartitionSpec> extractPartition(Table table, TupleDomain<ColumnHandle> constraint)
            throws OdpsException
    {
        List<PartitionSpec> res = new ArrayList<>();
        List<PartitionSpec> allPartitions = table.getPartitionSpecs();
        Optional<Map<ColumnHandle, Domain>> domains = constraint.getDomains();
        if (domains.isPresent()) {
            Map<ColumnHandle, Domain> columnHandleDomainMap = domains.get();
            Map<String, Domain> columnConstant = columnHandleDomainMap.entrySet().stream().collect(Collectors.toMap(k -> ((MaxComputeColumnHandle) k.getKey()).getName(), k -> k.getValue()));

            for (PartitionSpec partition : allPartitions) {
                if (validateColumnValues(columnConstant, partition)) {
                    res.add(partition);
                }
            }
        }
        else {
            // If there is no constraint, default scan all partitions
            return allPartitions;
        }
        return res;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



trino-connector/src/main/java/io/trino/plugin/maxcompute/MaxComputeSplitManager.java [109:130]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private List<PartitionSpec> extractPartition(Table table, TupleDomain<ColumnHandle> constraint)
            throws OdpsException
    {
        List<PartitionSpec> res = new ArrayList<>();
        List<PartitionSpec> allPartitions = table.getPartitionSpecs();
        Optional<Map<ColumnHandle, Domain>> domains = constraint.getDomains();
        if (domains.isPresent()) {
            Map<ColumnHandle, Domain> columnHandleDomainMap = domains.get();
            Map<String, Domain> columnConstant = columnHandleDomainMap.entrySet().stream().collect(Collectors.toMap(k -> ((MaxComputeColumnHandle) k.getKey()).getName(), k -> k.getValue()));

            for (PartitionSpec partition : allPartitions) {
                if (validateColumnValues(columnConstant, partition)) {
                    res.add(partition);
                }
            }
        }
        else {
            // If there is no constraint, default scan all partitions
            return allPartitions;
        }
        return res;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -