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;