Class JavaIterableWrapperSerializer

Object
com.esotericsoftware.kryo.Serializer<Iterable<?>>
org.apache.spark.serializer.JavaIterableWrapperSerializer

public class JavaIterableWrapperSerializer extends com.esotericsoftware.kryo.Serializer<Iterable<?>>
A Kryo serializer for serializing results returned by asJavaIterable.

The underlying object is scala.collection.convert.Wrappers$IterableWrapper. Kryo deserializes this into an AbstractCollection, which unfortunately doesn't work.

  • Constructor Details

    • JavaIterableWrapperSerializer

      public JavaIterableWrapperSerializer()
  • Method Details

    • wrapperClass

      public static Class<? extends List<Object>> wrapperClass()
    • org$apache$spark$internal$Logging$$log_

      public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()
    • org$apache$spark$internal$Logging$$log__$eq

      public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
    • LogStringContext

      public static org.apache.spark.internal.Logging.LogStringContext LogStringContext(scala.StringContext sc)
    • write

      public void write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output out, Iterable<?> obj)
      Specified by:
      write in class com.esotericsoftware.kryo.Serializer<Iterable<?>>
    • read

      public Iterable<?> read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input in, Class<Iterable<?>> clz)
      Specified by:
      read in class com.esotericsoftware.kryo.Serializer<Iterable<?>>