DataFrameReader 클래스

  • 참조

정의

네임스페이스:
Microsoft.Spark.Sql
어셈블리:
Microsoft.Spark.dll
패키지:
Microsoft.Spark v1.0.0

DataFrameReader는 외부 스토리지 시스템(예: 파일 시스템, 키-값 저장소 등)에서 를 로드 DataFrame 하는 기능을 제공합니다.

public sealed class DataFrameReader
type DataFrameReader = class
Public NotInheritable Class DataFrameReader
상속
Object
DataFrameReader

메서드

Csv(String[])

CSV 파일을 로드하고 결과를 DataFrame으로 반환합니다.
Format(String)

입력 데이터 원본 형식을 지정합니다.
Jdbc(String, String, Dictionary<String,String>)

테이블 및 연결 속성이라는 JDBC URL URL을 통해 액세스할 수 있는 데이터베이스 테이블을 나타내는 DataFrame을 생성합니다.
Jdbc(String, String, IEnumerable<String>, Dictionary<String,String>)

테이블 및 연결 속성이라는 JDBC URL URL을 통해 액세스할 수 있는 데이터베이스 테이블을 나타내는 DataFrame을 생성합니다. 조건자 매개 변수는 WHERE 절에 포함하기에 적합한 목록 식을 제공합니다. 각 파티션은 DataFrame의 하나의 파티션을 정의합니다.
Jdbc(String, String, String, Int64, Int64, Int32, Dictionary<String,String>)

테이블이라는 JDBC URL URL을 통해 액세스할 수 있는 데이터베이스 테이블을 나타내는 DataFrame을 생성합니다. 테이블의 파티션은 이 함수에 전달된 매개 변수에 따라 병렬로 검색됩니다.
Json(String[])

JSON 파일(줄당 하나의 개체)을 로드하고 결과를 DataFrame으로 반환합니다.
Load()

경로가 필요하지 않은 데이터 원본(예: 외부 키-값 저장소)에 대한 입력을 DataFrame으로 로드합니다.
Load(String)

경로가 필요한 데이터 원본(예: 로컬 또는 분산 파일 시스템에서 백업하는 데이터)에 대한 입력을 DataFrame으로 로드합니다.
Load(String[])

지정된 경로에서 입력을 DataFrame으로 로드합니다.
Option(String, Boolean)

기본 데이터 원본에 대한 입력 옵션을 추가합니다.
Option(String, Double)

기본 데이터 원본에 대한 입력 옵션을 추가합니다.
Option(String, Int64)

기본 데이터 원본에 대한 입력 옵션을 추가합니다.
Option(String, String)

기본 데이터 원본에 대한 입력 옵션을 추가합니다.
Options(Dictionary<String,String>)

기본 데이터 원본에 대한 입력 옵션을 추가합니다.
Orc(String[])

ORC 파일을 로드하고 결과를 DataFrame으로 반환합니다.
Parquet(String[])

Parquet 파일을 로드하여 결과를 DataFrame으로 반환합니다.
Schema(String)

지정된 DDL 형식 문자열을 사용하여 스키마를 지정합니다.
Schema(StructType)

를 사용하여 StructType스키마를 지정합니다.
Table(String)

지정된 테이블을 DataFrame으로 반환합니다.
Text(String[])

텍스트 파일을 로드하고 스키마가 "value"라는 문자열 열로 시작하고 분할된 열(있는 경우)으로 시작하는 DataFrame을 반환합니다.

적용 대상