saveAsTable

Hiermee wordt de inhoud van de DataFrame tabel opgeslagen als de opgegeven tabel. Als de tabel al bestaat, is het gedrag afhankelijk van de mode parameter (standaard is het genereren van een uitzondering). Als mode dat het geval is 'overwrite', hoeft het schema van de DataFrame tabel niet overeen te komen met het bestaande tabelschema.

Syntaxis

saveAsTable(name, format=None, mode=None, partitionBy=None, **options)

Parameterwaarden

Kenmerk Typ Beschrijving
name str De naam van de tabel.
format str, optioneel De indeling die wordt gebruikt om op te slaan.
mode str, optioneel Het gedrag wanneer gegevens al bestaan. Geaccepteerde waarden zijn'append', 'overwrite''error'of 'errorifexists' (standaard) en 'ignore'.
partitionBy str of list, optioneel Namen van partitioneringskolommen.
**options Woordenboek Aanvullende tekenreeksopties.

Retouren

Geen

Aantekeningen

Wanneer mode is 'append', als er al een tabel bestaat, worden de opmaak en opties gebruikt. In tegenstelling tot DataFrameWriter.insertInto, DataFrameWriter.saveAsTable gebruikt u kolomnamen om de juiste kolomposities te vinden.

Examples

Maak een tabel op basis van een DataFrame en lees deze terug.

spark.sql("DROP TABLE IF EXISTS tblA")
spark.createDataFrame([
    (100, "Alice"), (120, "Bob"), (140, "Tom")],
    schema=["age", "name"]
).write.saveAsTable("tblA")

spark.read.table("tblA").sort("age").show()
# +---+------------+
# |age|        name|
# +---+------------+
# |100|Alice|
# |120|Bob|
# |140| Tom|
# +---+------------+

spark.sql("DROP TABLE tblA")
  • Last updated on