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 <[email protected]> Authored: Fri Nov 14 13:55:46 2014 +0900 Committer: Jihoon Son <[email protected]> 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();
