org.apache.crunch.impl.spark.serde

Class WritableSerDe

java.lang.Object

org.apache.crunch.impl.spark.serde.WritableSerDe

All Implemented Interfaces:

Serializable, SerDe<org.apache.hadoop.io.Writable>

public class WritableSerDe
extends Object
implements SerDe<org.apache.hadoop.io.Writable>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
WritableSerDe(Class<? extends org.apache.hadoop.io.Writable> clazz)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.io.Writable	fromBytes(byte[] bytes)
com.google.common.base.Function<byte[],org.apache.hadoop.io.Writable>	fromBytesFunction()
ByteArray	toBytes(org.apache.hadoop.io.Writable obj)

Methods inherited from class java.lang.Object

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

Constructor Detail

WritableSerDe

public WritableSerDe(Class<? extends org.apache.hadoop.io.Writable> clazz)

Method Detail

toBytes

public ByteArray toBytes(org.apache.hadoop.io.Writable obj)
                  throws Exception

Specified by:

toBytes in interface SerDe<org.apache.hadoop.io.Writable>

Throws:

Exception

fromBytes

public org.apache.hadoop.io.Writable fromBytes(byte[] bytes)

Specified by:

fromBytes in interface SerDe<org.apache.hadoop.io.Writable>

fromBytesFunction

public com.google.common.base.Function<byte[],org.apache.hadoop.io.Writable> fromBytesFunction()

Specified by:

fromBytesFunction in interface SerDe<org.apache.hadoop.io.Writable>