Skip to content
Snippets Groups Projects
Commit 268ecbd2 authored by Patrick Wendell's avatar Patrick Wendell
Browse files

Minor changes after auditing diff from earlier version

parent c58d4ea3
No related branches found
No related tags found
No related merge requests found
......@@ -19,10 +19,7 @@ package org.apache.spark.rdd
import java.io.EOFException
import scala.reflect.ClassTag
import org.apache.hadoop.conf.{Configuration, Configurable}
import org.apache.hadoop.io.Writable
import org.apache.hadoop.mapred.InputFormat
import org.apache.hadoop.mapred.InputSplit
import org.apache.hadoop.mapred.JobConf
......
......@@ -113,9 +113,7 @@ class NewHadoopRDD[K, V](
throw new java.util.NoSuchElementException("End of stream")
}
havePair = false
val key = reader.getCurrentKey
val value = reader.getCurrentValue
(key, value)
(reader.getCurrentKey, reader.getCurrentValue)
}
private def close() {
......
......@@ -26,7 +26,6 @@ import scala.collection.JavaConversions._
import scala.collection.Map
import scala.collection.mutable.ArrayBuffer
import scala.io.Source
import scala.reflect.ClassTag
import com.google.common.io.Files
import com.google.common.util.concurrent.ThreadFactoryBuilder
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment