hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1598006 - in /hama/trunk/core/src/test/java/org/apache/hama/bsp: TestMessages.java message/compress/TestBSPMessageCompressor.java
Date Wed, 28 May 2014 13:04:42 GMT
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);



Mime
View raw message