cccs-eric 6fe60a274e
feat(iceberg): Upgrade Iceberg ingestion source to pyiceberg 0.4.0 (#8357)
Co-authored-by: cccs-Dustin <96579982+cccs-Dustin@users.noreply.github.com>
Co-authored-by: Fokko Driesprong <fokko@apache.org>
Co-authored-by: Andrew Sikowitz <andrew.sikowitz@acryl.io>
2023-08-31 13:01:05 -04:00

6 lines
122 B
Python

from pyspark.sql import SparkSession
spark = SparkSession.builder.getOrCreate()
spark.sql("DROP TABLE nyc.taxis PURGE")