0

在创建表时，我在 spark 数据集中使用createTableColumnTypes数据库列数据类型而不是默认值。它非常适合，VARCHAR(n)但如果我使用TEXT它会抛出错误。代码是用 Java 编写的

Dataset < Row > df = sqlContext.read()
                    .format("com.databricks.spark.csv")
                    .schema(sparkDataSchema)
                    .option("delimiter", dataDelimeter)
                    .option("header", true).option("quote", "\"")
                    .option("escape", "\"").load(paths.split(","));


df.write().option("truncate", true).mode(SaveMode.Overwrite).option("createTableColumnTypes", customSchema).jdbc(url, tableName, connectionProperties);

错误如下

线程“主”org.apache.spark.sql.catalyst.parser.ParseException 中的异常：不支持 DataType 文本。（第 1 行，第 29 行）

4

0 回答 0