diff options
author | Reynold Xin <rxin@databricks.com> | 2015-12-16 00:57:34 -0800 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2015-12-16 00:57:34 -0800 |
commit | 1a3d0cd9f013aee1f03b1c632c91ae0951bccbb0 (patch) | |
tree | 6a02594429a3eb286bd9cb63aede40801c7cc0c7 /sql/core | |
parent | 18ea11c3a84e5eafd81fa0fe7c09224e79c4e93f (diff) | |
download | spark-1a3d0cd9f013aee1f03b1c632c91ae0951bccbb0.tar.gz spark-1a3d0cd9f013aee1f03b1c632c91ae0951bccbb0.tar.bz2 spark-1a3d0cd9f013aee1f03b1c632c91ae0951bccbb0.zip |
Revert "[SPARK-12105] [SQL] add convenient show functions"
This reverts commit 31b391019ff6eb5a483f4b3e62fd082de7ff8416.
Diffstat (limited to 'sql/core')
-rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala | 25 |
1 files changed, 9 insertions, 16 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala b/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala index b69d441142..497bd48266 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala @@ -161,23 +161,16 @@ class DataFrame private[sql]( } /** - * Compose the string representing rows for output - */ - def showString(): String = { - showString(20) - } - - /** * Compose the string representing rows for output - * @param numRows Number of rows to show + * @param _numRows Number of rows to show * @param truncate Whether truncate long strings and align cells right */ - def showString(numRows: Int, truncate: Boolean = true): String = { - val _numRows = numRows.max(0) + private[sql] def showString(_numRows: Int, truncate: Boolean = true): String = { + val numRows = _numRows.max(0) val sb = new StringBuilder - val takeResult = take(_numRows + 1) - val hasMoreData = takeResult.length > _numRows - val data = takeResult.take(_numRows) + val takeResult = take(numRows + 1) + val hasMoreData = takeResult.length > numRows + val data = takeResult.take(numRows) val numCols = schema.fieldNames.length // For array values, replace Seq and Array with square brackets @@ -231,10 +224,10 @@ class DataFrame private[sql]( sb.append(sep) - // For Data that has more than "_numRows" records + // For Data that has more than "numRows" records if (hasMoreData) { - val rowsString = if (_numRows == 1) "row" else "rows" - sb.append(s"only showing top $_numRows $rowsString\n") + val rowsString = if (numRows == 1) "row" else "rows" + sb.append(s"only showing top $numRows $rowsString\n") } sb.toString() |