Class JavaSerializer.ObjectInputStreamWithKryoClassLoader
- java.lang.Object
-
- java.io.InputStream
-
- java.io.ObjectInputStream
-
- com.esotericsoftware.kryo.serializers.JavaSerializer.ObjectInputStreamWithKryoClassLoader
-
- All Implemented Interfaces:
java.io.Closeable
,java.io.DataInput
,java.io.ObjectInput
,java.io.ObjectStreamConstants
,java.lang.AutoCloseable
- Enclosing class:
- JavaSerializer
private static class JavaSerializer.ObjectInputStreamWithKryoClassLoader extends java.io.ObjectInputStream
$ObjectInputStream
uses the last user-defined $ClassLoader
which may not be the correct one. This is a known Java issue and is often solved by using a specific class loader. See: https://github.com/apache/spark/blob/v1.6.3/streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala#L154 https://issues.apache.org/jira/browse/GROOVY-1627
-
-
Field Summary
Fields Modifier and Type Field Description private java.lang.ClassLoader
loader
-
Fields inherited from interface java.io.ObjectStreamConstants
baseWireHandle, PROTOCOL_VERSION_1, PROTOCOL_VERSION_2, SC_BLOCK_DATA, SC_ENUM, SC_EXTERNALIZABLE, SC_SERIALIZABLE, SC_WRITE_METHOD, STREAM_MAGIC, STREAM_VERSION, SUBCLASS_IMPLEMENTATION_PERMISSION, SUBSTITUTION_PERMISSION, TC_ARRAY, TC_BASE, TC_BLOCKDATA, TC_BLOCKDATALONG, TC_CLASS, TC_CLASSDESC, TC_ENDBLOCKDATA, TC_ENUM, TC_EXCEPTION, TC_LONGSTRING, TC_MAX, TC_NULL, TC_OBJECT, TC_PROXYCLASSDESC, TC_REFERENCE, TC_RESET, TC_STRING
-
-
Constructor Summary
Constructors Constructor Description ObjectInputStreamWithKryoClassLoader(java.io.InputStream in, Kryo kryo)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected java.lang.Class<?>
resolveClass(java.io.ObjectStreamClass desc)
-
Methods inherited from class java.io.ObjectInputStream
available, close, defaultReadObject, enableResolveObject, read, read, readBoolean, readByte, readChar, readClassDescriptor, readDouble, readFields, readFloat, readFully, readFully, readInt, readLine, readLong, readObject, readObjectOverride, readShort, readStreamHeader, readUnshared, readUnsignedByte, readUnsignedShort, readUTF, registerValidation, resolveObject, resolveProxyClass, skipBytes
-
-
-
-
Constructor Detail
-
ObjectInputStreamWithKryoClassLoader
ObjectInputStreamWithKryoClassLoader(java.io.InputStream in, Kryo kryo) throws java.io.IOException
- Throws:
java.io.IOException
-
-