212

spotify · Aug 27, 2024 · 337d487 · 337d487
1 parent 641e87e
commit 337d487
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/beam/src/main/scala/magnolify/beam/BeamSchemaType.scala b/beam/src/main/scala/magnolify/beam/BeamSchemaType.scala
@@ -159,8 +159,10 @@ object BeamSchemaField {
           caseClass.construct(p => p.typeclass.fromAny(v.getValue[Any](p.index))(cm))
 
         override def to(v: T)(cm: CaseMapper): Row = {
-          val values = caseClass.parameters.map(p => p.typeclass.to(p.dereference(v))(cm))
-          Row.withSchema(schema(cm)).addValues(values: _*).build()
+          val values = caseClass.parameters.map { p =>
+            p.typeclass.to(p.dereference(v))(cm).asInstanceOf[Object]
+          }
+          Row.withSchema(schema(cm)).addValues(values.asJava).build()
         }
       }
     }