org.apache.spark.serializer

Class SerializationDebugger

Object

org.apache.spark.serializer.SerializationDebugger

All Implemented Interfaces:

Logging

public class SerializationDebugger
extends Object
implements Logging

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SerializationDebugger.ObjectStreamClassMethods An implicit class that allows us to call private methods of ObjectStreamClass.
static class	SerializationDebugger.ObjectStreamClassMethods$

Constructor Summary

Constructors

Constructor and Description
SerializationDebugger()

Method Summary

Methods

Modifier and Type	Method and Description
static boolean	enableDebugging()
static scala.collection.immutable.List<String>	find(Object obj) Find the path leading to a not serializable object.
static java.io.NotSerializableException	improveException(Object obj, java.io.NotSerializableException e) Improve the given NotSerializableException with the serialization path leading from the given object to the problematic object.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

SerializationDebugger

public SerializationDebugger()

Method Detail

improveException

public static java.io.NotSerializableException improveException(Object obj,
                                                java.io.NotSerializableException e)

Improve the given NotSerializableException with the serialization path leading from the given object to the problematic object. This is turned off automatically if sun.io.serialization.extendedDebugInfo flag is turned on for the JVM.

find

public static scala.collection.immutable.List<String> find(Object obj)

Find the path leading to a not serializable object. This method is modeled after OpenJDK's serialization mechanism, and handles the following cases: - primitives - arrays of primitives - arrays of non-primitive objects - Serializable objects - Externalizable objects - writeReplace

It does not yet handle writeObject override, but that shouldn't be too hard to do either.

enableDebugging

public static boolean enableDebugging()