Spark操作Kudu 修改表

  • 代码示例
/*** 添加列* @param kuduContext*/
def addColumn(kuduContext: KuduContext): Unit ={val alterTableOptions: AlterTableOptions = new AlterTableOptionsalterTableOptions.addColumn(new ColumnSchema.ColumnSchemaBuilder("Address", Type.STRING).nullable(true).build)try {kuduContext.syncClient.alterTable(tableName, alterTableOptions)} catch {case ex:Exception => ex.printStackTrace()}
}