typo fix

ankiiitraj · web-flow · commit 8ee93ea100fe · 2022-09-24T18:18:48.000+05:30
diff --git a/src/main/scala/org/apache/spark/sql/redis/RedisSourceRelation.scala b/src/main/scala/org/apache/spark/sql/redis/RedisSourceRelation.scala
@@ -137,7 +137,8 @@ class RedisSourceRelation(override val sqlContext: SQLContext,
       }
     }
     // If dataframe contains only key column
-    if (fields.size() < 2) {
+    val colCount = data.columns.length
+    if (colCount < 2) {
       logInfo(s"Dataframe only contains key.column specified in options. No data was writen to redis.")
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -137,7 +137,8 @@ class RedisSourceRelation(override val sqlContext: SQLContext,`
`137`	`137`	`}`
`138`	`138`	`}`
`139`	`139`	`// If dataframe contains only key column`
`140`		`- if (fields.size() < 2) {`
	`140`	`+ val colCount = data.columns.length`
	`141`	`+ if (colCount < 2) {`
`141`	`142`	`logInfo(s"Dataframe only contains key.column specified in options. No data was writen to redis.")`
`142`	`143`	`}`
`143`	`144`	`}`