зеркало из https://github.com/microsoft/spark.git
Made Serializer and JavaSerializer non private.
This commit is contained in:
Родитель
42cd148507
Коммит
45f4b7cc7e
|
@ -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
|
def newInstance(): SerializerInstance = new JavaSerializerInstance
|
||||||
}
|
}
|
||||||
|
|
|
@ -9,10 +9,10 @@ import it.unimi.dsi.fastutil.io.FastByteArrayOutputStream
|
||||||
import spark.util.ByteBufferInputStream
|
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.
|
* create SerializerInstances that do the actual serialization.
|
||||||
*/
|
*/
|
||||||
private[spark] trait Serializer {
|
trait Serializer {
|
||||||
def newInstance(): SerializerInstance
|
def newInstance(): SerializerInstance
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -88,7 +88,7 @@ private[spark] trait DeserializationStream {
|
||||||
}
|
}
|
||||||
gotNext = true
|
gotNext = true
|
||||||
}
|
}
|
||||||
|
|
||||||
override def hasNext: Boolean = {
|
override def hasNext: Boolean = {
|
||||||
if (!gotNext) {
|
if (!gotNext) {
|
||||||
getNext()
|
getNext()
|
||||||
|
|
Загрузка…
Ссылка в новой задаче