Spring for Apache Hadoop

org.springframework.yarn.integration.ip.mind
Class MindRpcSerializer

java.lang.Object
  extended by org.springframework.yarn.integration.ip.mind.MindRpcSerializer
All Implemented Interfaces:
org.springframework.core.serializer.Deserializer<MindRpcMessageHolder>, org.springframework.core.serializer.Serializer<MindRpcMessageHolder>

public class MindRpcSerializer
extends java.lang.Object
implements org.springframework.core.serializer.Serializer<MindRpcMessageHolder>, org.springframework.core.serializer.Deserializer<MindRpcMessageHolder>

Spring Serializer and Deserializer interfaces for mind protocol.

Author:
Janne Valkealahti

Field Summary
protected  int maxMessageSize
           
 
Constructor Summary
MindRpcSerializer()
           
 
Method Summary
protected  void checkClosure(int bite)
           
 MindRpcMessageHolder deserialize(java.io.InputStream inputStream)
           
protected  byte[] readBytes(java.io.InputStream inputStream, int length)
          Helper method to read bytes from a stream.
protected  int[] readHeader(java.io.InputStream inputStream)
          Reads the first line as a protocol header and parses sizes of underlying headers and content.
protected  java.util.Map<java.lang.String,java.lang.String> readHeaders(java.io.InputStream inputStream, int length)
          Reads a message headers from inputstream with a given length.
 void serialize(MindRpcMessageHolder object, java.io.OutputStream outputStream)
           
 void setMaxMessageSize(int maxMessageSize)
          Sets the max message size for transport.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

maxMessageSize

protected int maxMessageSize
Constructor Detail

MindRpcSerializer

public MindRpcSerializer()
Method Detail

deserialize

public MindRpcMessageHolder deserialize(java.io.InputStream inputStream)
                                 throws java.io.IOException
Specified by:
deserialize in interface org.springframework.core.serializer.Deserializer<MindRpcMessageHolder>
Throws:
java.io.IOException
See Also:
Deserializer.deserialize(java.io.InputStream)

serialize

public void serialize(MindRpcMessageHolder object,
                      java.io.OutputStream outputStream)
               throws java.io.IOException
Specified by:
serialize in interface org.springframework.core.serializer.Serializer<MindRpcMessageHolder>
Throws:
java.io.IOException
See Also:
Serializer.serialize(java.lang.Object, java.io.OutputStream)

setMaxMessageSize

public void setMaxMessageSize(int maxMessageSize)
Sets the max message size for transport.

Parameters:
maxMessageSize - the length of max message

readHeader

protected int[] readHeader(java.io.InputStream inputStream)
                    throws java.io.IOException
Reads the first line as a protocol header and parses sizes of underlying headers and content.

Parameters:
inputStream - the input stream
Returns:
int array containing sizes of headers and content
Throws:
java.io.IOException - if read error occured

readHeaders

protected java.util.Map<java.lang.String,java.lang.String> readHeaders(java.io.InputStream inputStream,
                                                                       int length)
                                                                throws java.io.IOException
Reads a message headers from inputstream with a given length.

Parameters:
inputStream - the input stream
length - how much to read from a stream
Returns:
Map of headers
Throws:
java.io.IOException - if error occured

readBytes

protected byte[] readBytes(java.io.InputStream inputStream,
                           int length)
                    throws java.io.IOException
Helper method to read bytes from a stream.

Parameters:
inputStream - the input stream
length - how much to read
Returns:
bytes to read
Throws:
java.io.IOException - if error occured

checkClosure

protected void checkClosure(int bite)
                     throws java.io.IOException
Throws:
java.io.IOException

Spring for Apache Hadoop