Uploaded image for project: 'Spark'
  1. Spark
  2. SPARK-46586

Support `s.c.immutable.ArraySeq` as `customCollectionCls` in `MapObjects`

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 4.0.0
    • 4.0.0
    • SQL

    Description

      val myUdf = udf((a: immutable.ArraySeq[Int]) =>
          immutable.ArraySeq.unsafeWrapArray[Int](Array(a.head + 99)))
        checkAnswer(Seq(Array(1))
          .toDF("col")
          .select(myUdf(Column("col"))),
          Row(ArrayBuffer(100))) 

      will test failed in Spark 4.0 when using Scala 2.13

      Attachments

        Activity

          People

            panbingkun BingKun Pan
            LuciferYang Yang Jie
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: