Package 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	Description
JavaIterableWrapperSerializer()

Method Summary

Modifier and Type	Method	Description
static org.slf4j.Logger	org$apache$spark$internal$Logging$$log_()
static void	org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
Iterable<?>	read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input in, Class<Iterable<?>> clz)
static Class<? extends List<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 java.lang.Object

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

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)

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