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 2015/07/22 15:01:05 UTC
[32/52] [abbrv] tajo git commit: TAJO-1691: Refactor visitors and
planner to throw TajoException.
http://git-wip-us.apache.org/repos/asf/tajo/blob/4841c656/tajo-storage/tajo-storage-hbase/src/main/java/org/apache/tajo/storage/hbase/SortedInsertRewriter.java
----------------------------------------------------------------------
diff --git a/tajo-storage/tajo-storage-hbase/src/main/java/org/apache/tajo/storage/hbase/SortedInsertRewriter.java b/tajo-storage/tajo-storage-hbase/src/main/java/org/apache/tajo/storage/hbase/SortedInsertRewriter.java
index ebf557e..db9f3c8 100644
--- a/tajo-storage/tajo-storage-hbase/src/main/java/org/apache/tajo/storage/hbase/SortedInsertRewriter.java
+++ b/tajo-storage/tajo-storage-hbase/src/main/java/org/apache/tajo/storage/hbase/SortedInsertRewriter.java
@@ -22,8 +22,9 @@ import org.apache.tajo.OverridableConf;
import org.apache.tajo.catalog.Column;
import org.apache.tajo.catalog.Schema;
import org.apache.tajo.catalog.SortSpec;
+import org.apache.tajo.exception.TajoException;
+import org.apache.tajo.exception.TajoInternalError;
import org.apache.tajo.plan.LogicalPlan;
-import org.apache.tajo.plan.PlanningException;
import org.apache.tajo.plan.logical.*;
import org.apache.tajo.plan.logical.SortNode.SortPurpose;
import org.apache.tajo.plan.rewrite.LogicalPlanRewriteRule;
@@ -68,7 +69,7 @@ public class SortedInsertRewriter implements LogicalPlanRewriteRule {
}
@Override
- public LogicalPlan rewrite(OverridableConf queryContext, LogicalPlan plan) throws PlanningException {
+ public LogicalPlan rewrite(OverridableConf queryContext, LogicalPlan plan) throws TajoException {
LogicalRootNode rootNode = plan.getRootBlock().getRoot();
StoreTableNode storeTable = rootNode.getChild();
@@ -78,7 +79,7 @@ public class SortedInsertRewriter implements LogicalPlanRewriteRule {
try {
sortColumns = getIndexColumns(tableSchema, storeTable.getOptions());
} catch (IOException e) {
- throw new PlanningException(e);
+ throw new TajoInternalError(e);
}
int[] sortColumnIndexes = new int[sortColumns.length];
@@ -101,7 +102,7 @@ public class SortedInsertRewriter implements LogicalPlanRewriteRule {
for (int i = 0; i < sortColumnIndexes.length; i++) {
Column sortColumn = sortSchema.getColumn(sortColumnIndexes[i]);
if (sortColumn == null) {
- throw new PlanningException("Can't fine proper sort column:" + sortColumns[i]);
+ throw new TajoInternalError("Can't fine proper sort column:" + sortColumns[i]);
}
sortSpecs[index++] = new SortSpec(sortColumn, true, true);
}