removed unneeded classes added DeveloperApi note to portabledatastrea…

…ms since the implementation might change
YanTangZhai · Oct 2, 2014 · a32fef7 · a32fef7
1 parent 49174d9
commit a32fef7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/input/RawFileInput.scala b/core/src/main/scala/org/apache/spark/input/RawFileInput.scala
@@ -35,7 +35,7 @@ import java.io.{ ByteArrayInputStream, ByteArrayOutputStream, DataOutputStream,
  *  A general format for reading whole files in as streams, byte arrays,
  *  or other functions to be added
  */
-abstract class StreamFileInputFormat[T]
+private[spark] abstract class StreamFileInputFormat[T]
   extends CombineFileInputFormat[String, T] {
   override protected def isSplitable(context: JobContext, file: Path): Boolean = false
   /**
@@ -152,7 +152,7 @@ class PortableDataStream(@transient isplit: CombineFileSplit,
  * An abstract class of [[org.apache.hadoop.mapreduce.RecordReader RecordReader]]
  * to reading files out as streams
  */
-abstract class StreamBasedRecordReader[T](
+private[spark] abstract class StreamBasedRecordReader[T](
   split: CombineFileSplit,
   context: TaskAttemptContext,
   index: Integer)