Github user ceedubs commented on a diff in the pull request:
https://github.com/apache/spark/pull/21971#discussion_r207246356
--- Diff: core/src/main/scala/org/apache/spark/rdd/AsyncRDDActions.scala ---
@@ -61,6 +62,36 @@ class AsyncRDDActions[T: ClassTag](self: RDD[T]) extends
Github user ceedubs commented on a diff in the pull request:
https://github.com/apache/spark/pull/21971#discussion_r207246593
--- Diff: core/src/main/scala/org/apache/spark/rdd/AsyncRDDActions.scala ---
@@ -61,6 +62,36 @@ class AsyncRDDActions[T: ClassTag](self: RDD[T]) extends
GitHub user ceedubs opened a pull request:
https://github.com/apache/spark/pull/21971
[SPARK-24947] [Core] aggregateAsync and foldAsync
See the description in the [Jira
ticket](https://issues.apache.org/jira/browse/SPARK-24947).
This contribution is my original work
GitHub user ceedubs opened a pull request:
https://github.com/apache/spark/pull/20869
Improve implicitNotFound message for Encoder
The `implicitNotFound` message for `Encoder` doesn't mention the name of
the type for which it can't find an encoder. Furthermore, it