:: 演进中 :

用于指定如何创建/替换 Delta 表的构建器。您必须在执行构建器之前指定表名或路径。您可以指定表列、分区列、数据位置、表注释和属性，以及如何创建/替换 Delta 表。

执行构建器后，将返回 DeltaTable 的实例。

使用表名创建带生成列的 Delta 表的 Scala 示例

val table: DeltaTable = DeltaTable.create()
  .tableName("testTable")
  .addColumn("c1",  dataType = "INT", nullable = false)
  .addColumn(
    DeltaTable.columnBuilder("c2")
      .dataType("INT")
      .generatedAlwaysAs("c1 + 10")
      .build()
  )
  .addColumn(
    DeltaTable.columnBuilder("c3")
      .dataType("INT")
      .comment("comment")
      .nullable(true)
      .build()
  )
  .partitionedBy("c1", "c2")
  .execute()

使用位置创建 Delta 表的 Scala 示例

val table: DeltaTable = DeltaTable.createIfNotExists(spark)
  .location("/foo/`bar`")
  .addColumn("c1", dataType = "INT", nullable = false)
  .addColumn(
    DeltaTable.columnBuilder(spark, "c2")
      .dataType("INT")
      .generatedAlwaysAs("c1 + 10")
      .build()
  )
  .addColumn(
    DeltaTable.columnBuilder(spark, "c3")
      .dataType("INT")
      .comment("comment")
      .nullable(true)
      .build()
  )
  .partitionedBy("c1", "c2")
  .execute()

替换表的 Java 示例

DeltaTable table = DeltaTable.replace()
  .tableName("db.table")
  .addColumn("c1",  "INT", false)
  .addColumn(
    DeltaTable.columnBuilder("c2")
      .dataType("INT")
      .generatedAlwaysBy("c1 + 10")
      .build()
  )
  .execute();