“Tabela Delta de colunas de soltar” Respostas de código

Tabela Delta de colunas de soltar

schema='<schema>'
table='<table>'

columnstoDrop = ["<column or columns to drop>"]
display(spark.sql(f"describe table {schema}.{table}"))
df = spark.sql(f"Select * from {schema}.{table}")

df1 = df.drop(*columnstoDrop)

spark.sql(f"DROP TABLE if exists {schema}.{table}")

df1.write \
  .format(write_format) \
  .mode('overwrite') \
  .option("overwriteSchema", "true") \
  .save(f"{save_path}{table}")

spark.sql(f"CREATE  TABLE  {schema}.{table}  USING DELTA LOCATION '{save_path}{table}'")

display(spark.sql(f"describe table {schema}.{table}"))
Anthony Taylor

Drop coluna do datfame

df.drop(['B', 'C'], axis=1)
Arrogant Alpaca

Respostas semelhantes a “Tabela Delta de colunas de soltar”

Perguntas semelhantes a “Tabela Delta de colunas de soltar”

Mais respostas relacionadas para “Tabela Delta de colunas de soltar” em Python

Procure respostas de código populares por idioma

Procurar outros idiomas de código