Skip to content

Commit a32fef7

Browse files
committed
removed unneeded classes added DeveloperApi note to portabledatastreams since the implementation might change
1 parent 49174d9 commit a32fef7

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

core/src/main/scala/org/apache/spark/input/RawFileInput.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ import java.io.{ ByteArrayInputStream, ByteArrayOutputStream, DataOutputStream,
3535
* A general format for reading whole files in as streams, byte arrays,
3636
* or other functions to be added
3737
*/
38-
abstract class StreamFileInputFormat[T]
38+
private[spark] abstract class StreamFileInputFormat[T]
3939
extends CombineFileInputFormat[String, T] {
4040
override protected def isSplitable(context: JobContext, file: Path): Boolean = false
4141
/**
@@ -152,7 +152,7 @@ class PortableDataStream(@transient isplit: CombineFileSplit,
152152
* An abstract class of [[org.apache.hadoop.mapreduce.RecordReader RecordReader]]
153153
* to reading files out as streams
154154
*/
155-
abstract class StreamBasedRecordReader[T](
155+
private[spark] abstract class StreamBasedRecordReader[T](
156156
split: CombineFileSplit,
157157
context: TaskAttemptContext,
158158
index: Integer)

0 commit comments

Comments
 (0)