зеркало из https://github.com/microsoft/spark.git
Merge pull request #244 from rxin/dev
Made Serializer and JavaSerializer non private.
This commit is contained in:
Коммит
66d848175a
|
@ -57,6 +57,6 @@ private[spark] class JavaSerializerInstance extends SerializerInstance {
|
|||
}
|
||||
}
|
||||
|
||||
private[spark] class JavaSerializer extends Serializer {
|
||||
class JavaSerializer extends Serializer {
|
||||
def newInstance(): SerializerInstance = new JavaSerializerInstance
|
||||
}
|
||||
|
|
|
@ -9,10 +9,10 @@ import it.unimi.dsi.fastutil.io.FastByteArrayOutputStream
|
|||
import spark.util.ByteBufferInputStream
|
||||
|
||||
/**
|
||||
* A serializer. Because some serialization libraries are not thread safe, this class is used to
|
||||
* A serializer. Because some serialization libraries are not thread safe, this class is used to
|
||||
* create SerializerInstances that do the actual serialization.
|
||||
*/
|
||||
private[spark] trait Serializer {
|
||||
trait Serializer {
|
||||
def newInstance(): SerializerInstance
|
||||
}
|
||||
|
||||
|
@ -88,7 +88,7 @@ private[spark] trait DeserializationStream {
|
|||
}
|
||||
gotNext = true
|
||||
}
|
||||
|
||||
|
||||
override def hasNext: Boolean = {
|
||||
if (!gotNext) {
|
||||
getNext()
|
||||
|
|
Загрузка…
Ссылка в новой задаче