“Drop -Spalten Delta Tabelle” Code-Antworten

Drop -Spalten Delta Tabelle

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 -Spalte mit Datafame

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

Ähnliche Antworten wie “Drop -Spalten Delta Tabelle”

Fragen ähnlich wie “Drop -Spalten Delta Tabelle”

Weitere verwandte Antworten zu “Drop -Spalten Delta Tabelle” auf Python

Durchsuchen Sie beliebte Code-Antworten nach Sprache

Durchsuchen Sie andere Codesprachen