We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2de848f commit 30655f5Copy full SHA for 30655f5
mllib/src/main/scala/org/apache/spark/ml/util/SchemaUtils.scala
@@ -49,10 +49,10 @@ private[spark] object SchemaUtils {
49
* @param dataTypes required column data types
50
*/
51
def checkColumnTypes(
52
- schema: StructType,
53
- colName: String,
54
- dataTypes: Seq[DataType],
55
- msg: String = ""): Unit = {
+ schema: StructType,
+ colName: String,
+ dataTypes: Seq[DataType],
+ msg: String = ""): Unit = {
56
val actualDataType = schema(colName).dataType
57
val message = if (msg != null && msg.trim.length > 0) " " + msg else ""
58
require(dataTypes.exists(actualDataType.equals),
0 commit comments