可以用下面自定义函数导出:
/* @input dbName:数据库名称 * tableName:表名称 * @output 返回分区表建表信息 * @注意: * */ def getDDL(dbName,tableName){ //表不存在提示信息 if(!existsTable(dbName,tableName)){ return "Please check whether the table exists" } //字段与字段类型 col1= schema(loadTable(dbName,tableName)).colDefs.name col2= schema(loadTable(dbName,tableName)).colDefs.typeString col1 = "`"+concat(col1,"`") col2 = "["+concat(col2,",")+"]" //分区列 partitionCol = schema(loadTable(dbName,tableName)).partitionColumnName partitionCol = "`"+concat(partitionCol,"`") //打印建表信息 print("db = database("+'\"'+database+'\")') print("db.createPartitionedTable(table(1:0,"+col1+","+col2+"),`"+tableName+","+partitionCol+")") }
调用例子
login(`admin,`123456)
getDDL("dfs://level2","quotes")