pyspark - 在 koalas to_table 中设置 NOT NULL 列

Question

当我创建一个 Delta 表时，我可以将一些列设置为 NOT NULL

CREATE TABLE [db_name.]table_name
  [(col_name1 col_type1 [NOT NULL], ...)]
  USING DELTA

有没有办法用 设置非空列koalas.to_table？

Answer 1

无法直接从 执行koalas.to_table，但您可以ALTER TABLE在编写数据后使用语句添加约束（完整文档）：

ALTER TABLE <table_name> CHANGE COLUMN <col_name> SET NOT NULL;

（例如，通过spark.sql命令）