public static StructLikeSet actualRowSet(Table table, Long snapshotId, String... columns)
            throws IOException {
        table.refresh();
        StructLikeSet set = StructLikeSet.create(table.schema().asStruct());
        try (CloseableIterable<Record> reader =
                IcebergGenerics.read(table)
                        .useSnapshot(snapshotId == null ? table.currentSnapshot().snapshotId() : snapshotId)
                        .select(columns)
                        .build()) {
            reader.forEach(set::add);
        }
        return set;
    }
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