DataFrameWriter Třída

  • Reference

Definice

Obor názvů:
Microsoft.Spark.Sql
Sestavení:
Microsoft.Spark.dll
Balíček:
Microsoft.Spark v1.0.0

Rozhraní sloužící k zápisu datového rámce do externích úložných systémů (např. systémů souborů, úložišť klíč-hodnota atd.).

public sealed class DataFrameWriter
type DataFrameWriter = class
Public NotInheritable Class DataFrameWriter
Dědičnost
Object
DataFrameWriter

Metody

BucketBy(Int32, String, String[])

Zasadí výstup podle daných sloupců. Pokud je zadáno, výstup se rozloží v systému souborů podobně jako schéma vytváření kontejnerů Hive.
Csv(String)

Uloží obsah datového rámce ve formátu CSV na zadanou cestu.
Format(String)

Určuje podkladový výstupní zdroj dat. Mezi integrované možnosti patří parquet, json atd.
InsertInto(String)

Vloží obsah datového rámce do zadané tabulky. Vyžaduje, aby schéma datového rámce bylo stejné jako schéma tabulky.
Jdbc(String, String, Dictionary<String,String>)

Uloží obsah datového rámce do tabulky externí databáze přes JDBC.
Json(String)

Uloží obsah datového rámce ve formátu JSON na zadanou cestu.
Mode(SaveMode)

Určuje chování, když data nebo tabulka již existují.
Mode(String)

Určuje chování, když data nebo tabulka již existují.
Option(String, Boolean)

Přidá možnost výstupu pro podkladový zdroj dat.
Option(String, Double)

Přidá možnost výstupu pro podkladový zdroj dat.
Option(String, Int64)

Přidá možnost výstupu pro podkladový zdroj dat.
Option(String, String)

Přidá možnost výstupu pro podkladový zdroj dat.
Options(Dictionary<String,String>)

Přidá možnosti výstupu pro podkladový zdroj dat.
Orc(String)

Uloží obsah datového rámce ve formátu ORC na zadanou cestu.
Parquet(String)

Uloží obsah datového rámce ve formátu Parquet na zadanou cestu.
PartitionBy(String[])

Rozdělí výstup podle daných sloupců v systému souborů. Pokud je zadáno, výstup se rozloží v systému souborů podobně jako schéma dělení Hive.
Save()

Uloží obsah datového rámce jako zadanou tabulku.
Save(String)

Uloží obsah datového rámce na zadanou cestu.
SaveAsTable(String)

Uloží obsah datového rámce jako zadanou tabulku.
SortBy(String, String[])

Seřadí výstup v každém kbelíku podle daných sloupců.
Text(String)

Uloží obsah datového rámce v textovém souboru na zadanou cestu.

Platí pro