You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by ed...@apache.org on 2014/05/28 15:04:42 UTC

svn commit: r1598006 - in /hama/trunk/core/src/test/java/org/apache/hama/bsp: TestMessages.java message/compress/TestBSPMessageCompressor.java

Author: edwardyoon
Date: Wed May 28 13:04:41 2014
New Revision: 1598006

URL: http://svn.apache.org/r1598006
Log:
HAMA-908: Remove message.type package

Removed:
    hama/trunk/core/src/test/java/org/apache/hama/bsp/TestMessages.java
Modified:
    hama/trunk/core/src/test/java/org/apache/hama/bsp/message/compress/TestBSPMessageCompressor.java

Modified: hama/trunk/core/src/test/java/org/apache/hama/bsp/message/compress/TestBSPMessageCompressor.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/compress/TestBSPMessageCompressor.java?rev=1598006&r1=1598005&r2=1598006&view=diff
==============================================================================
--- hama/trunk/core/src/test/java/org/apache/hama/bsp/message/compress/TestBSPMessageCompressor.java (original)
+++ hama/trunk/core/src/test/java/org/apache/hama/bsp/message/compress/TestBSPMessageCompressor.java Wed May 28 13:04:41 2014
@@ -27,19 +27,18 @@ import junit.framework.TestCase;
 
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.IntWritable;
-import org.apache.hama.bsp.message.type.IntegerMessage;
 
 public class TestBSPMessageCompressor extends TestCase {
 
   public void testCompression() throws IOException {
     Configuration configuration = new Configuration();
-    BSPMessageCompressor<IntegerMessage> compressor = new BSPMessageCompressorFactory<IntegerMessage>()
+    BSPMessageCompressor<IntWritable> compressor = new BSPMessageCompressorFactory<IntWritable>()
         .getCompressor(configuration);
 
     assertNull(compressor);
     configuration.setClass(BSPMessageCompressorFactory.COMPRESSION_CODEC_CLASS,
         SnappyCompressor.class, BSPMessageCompressor.class);
-    compressor = new BSPMessageCompressorFactory<IntegerMessage>()
+    compressor = new BSPMessageCompressorFactory<IntWritable>()
         .getCompressor(configuration);
 
     assertNotNull(compressor);