You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by li...@apache.org on 2017/06/23 17:57:02 UTC
spark git commit: [MINOR][DOCS] Docs in DataFrameNaFunctions.scala
use wrong method
Repository: spark
Updated Branches:
refs/heads/master 2ebd0838d -> 4cc62951a
[MINOR][DOCS] Docs in DataFrameNaFunctions.scala use wrong method
## What changes were proposed in this pull request?
* Following the first few examples in this file, the remaining methods should also be methods of `df.na` not `df`.
* Filled in some missing parentheses
## How was this patch tested?
N/A
Author: Ong Ming Yang <me...@ongmingyang.com>
Closes #18398 from ongmingyang/master.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/4cc62951
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/4cc62951
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/4cc62951
Branch: refs/heads/master
Commit: 4cc62951a2b12a372a2b267bf8597a0a31e2b2cb
Parents: 2ebd083
Author: Ong Ming Yang <me...@ongmingyang.com>
Authored: Fri Jun 23 10:56:59 2017 -0700
Committer: Xiao Li <ga...@gmail.com>
Committed: Fri Jun 23 10:56:59 2017 -0700
----------------------------------------------------------------------
.../apache/spark/sql/DataFrameNaFunctions.scala | 20 ++++++++++----------
1 file changed, 10 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/4cc62951/sql/core/src/main/scala/org/apache/spark/sql/DataFrameNaFunctions.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/DataFrameNaFunctions.scala b/sql/core/src/main/scala/org/apache/spark/sql/DataFrameNaFunctions.scala
index ee949e7..871fff7 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/DataFrameNaFunctions.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/DataFrameNaFunctions.scala
@@ -268,13 +268,13 @@ final class DataFrameNaFunctions private[sql](df: DataFrame) {
* import com.google.common.collect.ImmutableMap;
*
* // Replaces all occurrences of 1.0 with 2.0 in column "height".
- * df.replace("height", ImmutableMap.of(1.0, 2.0));
+ * df.na.replace("height", ImmutableMap.of(1.0, 2.0));
*
* // Replaces all occurrences of "UNKNOWN" with "unnamed" in column "name".
- * df.replace("name", ImmutableMap.of("UNKNOWN", "unnamed"));
+ * df.na.replace("name", ImmutableMap.of("UNKNOWN", "unnamed"));
*
* // Replaces all occurrences of "UNKNOWN" with "unnamed" in all string columns.
- * df.replace("*", ImmutableMap.of("UNKNOWN", "unnamed"));
+ * df.na.replace("*", ImmutableMap.of("UNKNOWN", "unnamed"));
* }}}
*
* @param col name of the column to apply the value replacement
@@ -295,10 +295,10 @@ final class DataFrameNaFunctions private[sql](df: DataFrame) {
* import com.google.common.collect.ImmutableMap;
*
* // Replaces all occurrences of 1.0 with 2.0 in column "height" and "weight".
- * df.replace(new String[] {"height", "weight"}, ImmutableMap.of(1.0, 2.0));
+ * df.na.replace(new String[] {"height", "weight"}, ImmutableMap.of(1.0, 2.0));
*
* // Replaces all occurrences of "UNKNOWN" with "unnamed" in column "firstname" and "lastname".
- * df.replace(new String[] {"firstname", "lastname"}, ImmutableMap.of("UNKNOWN", "unnamed"));
+ * df.na.replace(new String[] {"firstname", "lastname"}, ImmutableMap.of("UNKNOWN", "unnamed"));
* }}}
*
* @param cols list of columns to apply the value replacement
@@ -319,13 +319,13 @@ final class DataFrameNaFunctions private[sql](df: DataFrame) {
*
* {{{
* // Replaces all occurrences of 1.0 with 2.0 in column "height".
- * df.replace("height", Map(1.0 -> 2.0))
+ * df.na.replace("height", Map(1.0 -> 2.0));
*
* // Replaces all occurrences of "UNKNOWN" with "unnamed" in column "name".
- * df.replace("name", Map("UNKNOWN" -> "unnamed")
+ * df.na.replace("name", Map("UNKNOWN" -> "unnamed"));
*
* // Replaces all occurrences of "UNKNOWN" with "unnamed" in all string columns.
- * df.replace("*", Map("UNKNOWN" -> "unnamed")
+ * df.na.replace("*", Map("UNKNOWN" -> "unnamed"));
* }}}
*
* @param col name of the column to apply the value replacement
@@ -348,10 +348,10 @@ final class DataFrameNaFunctions private[sql](df: DataFrame) {
*
* {{{
* // Replaces all occurrences of 1.0 with 2.0 in column "height" and "weight".
- * df.replace("height" :: "weight" :: Nil, Map(1.0 -> 2.0));
+ * df.na.replace("height" :: "weight" :: Nil, Map(1.0 -> 2.0));
*
* // Replaces all occurrences of "UNKNOWN" with "unnamed" in column "firstname" and "lastname".
- * df.replace("firstname" :: "lastname" :: Nil, Map("UNKNOWN" -> "unnamed");
+ * df.na.replace("firstname" :: "lastname" :: Nil, Map("UNKNOWN" -> "unnamed"));
* }}}
*
* @param cols list of columns to apply the value replacement
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org