本节介绍如何将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);