DataFrameReader Klasa

Odwołanie

Definicja

Przestrzeń nazw:: Microsoft.Spark.Sql

Zestaw:: Microsoft.Spark.dll

Pakiet:: Microsoft.Spark v1.0.0

Ważne

Niektóre informacje odnoszą się do produktu w wersji wstępnej, który może zostać znacząco zmodyfikowany przed wydaniem. Firma Microsoft nie udziela żadnych gwarancji, jawnych lub domniemanych, w odniesieniu do informacji podanych w tym miejscu.

Element DataFrameReader zapewnia funkcjonalność ładowania DataFrame z zewnętrznych systemów magazynowania (np. systemów plików, magazynów klucz-wartość itp.).

public sealed class DataFrameReader

type DataFrameReader = class

Public NotInheritable Class DataFrameReader

Dziedziczenie: Object
DataFrameReader

Metody

Csv(String[])	Ładuje pliki CSV i zwraca wynik jako ramkę danych.
Format(String)	Określa format źródła danych wejściowych.
Jdbc(String, String, Dictionary<String,String>)	Skonstruuj ramkę danych reprezentującą tabelę bazy danych dostępną za pośrednictwem adresu URL adresu URL JDBC o nazwie tabela i właściwości połączenia.
Jdbc(String, String, IEnumerable<String>, Dictionary<String,String>)	Skonstruuj ramkę danych reprezentującą tabelę bazy danych dostępną za pośrednictwem adresu URL adresu URL JDBC o nazwie tabela i właściwości połączenia. Parametr predykatów zawiera wyrażenia listy odpowiednie do włączenia w klauzulach WHERE; każda z nich definiuje jedną partycję ramki danych.
Jdbc(String, String, String, Int64, Int64, Int32, Dictionary<String,String>)	Skonstruuj ramkę danych reprezentującą tabelę bazy danych dostępną za pośrednictwem adresu URL adresu URL JDBC o nazwie tabela. Partycje tabeli zostaną pobrane równolegle na podstawie parametrów przekazanych do tej funkcji.
Json(String[])	Ładuje plik JSON (jeden obiekt na wiersz) i zwraca wynik jako ramkę danych.
Load()	Ładuje dane wejściowe jako ramkę danych dla źródeł danych, które nie wymagają ścieżki (np. zewnętrzne magazyny klucz-wartość).
Load(String)	Ładuje dane wejściowe jako ramkę danych dla źródeł danych, które wymagają ścieżki (np. danych wspieranych przez lokalny lub rozproszony system plików).
Load(String[])	Ładuje dane wejściowe jako ramkę danych z podanych ścieżek.
Option(String, Boolean)	Dodaje opcję wprowadzania dla bazowego źródła danych.
Option(String, Double)	Dodaje opcję wprowadzania dla bazowego źródła danych.
Option(String, Int64)	Dodaje opcję wprowadzania dla bazowego źródła danych.
Option(String, String)	Dodaje opcję wprowadzania dla bazowego źródła danych.
Options(Dictionary<String,String>)	Dodaje opcje wejściowe dla bazowego źródła danych.
Orc(String[])	Ładuje plik ORC i zwraca wynik jako ramkę danych.
Parquet(String[])	Ładuje plik Parquet, zwracając wynik jako ramkę danych.
Schema(String)	Określa schemat przy użyciu danego ciągu sformatowanego w formacie DDL.
Schema(StructType)	Określa schemat przy użyciu polecenia StructType.
Table(String)	Zwraca określoną tabelę jako ramkę danych.
Text(String[])	Ładuje pliki tekstowe i zwraca ramkę danych, której schemat rozpoczyna się od kolumny ciągu o nazwie "value", a następnie kolumn podzielonych na partycje, jeśli istnieją.

Dotyczy