DataFrame.ToLocalIterator 方法

定义

命名空间:

Microsoft.Spark.Sql

程序集:

Microsoft.Spark.dll

包:

Microsoft.Spark v1.0.0

重载

ToLocalIterator(Boolean)	返回一个迭代器，其中包含此 DataFrame中的所有行。 迭代器占用的内存量与此 DataFrame中最大的分区一样多。 使用预提取时，最多可能会消耗 2 个最大分区的内存。
ToLocalIterator()	返回一个迭代器，其中包含此 DataFrame中的所有行。 迭代器占用的内存量与此 DataFrame中最大的分区一样多。

ToLocalIterator(Boolean)

返回一个迭代器，其中包含此 DataFrame中的所有行。 迭代器占用的内存量与此 DataFrame中最大的分区一样多。 使用预提取时，最多可能会消耗 2 个最大分区的内存。

[Microsoft.Spark.Since("3.0.0")]
public System.Collections.Generic.IEnumerable<Microsoft.Spark.Sql.Row> ToLocalIterator (bool prefetchPartitions);

[<Microsoft.Spark.Since("3.0.0")>]
member this.ToLocalIterator : bool -> seq<Microsoft.Spark.Sql.Row>

Public Iterator Function ToLocalIterator (prefetchPartitions As Boolean) As IEnumerable(Of Row)

参数

prefetchPartitions

Boolean

如果 Spark 应在需要之前预提取下一个分区。

返回

IEnumerable<Row>

行对象

属性

SinceAttribute

ToLocalIterator()

返回一个迭代器，其中包含此 DataFrame中的所有行。 迭代器占用的内存量与此 DataFrame中最大的分区一样多。

public System.Collections.Generic.IEnumerable<Microsoft.Spark.Sql.Row> ToLocalIterator ();

member this.ToLocalIterator : unit -> seq<Microsoft.Spark.Sql.Row>

Public Function ToLocalIterator () As IEnumerable(Of Row)

返回

IEnumerable<Row>

行对象