DataFrameReader Klasse

  • Referenz

Definition

Namespace:
Microsoft.Spark.Sql
Assembly:
Microsoft.Spark.dll
Paket:
Microsoft.Spark v1.0.0

DataFrameReader bietet Funktionen zum Laden von aus DataFrame externen Speichersystemen (z. B. Dateisysteme, Schlüssel-Wert-Speicher usw.).

public sealed class DataFrameReader
type DataFrameReader = class
Public NotInheritable Class DataFrameReader
Vererbung
Object
DataFrameReader

Methoden

Csv(String[])

Lädt CSV-Dateien und gibt das Ergebnis als DataFrame zurück.
Format(String)

Gibt das Format der Eingabedatenquelle an.
Jdbc(String, String, Dictionary<String,String>)

Erstellen Sie einen DataFrame, der die Datenbanktabelle darstellt, auf die über die JDBC-URL-URL namens Tabelle und Verbindungseigenschaften zugegriffen werden kann.
Jdbc(String, String, IEnumerable<String>, Dictionary<String,String>)

Erstellen Sie einen DataFrame, der die Datenbanktabelle darstellt, auf die über die JDBC-URL-URL namens Tabelle und Verbindungseigenschaften zugegriffen werden kann. Der Prädikate-Parameter gibt eine Liste von Ausdrücken an, die für die Aufnahme in WHERE-Klauseln geeignet sind. jede definiert eine Partition des DataFrames.
Jdbc(String, String, String, Int64, Int64, Int32, Dictionary<String,String>)

Erstellen Sie einen DataFrame, der die Datenbanktabelle darstellt, auf die über die JDBC-URL-URL namens table zugegriffen werden kann. Partitionen der Tabelle werden basierend auf den parametern, die an diese Funktion übergeben werden, parallel abgerufen.
Json(String[])

Lädt eine JSON-Datei (ein Objekt pro Zeile) und gibt das Ergebnis als DataFrame zurück.
Load()

Lädt die Eingabe als DataFrame für Datenquellen, die keinen Pfad erfordern (z. B. externe Schlüssel-Wert-Speicher).
Load(String)

Lädt die Eingabe als DataFrame für Datenquellen, die einen Pfad benötigen (z. B. Daten, die von einem lokalen oder verteilten Dateisystem gesichert werden).
Load(String[])

Lädt die Eingabe in als DataFrame aus den angegebenen Pfaden.
Option(String, Boolean)

Fügt eine Eingabeoption für die zugrunde liegende Datenquelle hinzu.
Option(String, Double)

Fügt eine Eingabeoption für die zugrunde liegende Datenquelle hinzu.
Option(String, Int64)

Fügt eine Eingabeoption für die zugrunde liegende Datenquelle hinzu.
Option(String, String)

Fügt eine Eingabeoption für die zugrunde liegende Datenquelle hinzu.
Options(Dictionary<String,String>)

Fügt Eingabeoptionen für die zugrunde liegende Datenquelle hinzu.
Orc(String[])

Lädt eine ORC-Datei und gibt das Ergebnis als DataFrame zurück.
Parquet(String[])

Lädt eine Parquet-Datei und gibt das Ergebnis als DataFrame zurück.
Schema(String)

Gibt das Schema mithilfe der angegebenen DDL-formatierten Zeichenfolge an.
Schema(StructType)

Gibt das Schema mithilfe StructTypevon an.
Table(String)

Gibt die angegebene Tabelle als DataFrame zurück.
Text(String[])

Lädt Textdateien und gibt einen DataFrame zurück, dessen Schema mit einer Zeichenfolgenspalte mit dem Namen "value" beginnt, gefolgt von partitionierten Spalten, falls vorhanden.

Gilt für: