Skip to content

Commit 3553d91

Browse files
committed
WIP: fix test failures
1 parent 243fae3 commit 3553d91

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/InternalRow.scala

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -173,6 +173,10 @@ object InternalRow {
173173
(input, v) => input.setDecimal(ordinal, v.asInstanceOf[Decimal], precision)
174174
case udt: UserDefinedType[_] => getWriter(ordinal, udt.sqlType)
175175
case NullType => (input, _) => input.setNullAt(ordinal)
176+
case StringType => (input, v) => input.update(ordinal, v.asInstanceOf[UTF8String].copy())
177+
case _: StructType => (input, v) => input.update(ordinal, v.asInstanceOf[InternalRow].copy())
178+
case _: ArrayType => (input, v) => input.update(ordinal, v.asInstanceOf[ArrayData].copy())
179+
case _: MapType => (input, v) => input.update(ordinal, v.asInstanceOf[MapData].copy())
176180
case _ => (input, v) => input.update(ordinal, v)
177181
}
178182
}

0 commit comments

Comments
 (0)