public static Table createTable(
            String path, Map<String, String> properties, boolean partitioned) {
        PartitionSpec spec;
        if (partitioned) {
            spec = PartitionSpec.builderFor(SCHEMA).identity("data").build();
        } else {
            spec = PartitionSpec.unpartitioned();
        }
        return new HadoopTables().create(SCHEMA, spec, properties, path);
    }
Copy from iceberg-flink:iceberg-flink-1.15:1.1.x
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/test/java/org/apache/inlong/sort/iceberg/sink/util/SimpleDataUtil.java