Author: edwardyoon
Date: Wed Jan 15 00:48:32 2014
New Revision: 1558248
URL: http://svn.apache.org/r1558248
Log:
HAMA-849: No need to use sorted queue for outgoingQueue
Modified:
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SortedMemoryQueueTransfer.java
Modified:
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SortedMemoryQueueTransfer.java
URL:
http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SortedMemoryQueueTransfer.java?rev=1558248&r1=1558247&r2=1558248&view=diff
==============================================================================
---
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SortedMemoryQueueTransfer.java
(original)
+++
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SortedMemoryQueueTransfer.java
Wed Jan 15 00:48:32 2014
@@ -28,9 +28,12 @@ import org.apache.hadoop.io.WritableComp
public class SortedMemoryQueueTransfer<M extends WritableComparable<M>>
implements
MessageTransferProtocol<M> {
+ /**
+ * OutgoingQueue doesn't need to be sorted.
+ */
@Override
- public SortedMemoryQueue<M> getSenderQueue(Configuration conf) {
- return new SortedMemoryQueue<M>();
+ public MemoryQueue<M> getSenderQueue(Configuration conf) {
+ return new MemoryQueue<M>();
}
@Override
