Spark：DataFrame 中的类型转换

Question

我在数据框中有一个字符串类型的字段。我正在使用覆盖模式保存到 mysql。字符串字段正在 mysql 中保存为文本字段。我想将它保存为 varchar (40)。

df.write.mode("overwrite").jdbc(mysqlUrl,tableName,properties)

我怎样才能达到同样的效果？

还有可以在数据框中应用索引吗？

Answer 1

在写入数据库前使用cast函数转换data frame中的数据类型

df.selectExpr(cast(column name) as int)  fromid).write.mode("overwrite").jdbc(mysqlUrl,tableName,properties)

可以使用窗口函数应用索引。