SparkSession.ExecuteCommand 方法

定义

命名空间:

Microsoft.Spark.Sql

程序集:

Microsoft.Spark.dll

包:

Microsoft.Spark v1.0.0

在外部执行引擎而不是 Spark 中执行任意字符串命令。 当用户想要从 Spark 中执行某些命令时，这可能很有用。 例如，执行 JDBC 的自定义 DDL/DML 命令、为 ElasticSearch 创建索引、为 Solr 创建核心等。 调用此方法后，将预先执行命令，并且返回的数据帧将包含命令的输出（如果有任何) (）。

[Microsoft.Spark.Since("3.0.0")]
public Microsoft.Spark.Sql.DataFrame ExecuteCommand (string runner, string command, System.Collections.Generic.Dictionary<string,string> options);

[<Microsoft.Spark.Since("3.0.0")>]
member this.ExecuteCommand : string * string * System.Collections.Generic.Dictionary<string, string> -> Microsoft.Spark.Sql.DataFrame

Public Function ExecuteCommand (runner As String, command As String, options As Dictionary(Of String, String)) As DataFrame

参数

runner

String

实现的运行器的类名 ExternalCommandRunner

command

String

要执行的目标命令

options

Dictionary<String,String>

运行器的选项

返回

DataFrame

>DataFrame 对象

属性

SinceAttribute