hama/trunk/conf/hama-env.sh
|
modified
, text changed
|
hama/trunk/conf/hama-site.xml
|
modified
, text changed
|
hama/trunk/core/src/main/java/org/apache/hama/bsp/LocalBSPRunner.java
|
modified
, text changed
|
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java
|
modified
, text changed
|
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/io/
(Copied from hama/trunk/core/src/main/java/org/apache/hama/bsp/message/io, r1617395)
|
added
|
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/BSPMessageInterface.java
(Copied from hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/BSPMessageInterface.java, r1617395)
|
added
|
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/ByteArrayMessageQueue.java
(Copied from hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/ByteArrayMessageQueue.java, r1617395)
|
added
|
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/DefaultMessageQueue.java
(Copied from hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/DefaultMessageQueue.java, r1617395)
|
added
|
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/DiskQueue.java
|
modified
, text changed
|
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/MemoryQueue.java
|
modified
, text changed
|
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/MessageQueue.java
|
modified
, text changed
|
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SingleLockQueue.java
|
modified
, text changed
|
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SortedMemoryQueue.java
|
modified
, text changed
|
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SpillingQueue.java
(Copied from hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SpillingQueue.java, r1617395)
|
added
|
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SynchronizedQueue.java
|
modified
, text changed
|
hama/trunk/core/src/test/java/org/apache/hama/bsp/TestPersistQueue.java
|
modified
, text changed
|
hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestHamaMessageManager.java
|
modified
, text changed
|
hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestMessageIO.java
(Copied from hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestMessageIO.java, r1617395)
|
added
|
hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestSpillingQueue.java
(Copied from hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestSpillingQueue.java, r1617395)
|
added
|