org.apache.spark

Class WritableConverter<T>

Object

org.apache.spark.WritableConverter<T>

All Implemented Interfaces:

java.io.Serializable

public class WritableConverter<T>
extends Object
implements java.io.Serializable

A class encapsulating how to convert some type T to Writable. It stores both the Writable class corresponding to T (e.g. IntWritable for Int) and a function for doing the conversion. The getter for the writable class takes a ClassTag[T] in case this is a generic object that doesn't know the type of T when it is created. This sounds strange but is necessary to support converting subclasses of Writable to themselves (writableWritableConverter).

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
WritableConverter(scala.Function1<scala.reflect.ClassTag<T>,Class<? extends org.apache.hadoop.io.Writable>> writableClass, scala.Function1<org.apache.hadoop.io.Writable,T> convert)

Method Summary

Methods

Modifier and Type	Method and Description
scala.Function1<org.apache.hadoop.io.Writable,T>	convert()
scala.Function1<scala.reflect.ClassTag<T>,Class<? extends org.apache.hadoop.io.Writable>>	writableClass()

Methods inherited from class Object

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

Constructor Detail

WritableConverter

public WritableConverter(scala.Function1<scala.reflect.ClassTag<T>,Class<? extends org.apache.hadoop.io.Writable>> writableClass,
                 scala.Function1<org.apache.hadoop.io.Writable,T> convert)

Method Detail

writableClass

public scala.Function1<scala.reflect.ClassTag<T>,Class<? extends org.apache.hadoop.io.Writable>> writableClass()

convert

public scala.Function1<org.apache.hadoop.io.Writable,T> convert()