Github user jerryshao commented on the issue:

    https://github.com/apache/spark/pull/19586
  
    @ConeyLiu what about the below example, does your implementation support 
this?
    
    ```scala
    
    trait Base { val name: String }
    case class A(name: String) extends Base
    case class B(name: String) extends Base
    
    sc.parallelize(Seq(A("a"), B("b"))).map { i => (i, 1) }.reduceByKey(_ + 
_).collect()
    ```
    
    Here not all the elements have same class type, does your PR here support 
such scenario?



---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org

Reply via email to