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);