org.apache.spark.serializer

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 Summary

Constructors

Constructor and Description
JavaIterableWrapperSerializer()

Method Summary

Modifier and Type	Method and Description
static T	copy(com.esotericsoftware.kryo.Kryo x$1, T x$2)
static boolean	getAcceptsNull()
static boolean	isImmutable()
Iterable<?>	read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input in, Class<Iterable<?>> clz)
static void	setAcceptsNull(boolean x$1)
static void	setGenerics(com.esotericsoftware.kryo.Kryo x$1, Class<?>[] x$2)
static void	setImmutable(boolean x$1)
static Object	wrapperClass()
void	write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output out, Iterable<?> obj)

Methods inherited from class com.esotericsoftware.kryo.Serializer

copy, getAcceptsNull, isImmutable, setAcceptsNull, setGenerics, setImmutable

Methods inherited from class Object

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

Constructor Detail

JavaIterableWrapperSerializer

public JavaIterableWrapperSerializer()

Method Detail

wrapperClass

public static Object wrapperClass()

getAcceptsNull

public static boolean getAcceptsNull()

setAcceptsNull

public static void setAcceptsNull(boolean x$1)

isImmutable

public static boolean isImmutable()

setImmutable

public static void setImmutable(boolean x$1)

setGenerics

public static void setGenerics(com.esotericsoftware.kryo.Kryo x$1,
                               Class<?>[] x$2)

copy

public static T copy(com.esotericsoftware.kryo.Kryo x$1,
                     T x$2)

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<?>>