org.apache.hama.bsp
Class BSPMessageBundle

java.lang.Object
  extended by org.apache.hama.bsp.BSPMessageBundle
All Implemented Interfaces:
org.apache.hadoop.io.Writable

public class BSPMessageBundle
extends java.lang.Object
implements org.apache.hadoop.io.Writable

BSPMessageBundle stores a group of BSPMessages so that they can be sent in batch rather than individually.


Field Summary
static org.apache.commons.logging.Log LOG
           
 
Constructor Summary
BSPMessageBundle()
           
 
Method Summary
 void addMessage(BSPMessage message)
          Add message to this bundle.
 java.util.List<BSPMessage> getMessages()
           
 void readFields(java.io.DataInput in)
           
 void write(java.io.DataOutput out)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

LOG

public static final org.apache.commons.logging.Log LOG
Constructor Detail

BSPMessageBundle

public BSPMessageBundle()
Method Detail

addMessage

public void addMessage(BSPMessage message)
Add message to this bundle.

Parameters:
message - BSPMessage to add.

getMessages

public java.util.List<BSPMessage> getMessages()

write

public void write(java.io.DataOutput out)
           throws java.io.IOException
Specified by:
write in interface org.apache.hadoop.io.Writable
Throws:
java.io.IOException

readFields

public void readFields(java.io.DataInput in)
                throws java.io.IOException
Specified by:
readFields in interface org.apache.hadoop.io.Writable
Throws:
java.io.IOException


Copyright © 2008-2011 The Apache Software Foundation. All Rights Reserved.