You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ir...@apache.org on 2015/05/02 02:39:35 UTC

spark git commit: [SPARK-6999] [SQL] Remove the infinite recursive method (useless)

Repository: spark
Updated Branches:
  refs/heads/master e6fb37712 -> 98e704580


[SPARK-6999] [SQL] Remove the infinite recursive method (useless)

Remove the method, since it causes infinite recursive calls. And seems it's a dummy method, since we have the API:
`def createDataFrame(rowRDD: JavaRDD[Row], schema: StructType): DataFrame`

Author: Cheng Hao <ha...@intel.com>

Closes #5804 from chenghao-intel/spark_6999 and squashes the following commits:

63220a8 [Cheng Hao] remove the infinite recursive method (useless)


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/98e70458
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/98e70458
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/98e70458

Branch: refs/heads/master
Commit: 98e7045805282988da907793a844fa53d4c293c9
Parents: e6fb377
Author: Cheng Hao <ha...@intel.com>
Authored: Fri May 1 19:39:30 2015 -0500
Committer: Imran Rashid <ir...@cloudera.com>
Committed: Fri May 1 19:39:30 2015 -0500

----------------------------------------------------------------------
 .../main/scala/org/apache/spark/sql/SQLContext.scala  | 14 --------------
 1 file changed, 14 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/98e70458/sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala b/sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala
index bd4a55f..5116fce 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala
@@ -429,20 +429,6 @@ class SQLContext(@transient val sparkContext: SparkContext)
   }
 
   /**
-   * Creates a [[DataFrame]] from an [[JavaRDD]] containing [[Row]]s by applying
-   * a seq of names of columns to this RDD, the data type for each column will
-   * be inferred by the first row.
-   *
-   * @param rowRDD an JavaRDD of Row
-   * @param columns names for each column
-   * @return DataFrame
-   * @group dataframes
-   */
-  def createDataFrame(rowRDD: JavaRDD[Row], columns: java.util.List[String]): DataFrame = {
-    createDataFrame(rowRDD.rdd, columns.toSeq)
-  }
-
-  /**
    * Applies a schema to an RDD of Java Beans.
    *
    * WARNING: Since there is no guaranteed ordering for fields in a Java Bean,


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org