Remove redundant toDF() calls.

apache · Aug 29, 2017 · 28aad0c · 28aad0c
1 parent feda29f
commit 28aad0c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala
@@ -45,7 +45,7 @@ abstract class Optimizer(sessionCatalog: SessionCatalog)
       rule: Rule[LogicalPlan]): Unit = {
     assert(
       result.isStreaming == original.isStreaming,
-      s"Rule ${rule.ruleName} changed isStreaming from original ${original.isStreaming}:" +
+      s"Rule ${rule.ruleName} changed isStreaming from original ${original.isStreaming}: " +
           s"original:\n$original\nnew:\n$result")
   }
 

diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/socket.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/socket.scala
@@ -135,10 +135,10 @@ class TextSocketSource(host: String, port: Int, includeTimestamp: Boolean, sqlCo
     // Underlying MemoryStream has schema (String, Timestamp); strip out the timestamp
     // if requested.
     if (includeTimestamp) {
-      rawBatch.toDF("value", "timestamp")
+      rawBatch.select("value", "timestamp")
     } else {
       // Strip out timestamp
-      rawBatch.select("value").toDF()
+      rawBatch.select("value")
     }
   }