Github user maropu commented on a diff in the pull request:
https://github.com/apache/spark/pull/22724#discussion_r225353071
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/literals.scala
---
@@ -196,6 +197,31 @@ object Literal {
case other =>
throw new RuntimeException(s"no default for type $dataType")
}
+
+ private[expressions] def validateLiteralValue(v: Any, dataType:
DataType): Unit = {
+ def doValidate(v: Any, dataType: DataType): Boolean = dataType match {
+ case BooleanType => v.isInstanceOf[Boolean]
+ case ByteType => v.isInstanceOf[Byte]
+ case ShortType => v.isInstanceOf[Short]
+ case IntegerType | DateType => v.isInstanceOf[Int]
+ case LongType | TimestampType => v.isInstanceOf[Long]
+ case FloatType => v.isInstanceOf[Float]
+ case DoubleType => v.isInstanceOf[Double]
+ case _: DecimalType => v.isInstanceOf[Decimal]
+ case CalendarIntervalType => v.isInstanceOf[CalendarInterval]
+ case BinaryType => v.isInstanceOf[Array[Byte]]
+ case StringType => v.isInstanceOf[UTF8String]
+ case _: StructType => v.isInstanceOf[InternalRow]
+ case _: ArrayType => v.isInstanceOf[ArrayData]
+ case _: MapType => v.isInstanceOf[MapData]
+ case ObjectType(cls) => cls.isInstance(v)
+ case udt: UserDefinedType[_] => doValidate(v, udt.sqlType)
+ case _ => false
+ }
+ require(v == null || doValidate(v, dataType),
+ s"Literal must have a corresponding value to
${dataType.catalogString}, " +
+ s"but ${if (v != null) s"class ${Utils.getSimpleName(v.getClass)}"
else "null"} found.")
--- End diff --
oh, yes. I'll update.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
