edu.snu.coral.compiler.frontend.spark.coder

Class SparkCoder<T>

java.lang.Object

edu.snu.coral.compiler.frontend.spark.coder.SparkCoder<T>

Type Parameters:

T - type of the object to (de)serialize.

All Implemented Interfaces:

Coder<T>, Serializable

public final class SparkCoder<T>
extends Object
implements Coder<T>

Kryo Spark Coder for serialization.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface edu.snu.coral.common.coder.Coder

Coder.DummyCoder

Field Summary

Fields inherited from interface edu.snu.coral.common.coder.Coder

DUMMY_CODER

Constructor Summary

Constructors

Constructor and Description
SparkCoder(org.apache.spark.serializer.Serializer serializer) Default constructor.

Method Summary

Modifier and Type	Method and Description
T	decode(InputStream inStream) Decodes the a value from the given input stream.
void	encode(T element, OutputStream outStream) Encodes the given value onto the specified output stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkCoder

public SparkCoder(org.apache.spark.serializer.Serializer serializer)

Default constructor.

Parameters:

serializer - kryo serializer.

Method Detail

encode

public void encode(T element,
                   OutputStream outStream)
            throws IOException

Description copied from interface: Coder

Encodes the given value onto the specified output stream. It have to be able to encode the given stream consequently by calling this method repeatedly. Because the user can want to keep a single output stream and continuously concatenate elements, the output stream should not be closed.

Specified by:

encode in interface Coder<T>

Parameters:

element - the element to be encoded

outStream - the stream on which encoded bytes are written

Throws:

IOException - if fail to encode

decode

public T decode(InputStream inStream)
         throws IOException

Description copied from interface: Coder

Decodes the a value from the given input stream. It have to be able to decode the given stream consequently by calling this method repeatedly. Because there are many elements in the input stream, the stream should not be closed.

Specified by:

decode in interface Coder<T>

Parameters:

inStream - the stream from which bytes are read

Returns:

the decoded element

Throws:

IOException - if fail to decode