make helper methods private

Mukul Murthy · Mukul Murthy · commit 4ab9bdaea895 · 2018-06-13T15:06:50.000-07: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
@@ -336,7 +336,7 @@ class MemorySink(val schema: StructType, outputMode: OutputMode, options: DataSo
     numRows = 0
   }
 
-  def truncateRowsIfNeeded(rows: Array[Row], maxRows: Int, batchId: Long): Array[Row] = {
+  private def truncateRowsIfNeeded(rows: Array[Row], maxRows: Int, batchId: Long): Array[Row] = {
     if (rows.length > maxRows) {
       logWarning(s"Truncating batch $batchId to $maxRows rows")
       rows.take(maxRows)
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/memoryV2.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/memoryV2.scala
@@ -129,7 +129,7 @@ class MemorySinkV2 extends DataSourceV2 with StreamWriteSupport with MemorySinkB
     numRows = 0
   }
 
-  def truncateRowsIfNeeded(rows: Array[Row], maxRows: Int, batchId: Long): Array[Row] = {
+  private def truncateRowsIfNeeded(rows: Array[Row], maxRows: Int, batchId: Long): Array[Row] = {
     if (rows.length > maxRows) {
       logWarning(s"Truncating batch $batchId to $maxRows rows")
       rows.take(maxRows)

Original file line number	Diff line number	Diff line change
`@@ -336,7 +336,7 @@ class MemorySink(val schema: StructType, outputMode: OutputMode, options: DataSo`
`336`	`336`	`numRows = 0`
`337`	`337`	`}`
`338`	`338`
`339`		`- def truncateRowsIfNeeded(rows: Array[Row], maxRows: Int, batchId: Long): Array[Row] = {`
	`339`	`+ private def truncateRowsIfNeeded(rows: Array[Row], maxRows: Int, batchId: Long): Array[Row] = {`
`340`	`340`	`if (rows.length > maxRows) {`
`341`	`341`	`logWarning(s"Truncating batch $batchId to $maxRows rows")`
`342`	`342`	`rows.take(maxRows)`
Original file line number	Diff line number	Diff line change
`@@ -129,7 +129,7 @@ class MemorySinkV2 extends DataSourceV2 with StreamWriteSupport with MemorySinkB`
`129`	`129`	`numRows = 0`
`130`	`130`	`}`
`131`	`131`
`132`		`- def truncateRowsIfNeeded(rows: Array[Row], maxRows: Int, batchId: Long): Array[Row] = {`
	`132`	`+ private def truncateRowsIfNeeded(rows: Array[Row], maxRows: Int, batchId: Long): Array[Row] = {`
`133`	`133`	`if (rows.length > maxRows) {`
`134`	`134`	`logWarning(s"Truncating batch $batchId to $maxRows rows")`
`135`	`135`	`rows.take(maxRows)`