You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by ed...@apache.org on 2008/12/30 13:14:08 UTC

svn commit: r730115 - in /incubator/hama/trunk/src/java/org/apache/hama: algebra/BlockCyclicMultiplyMap.java io/BlockEntry.java io/BlockPosition.java io/IntegerEntry.java io/MapWritable.java mapred/TableRecordReaderBase.java

Author: edwardyoon
Date: Tue Dec 30 04:14:07 2008
New Revision: 730115

URL: http://svn.apache.org/viewvc?rev=730115&view=rev
Log:
Remove unuseful codes

Removed:
    incubator/hama/trunk/src/java/org/apache/hama/io/BlockEntry.java
    incubator/hama/trunk/src/java/org/apache/hama/io/BlockPosition.java
    incubator/hama/trunk/src/java/org/apache/hama/io/IntegerEntry.java
Modified:
    incubator/hama/trunk/src/java/org/apache/hama/algebra/BlockCyclicMultiplyMap.java
    incubator/hama/trunk/src/java/org/apache/hama/io/MapWritable.java
    incubator/hama/trunk/src/java/org/apache/hama/mapred/TableRecordReaderBase.java

Modified: incubator/hama/trunk/src/java/org/apache/hama/algebra/BlockCyclicMultiplyMap.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/java/org/apache/hama/algebra/BlockCyclicMultiplyMap.java?rev=730115&r1=730114&r2=730115&view=diff
==============================================================================
--- incubator/hama/trunk/src/java/org/apache/hama/algebra/BlockCyclicMultiplyMap.java (original)
+++ incubator/hama/trunk/src/java/org/apache/hama/algebra/BlockCyclicMultiplyMap.java Tue Dec 30 04:14:07 2008
@@ -73,6 +73,7 @@
   public void map(BlockID key, BlockWritable value,
       OutputCollector<BlockID, BlockWritable> output, Reporter reporter)
       throws IOException {
+    // we don't need to get blockSize each time
     int blockSize = matrix_b.getRows();
     SubMatrix a = value.get();
     HTable table = matrix_b.getHTable();

Modified: incubator/hama/trunk/src/java/org/apache/hama/io/MapWritable.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/java/org/apache/hama/io/MapWritable.java?rev=730115&r1=730114&r2=730115&view=diff
==============================================================================
--- incubator/hama/trunk/src/java/org/apache/hama/io/MapWritable.java (original)
+++ incubator/hama/trunk/src/java/org/apache/hama/io/MapWritable.java Tue Dec 30 04:14:07 2008
@@ -54,7 +54,6 @@
     addToMap(ImmutableBytesWritable.class, code++);
     addToMap(Text.class, code++);
     addToMap(DoubleEntry.class, code++);
-    addToMap(BlockEntry.class, code++);
     addToMap(byte[].class, code++);
   }
 

Modified: incubator/hama/trunk/src/java/org/apache/hama/mapred/TableRecordReaderBase.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/java/org/apache/hama/mapred/TableRecordReaderBase.java?rev=730115&r1=730114&r2=730115&view=diff
==============================================================================
--- incubator/hama/trunk/src/java/org/apache/hama/mapred/TableRecordReaderBase.java (original)
+++ incubator/hama/trunk/src/java/org/apache/hama/mapred/TableRecordReaderBase.java Tue Dec 30 04:14:07 2008
@@ -28,7 +28,6 @@
 import org.apache.hadoop.hbase.filter.RowFilterInterface;
 import org.apache.hadoop.hbase.filter.RowFilterSet;
 import org.apache.hadoop.hbase.filter.StopRowFilter;
-import org.apache.hama.io.BlockPosition;
 
 public abstract class TableRecordReaderBase {
   protected byte[] startRow;