edu.snu.coral.compiler.frontend.beam.coder

Class BeamCoder<T>

java.lang.Object

edu.snu.coral.compiler.frontend.beam.coder.BeamCoder<T>

Type Parameters:

T - element type.

All Implemented Interfaces:

Coder<T>, Serializable

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

Coder from Coder.

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
BeamCoder(org.apache.beam.sdk.coders.Coder<T> beamCoder) Constructor of BeamCoder.

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamCoder

public BeamCoder(org.apache.beam.sdk.coders.Coder<T> beamCoder)

Constructor of BeamCoder.

Parameters:

beamCoder - actual Beam coder to use.

Method Detail

encode

public void encode(T value,
                   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:

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

toString

public String toString()

Overrides:

toString in class Object