DataFrameWriterV2 类

定义

命名空间:

Microsoft.Spark.Sql

程序集:

Microsoft.Spark.dll

包:

Microsoft.Spark v1.0.0

用于使用 v2 API 将 写入 DataFrame 外部存储的接口。

[Microsoft.Spark.Since("3.0.0")]
public sealed class DataFrameWriterV2

[<Microsoft.Spark.Since("3.0.0")>]
type DataFrameWriterV2 = class

Public NotInheritable Class DataFrameWriterV2

继承

Object

DataFrameWriterV2

属性

SinceAttribute

方法

Append()	将数据帧的内容追加到输出表中。
Create()	根据数据帧的内容创建新表。
CreateOrReplace()	创建新表或将现有表替换为数据帧的内容。
Option(String, Boolean)	添加基础数据源的输出选项。
Option(String, Double)	添加基础数据源的输出选项。
Option(String, Int64)	添加基础数据源的输出选项。
Option(String, String)	添加基础数据源的输出选项。
Options(Dictionary<String,String>)	添加基础数据源的输出选项。
Overwrite(Column)	使用输出表中数据帧的内容覆盖与给定筛选条件匹配的行。
OverwritePartitions()	覆盖数据帧包含至少一行的所有分区，并在输出表中包含数据帧的内容。
PartitionedBy(Column, Column[])	使用给定列或转换对 、 Create()CreateOrReplace()或 Replace() 创建的输出表进行分区。
Replace()	将现有表替换为数据帧的内容。
TableProperty(String, String)	添加表属性。
Using(String)	指定基础输出数据源的提供程序。 Spark 的默认目录支持“parquet”、“json”等。