[HAMA-852] Add MessageClass property in BSPJob

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 0.6.3
• Fix Version/s: 0.7.0
• Component/s: bsp core, pipes
• Labels: pipes
• Assignee: Martin Illecker
• Reporter: Martin Illecker
• Created: 15/Jan/14 20:45
• Updated: 17/Jan/14 07:36
• Resolved: 17/Jan/14 07:36

Description

Add MessageClass property in BSPJob

 +  /**
 +   * Get the message class.
 +   * 
 +   * @return the message class.
 +   */
 +  public Class<?> getMessageClass() {
 +    return conf.getClass(Constants.MESSAGE_CLASS, Text.class, Object.class);
 +  }
 +
 +  /**
 +   * Set the message class.
 +   * 
 +   * @param theClass the message class.
 +   */
 +  public void setMessageClass(Class<?> theClass) {
 +    conf.setClass(Constants.MESSAGE_CLASS, theClass, Object.class);
 +  }

Use Constans.MESSAGE_CLASS

-  public static final String MESSAGE_CLASS = "bsp.message.type.class";
+  public static final String MESSAGE_CLASS = "bsp.message.class";

Then it would be possible to set the MessageClass by

-    bsp.set("bsp.message.class", DoubleWritable.class.getName());
+    bsp.setMessageClass(DoubleWritable.class);