amoro
amoro copied to clipboard
[spark3] support data frame api for keyed table
support v1 dataframe api
df.format("arctic").save("xxxx")
df.format("arctic").mode("overwrite").save("xxx")
val df = spark.read.format("arctic").load("xxx")
suport v2 dataframe api
df.writeTo("xxx")
df.writeTo("xxx").overwritePartitions()
val df = spark.read.table("xxx")