hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tjungb...@apache.org
Subject svn commit: r1295028 - in /incubator/hama/trunk: ./ core/src/main/java/org/apache/hama/bsp/ core/src/main/java/org/apache/hama/bsp/messages/ core/src/test/java/org/apache/hama/bsp/ core/src/test/java/org/apache/hama/bsp/message/ core/src/test/java/org/...
Date Wed, 29 Feb 2012 09:22:07 GMT
Author: tjungblut
Date: Wed Feb 29 09:22:06 2012
New Revision: 1295028

URL: http://svn.apache.org/viewvc?rev=1295028&view=rev
Log:
[HAMA-513]: Move message classes to somewhere from bsp package.

Added:
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/BSPMessage.java
      - copied, changed from r1295023, incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/BooleanMessage.java
      - copied, changed from r1295023, incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BooleanMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/ByteMessage.java
      - copied, changed from r1295023, incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/ByteMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/DoubleMessage.java
      - copied, changed from r1295023, incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/DoubleMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/IntegerDoubleMessage.java
      - copied, changed from r1295023, incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/IntegerDoubleMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/IntegerMessage.java
      - copied, changed from r1295023, incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/IntegerMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/LongMessage.java
      - copied, changed from r1295023, incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/LongMessage.java
Removed:
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BooleanMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/ByteMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/DoubleMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/IntegerDoubleMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/IntegerMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/LongMessage.java
Modified:
    incubator/hama/trunk/CHANGES.txt
    incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestCheckpoint.java
    incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestMessages.java
    incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java
    incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/compress/TestBSPMessageCompressor.java

Modified: incubator/hama/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/CHANGES.txt?rev=1295028&r1=1295027&r2=1295028&view=diff
==============================================================================
--- incubator/hama/trunk/CHANGES.txt (original)
+++ incubator/hama/trunk/CHANGES.txt Wed Feb 29 09:22:06 2012
@@ -12,6 +12,7 @@ Release 0.5 - Unreleased
 
   IMPROVEMENTS
 
+    HAMA-513: Move message classes to somewhere from bsp package. (tjungblut)
     HAMA-484: Counters should be accessible in client (tjungblut)    
     HAMA-483: Remove old and deprecated BSP API (tjungblut)    
     HAMA-514: Add maven-gpg-plugin to parent POM file (edwardyoon)

Copied: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/BSPMessage.java
(from r1295023, incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMessage.java)
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/BSPMessage.java?p2=incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/BSPMessage.java&p1=incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMessage.java&r1=1295023&r2=1295028&rev=1295028&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMessage.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/BSPMessage.java Wed
Feb 29 09:22:06 2012
@@ -15,9 +15,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hama.bsp;
+package org.apache.hama.bsp.messages;
 
 import org.apache.hadoop.io.Writable;
+import org.apache.hama.bsp.Messagable;
 
 /**
  * BSPMessage consists of the tag and the arbitrary amount of data to be

Copied: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/BooleanMessage.java
(from r1295023, incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BooleanMessage.java)
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/BooleanMessage.java?p2=incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/BooleanMessage.java&p1=incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BooleanMessage.java&r1=1295023&r2=1295028&rev=1295028&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BooleanMessage.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/BooleanMessage.java
Wed Feb 29 09:22:06 2012
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hama.bsp;
+package org.apache.hama.bsp.messages;
 
 import java.io.DataInput;
 import java.io.DataOutput;

Copied: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/ByteMessage.java
(from r1295023, incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/ByteMessage.java)
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/ByteMessage.java?p2=incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/ByteMessage.java&p1=incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/ByteMessage.java&r1=1295023&r2=1295028&rev=1295028&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/ByteMessage.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/ByteMessage.java
Wed Feb 29 09:22:06 2012
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hama.bsp;
+package org.apache.hama.bsp.messages;
 
 import java.io.DataInput;
 import java.io.DataOutput;

Copied: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/DoubleMessage.java
(from r1295023, incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/DoubleMessage.java)
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/DoubleMessage.java?p2=incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/DoubleMessage.java&p1=incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/DoubleMessage.java&r1=1295023&r2=1295028&rev=1295028&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/DoubleMessage.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/DoubleMessage.java
Wed Feb 29 09:22:06 2012
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hama.bsp;
+package org.apache.hama.bsp.messages;
 
 import java.io.DataInput;
 import java.io.DataOutput;

Copied: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/IntegerDoubleMessage.java
(from r1295023, incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/IntegerDoubleMessage.java)
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/IntegerDoubleMessage.java?p2=incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/IntegerDoubleMessage.java&p1=incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/IntegerDoubleMessage.java&r1=1295023&r2=1295028&rev=1295028&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/IntegerDoubleMessage.java
(original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/IntegerDoubleMessage.java
Wed Feb 29 09:22:06 2012
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hama.bsp;
+package org.apache.hama.bsp.messages;
 
 import java.io.DataInput;
 import java.io.DataOutput;

Copied: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/IntegerMessage.java
(from r1295023, incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/IntegerMessage.java)
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/IntegerMessage.java?p2=incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/IntegerMessage.java&p1=incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/IntegerMessage.java&r1=1295023&r2=1295028&rev=1295028&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/IntegerMessage.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/IntegerMessage.java
Wed Feb 29 09:22:06 2012
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hama.bsp;
+package org.apache.hama.bsp.messages;
 
 import java.io.DataInput;
 import java.io.DataOutput;

Copied: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/LongMessage.java
(from r1295023, incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/LongMessage.java)
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/LongMessage.java?p2=incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/LongMessage.java&p1=incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/LongMessage.java&r1=1295023&r2=1295028&rev=1295028&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/LongMessage.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/LongMessage.java
Wed Feb 29 09:22:06 2012
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hama.bsp;
+package org.apache.hama.bsp.messages;
 
 import java.io.DataInput;
 import java.io.DataOutput;

Modified: incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestCheckpoint.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestCheckpoint.java?rev=1295028&r1=1295027&r2=1295028&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestCheckpoint.java (original)
+++ incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestCheckpoint.java Wed Feb
29 09:22:06 2012
@@ -26,6 +26,7 @@ import org.apache.hadoop.fs.FSDataInputS
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
 import org.apache.hama.HamaConfiguration;
+import org.apache.hama.bsp.messages.ByteMessage;
 
 public class TestCheckpoint extends TestCase {
 

Modified: incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestMessages.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestMessages.java?rev=1295028&r1=1295027&r2=1295028&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestMessages.java (original)
+++ incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestMessages.java Wed Feb
29 09:22:06 2012
@@ -19,6 +19,7 @@ package org.apache.hama.bsp;
 
 import junit.framework.TestCase;
 
+import org.apache.hama.bsp.messages.ByteMessage;
 import org.apache.hama.util.Bytes;
 
 public class TestMessages extends TestCase {

Modified: incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java?rev=1295028&r1=1295027&r2=1295028&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java
(original)
+++ incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java
Wed Feb 29 09:22:06 2012
@@ -25,9 +25,9 @@ import junit.framework.TestCase;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.Writable;
 import org.apache.hama.bsp.BSPMessageBundle;
-import org.apache.hama.bsp.BooleanMessage;
-import org.apache.hama.bsp.DoubleMessage;
-import org.apache.hama.bsp.IntegerMessage;
+import org.apache.hama.bsp.messages.BooleanMessage;
+import org.apache.hama.bsp.messages.DoubleMessage;
+import org.apache.hama.bsp.messages.IntegerMessage;
 import org.apache.hama.util.BSPNetUtils;
 
 public class TestAvroMessageManager extends TestCase {

Modified: incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/compress/TestBSPMessageCompressor.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/compress/TestBSPMessageCompressor.java?rev=1295028&r1=1295027&r2=1295028&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/compress/TestBSPMessageCompressor.java
(original)
+++ incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/compress/TestBSPMessageCompressor.java
Wed Feb 29 09:22:06 2012
@@ -20,9 +20,9 @@ package org.apache.hama.bsp.message.comp
 import junit.framework.TestCase;
 
 import org.apache.hadoop.conf.Configuration;
-import org.apache.hama.bsp.BSPMessage;
 import org.apache.hama.bsp.BSPMessageBundle;
-import org.apache.hama.bsp.IntegerMessage;
+import org.apache.hama.bsp.messages.BSPMessage;
+import org.apache.hama.bsp.messages.IntegerMessage;
 
 public class TestBSPMessageCompressor extends TestCase {
 



Mime
View raw message