public static List<DataFile> matchingPartitions(
            List<DataFile> dataFiles, PartitionSpec partitionSpec, Map<String, Object> partitionValues) {
        Types.StructType partitionType = partitionSpec.partitionType();
        Record partitionRecord = GenericRecord.create(partitionType).copy(partitionValues);
        StructLikeWrapper expected = StructLikeWrapper.forType(partitionType).set(partitionRecord);
        return dataFiles.stream()
                .filter(
                        df -> {
                            StructLikeWrapper wrapper =
                                    StructLikeWrapper.forType(partitionType).set(df.partition());
                            return wrapper.equals(expected);
                        })
                .collect(Collectors.toList());
    }
Assert table contains the expected list of records after waiting up to {@code maxCheckCount}
with {@code checkInterval}
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/test/java/org/apache/inlong/sort/iceberg/sink/util/SimpleDataUtil.java