Author: edwardyoon
Date: Thu Dec 13 01:26:11 2012
New Revision: 1421058
URL: http://svn.apache.org/viewvc?rev=1421058&view=rev
Log:
Move Avro RPC to contrib project
Added:
hama/trunk/contrib/avro-rpc/
hama/trunk/contrib/avro-rpc/src/
hama/trunk/contrib/avro-rpc/src/main/
hama/trunk/contrib/avro-rpc/src/main/java/
hama/trunk/contrib/avro-rpc/src/main/java/org/
hama/trunk/contrib/avro-rpc/src/main/java/org/apache/
hama/trunk/contrib/avro-rpc/src/main/java/org/apache/hama/
hama/trunk/contrib/avro-rpc/src/main/java/org/apache/hama/avro/
hama/trunk/contrib/avro-rpc/src/main/java/org/apache/hama/avro/AvroBSPMessageBundle.java
- copied unchanged from r1421053,
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AvroBSPMessageBundle.java
hama/trunk/contrib/avro-rpc/src/main/java/org/apache/hama/avro/AvroMessageManagerImpl.java
- copied unchanged from r1421053,
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AvroMessageManagerImpl.java
hama/trunk/contrib/avro-rpc/src/main/java/org/apache/hama/avro/Sender.java
- copied unchanged from r1421053,
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/Sender.java
hama/trunk/contrib/avro-rpc/src/main/java/org/apache/hama/avro/TestAvroMessageManager.java
- copied unchanged from r1421053,
hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java
Removed:
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AvroBSPMessageBundle.java
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AvroMessageManagerImpl.java
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/Sender.java
hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java
Modified:
hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestDiskQueue.java
Modified:
hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestDiskQueue.java
URL:
http://svn.apache.org/viewvc/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestDiskQueue.java?rev=1421058&r1=1421057&r2=1421058&view=diff
==============================================================================
---
hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestDiskQueue.java
(original)
+++
hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestDiskQueue.java
Thu Dec 13 01:26:11 2012
@@ -29,11 +29,11 @@ import org.apache.hama.bsp.message.queue
import org.junit.Test;
public class TestDiskQueue extends TestCase {
+ public static final String TMP_OUTPUT_PATH = "/tmp/messageQueue";
static Configuration conf = new Configuration();
static {
- conf.set(DiskQueue.DISK_QUEUE_PATH_KEY,
- TestAvroMessageManager.TMP_OUTPUT_PATH);
+ conf.set(DiskQueue.DISK_QUEUE_PATH_KEY, TMP_OUTPUT_PATH);
}
@Test
