You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tajo.apache.org by ji...@apache.org on 2014/11/14 05:56:06 UTC
[7/7] tajo git commit: index support
index support
Project: http://git-wip-us.apache.org/repos/asf/tajo/repo
Commit: http://git-wip-us.apache.org/repos/asf/tajo/commit/f2f8981e
Tree: http://git-wip-us.apache.org/repos/asf/tajo/tree/f2f8981e
Diff: http://git-wip-us.apache.org/repos/asf/tajo/diff/f2f8981e
Branch: refs/heads/index_support
Commit: f2f8981ea63027e10df18a3b16b29148f2d7b36a
Parents: 02b827e
Author: Jihoon Son <ji...@apache.org>
Authored: Fri Nov 14 13:55:46 2014 +0900
Committer: Jihoon Son <ji...@apache.org>
Committed: Fri Nov 14 13:55:46 2014 +0900
----------------------------------------------------------------------
.../apache/tajo/engine/planner/physical/StoreIndexExec.java | 7 ++-----
1 file changed, 2 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tajo/blob/f2f8981e/tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/StoreIndexExec.java
----------------------------------------------------------------------
diff --git a/tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/StoreIndexExec.java b/tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/StoreIndexExec.java
index be1af50..0592217 100644
--- a/tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/StoreIndexExec.java
+++ b/tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/StoreIndexExec.java
@@ -28,10 +28,7 @@ import org.apache.tajo.catalog.SortSpec;
import org.apache.tajo.conf.TajoConf;
import org.apache.tajo.plan.logical.CreateIndexNode;
import org.apache.tajo.plan.util.PlannerUtil;
-import org.apache.tajo.storage.RowStoreUtil;
-import org.apache.tajo.storage.Tuple;
-import org.apache.tajo.storage.TupleComparator;
-import org.apache.tajo.storage.VTuple;
+import org.apache.tajo.storage.*;
import org.apache.tajo.storage.index.bst.BSTIndex;
import org.apache.tajo.storage.index.bst.BSTIndex.BSTIndexWriter;
import org.apache.tajo.worker.TaskAttemptContext;
@@ -71,7 +68,7 @@ public class StoreIndexExec extends UnaryPhysicalExec {
System.out.println("exec: " + indexPath);
// TODO: Create factory using reflection
BSTIndex bst = new BSTIndex(conf);
- this.comparator = new TupleComparator(keySchema, sortSpecs);
+ this.comparator = new BaseTupleComparator(keySchema, sortSpecs);
this.indexWriter = bst.getIndexWriter(indexPath, BSTIndex.TWO_LEVEL_INDEX, keySchema, comparator);
this.indexWriter.setLoadNum(100);
this.indexWriter.open();