diff options
Diffstat (limited to 'sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala b/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala index e216945fbe..5d2e32b418 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala @@ -2041,7 +2041,7 @@ class Dataset[T] private[sql]( * @since 1.6.0 */ def foreachPartition(func: ForeachPartitionFunction[T]): Unit = - foreachPartition(it => func.call(it.asJava)) + foreachPartition((it: Iterator[T]) => func.call(it.asJava)) /** * Returns the first `n` rows in the [[Dataset]]. |