Addressed comments

tdas · tdas · commit c3508e9094ac · 2018-02-07T11:58:07.000-08:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/memory.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/memory.scala
@@ -149,12 +149,12 @@ case class MemoryStream[A : Encoder](id: Int, sqlContext: SQLContext)
   }
 
   private def generateDebugString(
-      blocks: Seq[UnsafeRow],
+      rows: Seq[UnsafeRow],
       startOrdinal: Int,
       endOrdinal: Int): String = {
     val fromRow = encoder.resolveAndBind().fromRow _
     s"MemoryBatch [$startOrdinal, $endOrdinal]: " +
-        s"${blocks.map(row => fromRow(row)).mkString(", ")}"
+        s"${rows.map(row => fromRow(row)).mkString(", ")}"
   }
 
   override def commit(end: OffsetV2): Unit = synchronized {

Original file line number	Diff line number	Diff line change
`@@ -149,12 +149,12 @@ case class MemoryStream[A : Encoder](id: Int, sqlContext: SQLContext)`
`149`	`149`	`}`
`150`	`150`
`151`	`151`	`private def generateDebugString(`
`152`		`- blocks: Seq[UnsafeRow],`
	`152`	`+ rows: Seq[UnsafeRow],`
`153`	`153`	`startOrdinal: Int,`
`154`	`154`	`endOrdinal: Int): String = {`
`155`	`155`	`val fromRow = encoder.resolveAndBind().fromRow _`
`156`	`156`	`s"MemoryBatch [$startOrdinal, $endOrdinal]: " +`
`157`		`- s"${blocks.map(row => fromRow(row)).mkString(", ")}"`
	`157`	`+ s"${rows.map(row => fromRow(row)).mkString(", ")}"`
`158`	`158`	`}`
`159`	`159`
`160`	`160`	`override def commit(end: OffsetV2): Unit = synchronized {`