Skip to content

Commit 0f83127

Browse files
committed
Add mistakenly removed case
1 parent 2f10a99 commit 0f83127

File tree

1 file changed

+2
-0
lines changed
  • sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv

1 file changed

+2
-0
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv/CSVRelation.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -241,6 +241,8 @@ private[csv] class CsvOutputWriter(
241241
(row: InternalRow, ordinal: Int) =>
242242
params.timestampFormat.format(DateTimeUtils.toJavaTimestamp(row.getLong(ordinal)))
243243

244+
case udt: UserDefinedType[_] => makeConverter(udt.sqlType)
245+
244246
case _ =>
245247
throw new UnsupportedOperationException(
246248
s"CSV data source does not support ${dataType.simpleString} data type.")

0 commit comments

Comments
 (0)