DataFrameWriter クラス

定義

名前空間:

Microsoft.Spark.Sql

アセンブリ:

Microsoft.Spark.dll

パッケージ:

Microsoft.Spark v1.0.0

DataFrame を外部ストレージ システム (ファイル システム、キー値ストアなど) に書き込む際に使用されるインターフェイス。

public sealed class DataFrameWriter

type DataFrameWriter = class

Public NotInheritable Class DataFrameWriter

継承

Object

DataFrameWriter

メソッド

BucketBy(Int32, String, String[])	指定された列で出力をバケット化します。 指定した場合、出力は Hive のバケットスキームと同様にファイル システムにレイアウトされます。
Csv(String)	DataFrame の内容を CSV 形式で指定したパスに保存します。
Format(String)	基になる出力データ ソースを指定します。 組み込みオプションには、"parquet"、"json" などがあります。
InsertInto(String)	指定したテーブルに DataFrame の内容を挿入します。 DataFrame のスキーマがテーブルのスキーマと同じである必要があります。
Jdbc(String, String, Dictionary<String,String>)	JDBC を使用して DataFrame の内容を外部データベース テーブルに保存します
Json(String)	DataFrame の内容を JSON 形式で指定されたパスに保存します。
Mode(SaveMode)	データまたはテーブルが既に存在する場合の動作を指定します。
Mode(String)	データまたはテーブルが既に存在する場合の動作を指定します。
Option(String, Boolean)	基になるデータ ソースの出力オプションを追加します。
Option(String, Double)	基になるデータ ソースの出力オプションを追加します。
Option(String, Int64)	基になるデータ ソースの出力オプションを追加します。
Option(String, String)	基になるデータ ソースの出力オプションを追加します。
Options(Dictionary<String,String>)	基になるデータ ソースの出力オプションを追加します。
Orc(String)	DataFrame の内容を ORC 形式で指定したパスに保存します。
Parquet(String)	指定したパスで、DataFrame の内容を Parquet 形式で保存します。
PartitionBy(String[])	ファイル システム上の指定された列で出力をパーティション分割します。 指定した場合、出力は Hive のパーティション分割スキームと同様にファイル システムにレイアウトされます。
Save()	DataFrame の内容を指定したテーブルとして保存します。
Save(String)	指定したパスに DataFrame の内容を保存します。
SaveAsTable(String)	DataFrame の内容を指定したテーブルとして保存します。
SortBy(String, String[])	各バケットの出力を指定された列で並べ替えます。
Text(String)	DataFrame の内容を、指定したパスのテキスト ファイルに保存します。