本文介绍如何将Hive或SparkSQL的Parquet表转为Delta表。

使用示例如下:
  • Scala
    import io.delta.tables._
    // 非分区表
    val deltaTable = DeltaTable.convertToDelta(spark, "parquet.`/path/to/table`")
    // 分区表
    val partitionedDeltaTable = DeltaTable.convertToDelta(spark, "parquet.`/path/to/table`", "date string")
  • SQL
    -- 非分区表
    CONVERT TO DELTA parquet_table;
    -- 分区表
    CONVERT TO DELTA parquet_table PARTITIONED BY (date STRING);