incubator-hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tomm...@apache.org
Subject svn commit: r1338581 - in /incubator/hama/trunk: core/src/main/java/org/apache/hama/bsp/messages/ core/src/main/java/org/apache/hama/bsp/type/ core/src/test/java/org/apache/hama/bsp/ core/src/test/java/org/apache/hama/bsp/message/ core/src/test/java/or...
Date Tue, 15 May 2012 08:03:51 GMT
Author: tommaso
Date: Tue May 15 08:03:50 2012
New Revision: 1338581

URL: http://svn.apache.org/viewvc?rev=1338581&view=rev
Log:
[HAMA-573] - renamed package messages to type

Added:
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/
      - copied from r1338254, incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/
Removed:
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/messages/
Modified:
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/BSPMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/BooleanMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/ByteMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/DoubleMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/IntegerDoubleMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/IntegerMessage.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/LongMessage.java
    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
    incubator/hama/trunk/examples/src/main/java/org/apache/hama/examples/SuperstepPiEstimator.java

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/BSPMessage.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/BSPMessage.java?rev=1338581&r1=1338254&r2=1338581&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/BSPMessage.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/BSPMessage.java Tue May
15 08:03:50 2012
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hama.bsp.messages;
+package org.apache.hama.bsp.message.type;
 
 import org.apache.hadoop.io.Writable;
 import org.apache.hama.bsp.Messagable;

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/BooleanMessage.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/BooleanMessage.java?rev=1338581&r1=1338254&r2=1338581&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/BooleanMessage.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/BooleanMessage.java Tue
May 15 08:03:50 2012
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hama.bsp.messages;
+package org.apache.hama.bsp.message.type;
 
 import java.io.DataInput;
 import java.io.DataOutput;

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/ByteMessage.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/ByteMessage.java?rev=1338581&r1=1338254&r2=1338581&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/ByteMessage.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/ByteMessage.java Tue
May 15 08:03:50 2012
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hama.bsp.messages;
+package org.apache.hama.bsp.message.type;
 
 import java.io.DataInput;
 import java.io.DataOutput;

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/DoubleMessage.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/DoubleMessage.java?rev=1338581&r1=1338254&r2=1338581&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/DoubleMessage.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/DoubleMessage.java Tue
May 15 08:03:50 2012
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hama.bsp.messages;
+package org.apache.hama.bsp.message.type;
 
 import java.io.DataInput;
 import java.io.DataOutput;

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/IntegerDoubleMessage.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/IntegerDoubleMessage.java?rev=1338581&r1=1338254&r2=1338581&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/IntegerDoubleMessage.java
(original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/IntegerDoubleMessage.java
Tue May 15 08:03:50 2012
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hama.bsp.messages;
+package org.apache.hama.bsp.message.type;
 
 import java.io.DataInput;
 import java.io.DataOutput;

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/IntegerMessage.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/IntegerMessage.java?rev=1338581&r1=1338254&r2=1338581&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/IntegerMessage.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/IntegerMessage.java Tue
May 15 08:03:50 2012
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hama.bsp.messages;
+package org.apache.hama.bsp.message.type;
 
 import java.io.DataInput;
 import java.io.DataOutput;

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/LongMessage.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/LongMessage.java?rev=1338581&r1=1338254&r2=1338581&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/LongMessage.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/type/LongMessage.java Tue
May 15 08:03:50 2012
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.hama.bsp.messages;
+package org.apache.hama.bsp.message.type;
 
 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=1338581&r1=1338580&r2=1338581&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 Tue May
15 08:03:50 2012
@@ -32,7 +32,7 @@ import org.apache.hadoop.ipc.Server;
 import org.apache.hama.Constants;
 import org.apache.hama.HamaConfiguration;
 import org.apache.hama.bsp.TestBSPTaskFaults.MinimalGroomServer;
-import org.apache.hama.bsp.messages.ByteMessage;
+import org.apache.hama.bsp.message.type.ByteMessage;
 import org.apache.hama.bsp.sync.SyncClient;
 import org.apache.hama.bsp.sync.SyncServiceFactory;
 import org.apache.hama.ipc.BSPPeerProtocol;

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=1338581&r1=1338580&r2=1338581&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 Tue May
15 08:03:50 2012
@@ -19,7 +19,7 @@ package org.apache.hama.bsp;
 
 import junit.framework.TestCase;
 
-import org.apache.hama.bsp.messages.ByteMessage;
+import org.apache.hama.bsp.message.type.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=1338581&r1=1338580&r2=1338581&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
Tue May 15 08:03:50 2012
@@ -33,9 +33,9 @@ import org.apache.hama.bsp.Counters;
 import org.apache.hama.bsp.TaskAttemptID;
 import org.apache.hama.bsp.message.compress.BSPMessageCompressorFactory;
 import org.apache.hama.bsp.message.compress.SnappyCompressor;
-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.bsp.message.type.BooleanMessage;
+import org.apache.hama.bsp.message.type.DoubleMessage;
+import org.apache.hama.bsp.message.type.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=1338581&r1=1338580&r2=1338581&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
Tue May 15 08:03:50 2012
@@ -21,8 +21,8 @@ import junit.framework.TestCase;
 
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hama.bsp.BSPMessageBundle;
-import org.apache.hama.bsp.messages.BSPMessage;
-import org.apache.hama.bsp.messages.IntegerMessage;
+import org.apache.hama.bsp.message.type.BSPMessage;
+import org.apache.hama.bsp.message.type.IntegerMessage;
 
 public class TestBSPMessageCompressor extends TestCase {
 

Modified: incubator/hama/trunk/examples/src/main/java/org/apache/hama/examples/SuperstepPiEstimator.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/examples/src/main/java/org/apache/hama/examples/SuperstepPiEstimator.java?rev=1338581&r1=1338580&r2=1338581&view=diff
==============================================================================
--- incubator/hama/trunk/examples/src/main/java/org/apache/hama/examples/SuperstepPiEstimator.java
(original)
+++ incubator/hama/trunk/examples/src/main/java/org/apache/hama/examples/SuperstepPiEstimator.java
Tue May 15 08:03:50 2012
@@ -37,7 +37,7 @@ import org.apache.hama.bsp.NullInputForm
 import org.apache.hama.bsp.Superstep;
 import org.apache.hama.bsp.SuperstepBSP;
 import org.apache.hama.bsp.TextOutputFormat;
-import org.apache.hama.bsp.messages.DoubleMessage;
+import org.apache.hama.bsp.message.type.DoubleMessage;
 
 /**
  * This PiEstimator uses the new chainable superstep API to be fault tolerant.



Mime
View raw message