diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-01-21 18:11:31 -0800 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-01-21 18:11:31 -0800 |
| commit | 7d3e359f2c463681cf0128da2c6692beb13dade9 (patch) | |
| tree | 62b7041294a73dbbbec349c24bdf4e78e5077b6f | |
| parent | 506077c9938cd411842fe42404aa6b74b45b23a1 (diff) | |
| parent | 2d8218b8717435a47d7cea399290b30bf5ef010b (diff) | |
| download | spark-7d3e359f2c463681cf0128da2c6692beb13dade9.tar.gz spark-7d3e359f2c463681cf0128da2c6692beb13dade9.tar.bz2 spark-7d3e359f2c463681cf0128da2c6692beb13dade9.zip | |
Merge pull request #395 from stephenh/fixrecursion
Remove unneeded/now-broken saveAsNewAPIHadoopFile overload.
| -rw-r--r-- | core/src/main/scala/spark/PairRDDFunctions.scala | 12 |
1 files changed, 0 insertions, 12 deletions
diff --git a/core/src/main/scala/spark/PairRDDFunctions.scala b/core/src/main/scala/spark/PairRDDFunctions.scala index 656b820b8a..53b051f1c5 100644 --- a/core/src/main/scala/spark/PairRDDFunctions.scala +++ b/core/src/main/scala/spark/PairRDDFunctions.scala @@ -493,18 +493,6 @@ class PairRDDFunctions[K: ClassManifest, V: ClassManifest]( path: String, keyClass: Class[_], valueClass: Class[_], - outputFormatClass: Class[_ <: NewOutputFormat[_, _]]) { - saveAsNewAPIHadoopFile(path, keyClass, valueClass, outputFormatClass) - } - - /** - * Output the RDD to any Hadoop-supported file system, using a new Hadoop API `OutputFormat` - * (mapreduce.OutputFormat) object supporting the key and value types K and V in this RDD. - */ - def saveAsNewAPIHadoopFile( - path: String, - keyClass: Class[_], - valueClass: Class[_], outputFormatClass: Class[_ <: NewOutputFormat[_, _]], conf: Configuration = self.context.hadoopConfiguration) { val job = new NewAPIHadoopJob(conf) |