org.deeplearning4j.spark.util.serde

Class StorageLevelSerializer

java.lang.Object

org.nd4j.shade.jackson.databind.JsonSerializer<org.apache.spark.storage.StorageLevel>

org.deeplearning4j.spark.util.serde.StorageLevelSerializer

All Implemented Interfaces:

org.nd4j.shade.jackson.databind.jsonFormatVisitors.JsonFormatVisitable

public class StorageLevelSerializer
extends org.nd4j.shade.jackson.databind.JsonSerializer<org.apache.spark.storage.StorageLevel>

By default: Spark storage levels don't serialize/deserialize cleanly with Jackson (i.e., we can get different results out). So we'll manually control the serialization/deserialization for StorageLevel objects

Nested Class Summary

Nested classes/interfaces inherited from class org.nd4j.shade.jackson.databind.JsonSerializer

org.nd4j.shade.jackson.databind.JsonSerializer.None

Constructor Summary

Constructors

Constructor and Description
StorageLevelSerializer()

Method Summary

Modifier and Type	Method and Description
void	serialize(org.apache.spark.storage.StorageLevel storageLevel, org.nd4j.shade.jackson.core.JsonGenerator jsonGenerator, org.nd4j.shade.jackson.databind.SerializerProvider serializerProvider)

Methods inherited from class org.nd4j.shade.jackson.databind.JsonSerializer

acceptJsonFormatVisitor, getDelegatee, handledType, isEmpty, isEmpty, isUnwrappingSerializer, replaceDelegatee, serializeWithType, unwrappingSerializer, usesObjectId

Methods inherited from class java.lang.Object

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

Constructor Detail

StorageLevelSerializer

public StorageLevelSerializer()

Method Detail

serialize

public void serialize(org.apache.spark.storage.StorageLevel storageLevel,
                      org.nd4j.shade.jackson.core.JsonGenerator jsonGenerator,
                      org.nd4j.shade.jackson.databind.SerializerProvider serializerProvider)
               throws java.io.IOException,
                      org.nd4j.shade.jackson.core.JsonProcessingException

Specified by:

serialize in class org.nd4j.shade.jackson.databind.JsonSerializer<org.apache.spark.storage.StorageLevel>

Throws:

java.io.IOException

org.nd4j.shade.jackson.core.JsonProcessingException