[
https://issues.apache.org/jira/browse/HAMA-722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13637375#comment-13637375
]
Hudson commented on HAMA-722:
-----------------------------
Integrated in Hama trunk #117 (See
[https://builds.apache.org/job/Hama%20trunk/117/])
Fixes for [HAMA-707] and [HAMA-722] (Revision 1470171)
Result = SUCCESS
surajsmenon :
Files :
* /hama/trunk/CHANGES.txt
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java
* /hama/trunk/core/src/main/java/org/apache/hama/bsp/message/MessageManager.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/MessageTransferQueueFactory.java
* /hama/trunk/core/src/main/java/org/apache/hama/bsp/message/bundle
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/bundle/BSPMessageBundle.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/bundle/ByteBufferBSPMessageBundle.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/bundle/HeapByteArrayBSPMessageBundle.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/bundle/POJOMessageBundle.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/bundle/WritableMessageBundle.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/io/SpillingDataOutputBuffer.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/BSPMessageInterface.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/ByteArrayMessageQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/DiskQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/DiskTransferProtocolQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/MemoryQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/MemoryTransferProtocol.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/MessageQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/MessageTransferQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/POJOMessageQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SingleLockQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SortedMessageQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SpillingQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SpillingQueueTransferProtocol.java
*
/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestHadoopMessageManager.java
*
/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestMessageBundle.java
> Messaging queue should construct sender and receiver queue.
> -----------------------------------------------------------
>
> Key: HAMA-722
> URL: https://issues.apache.org/jira/browse/HAMA-722
> Project: Hama
> Issue Type: New Feature
> Components: bsp core
> Reporter: Suraj Menon
> Assignee: Suraj Menon
> Fix For: 0.7.0
>
> Attachments: HAMA-722.patch
>
>
> Change the existing message queue interface, so that framework could
> instantiate the sender and receiver queues. This is essential to implement
> protocols between the sender and receiver. For example, sender queue would
> send series of sorted segments and the receiver queue would be based on merge
> sort.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
