http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/ParallelPlanner.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/ParallelPlanner.java b/fe/src/main/java/org/apache/impala/planner/ParallelPlanner.java index 905d68d..6db4ae4 100644 --- a/fe/src/main/java/org/apache/impala/planner/ParallelPlanner.java +++ b/fe/src/main/java/org/apache/impala/planner/ParallelPlanner.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; import java.util.ArrayList; import java.util.List; @@ -24,7 +24,7 @@ import java.util.Map; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.common.IdGenerator; +import org.apache.impala.common.IdGenerator; import com.google.common.base.Joiner; import com.google.common.base.Preconditions; import com.google.common.collect.Lists;
http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/PipelinedPlanNodeSet.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/PipelinedPlanNodeSet.java b/fe/src/main/java/org/apache/impala/planner/PipelinedPlanNodeSet.java index 6714213..249987a 100644 --- a/fe/src/main/java/org/apache/impala/planner/PipelinedPlanNodeSet.java +++ b/fe/src/main/java/org/apache/impala/planner/PipelinedPlanNodeSet.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; import java.util.ArrayList; import java.util.List; @@ -24,7 +24,7 @@ import java.util.Set; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.thrift.TQueryOptions; +import org.apache.impala.thrift.TQueryOptions; import com.google.common.base.Preconditions; import com.google.common.collect.Lists; import com.google.common.collect.Sets; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/PlanFragment.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/PlanFragment.java b/fe/src/main/java/org/apache/impala/planner/PlanFragment.java index 48a71dc..0e5134f 100644 --- a/fe/src/main/java/org/apache/impala/planner/PlanFragment.java +++ b/fe/src/main/java/org/apache/impala/planner/PlanFragment.java @@ -15,30 +15,30 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; import java.util.List; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.BinaryPredicate; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.JoinOperator; -import com.cloudera.impala.analysis.SlotRef; -import com.cloudera.impala.catalog.HdfsFileFormat; -import com.cloudera.impala.catalog.HdfsTable; -import com.cloudera.impala.common.AnalysisException; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.common.NotImplementedException; -import com.cloudera.impala.common.TreeNode; -import com.cloudera.impala.planner.JoinNode.DistributionMode; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TPartitionType; -import com.cloudera.impala.thrift.TPlan; -import com.cloudera.impala.thrift.TPlanFragment; -import com.cloudera.impala.thrift.TPlanFragmentTree; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.BinaryPredicate; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.JoinOperator; +import org.apache.impala.analysis.SlotRef; +import org.apache.impala.catalog.HdfsFileFormat; +import org.apache.impala.catalog.HdfsTable; +import org.apache.impala.common.AnalysisException; +import org.apache.impala.common.InternalException; +import org.apache.impala.common.NotImplementedException; +import org.apache.impala.common.TreeNode; +import org.apache.impala.planner.JoinNode.DistributionMode; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TPartitionType; +import org.apache.impala.thrift.TPlan; +import org.apache.impala.thrift.TPlanFragment; +import org.apache.impala.thrift.TPlanFragmentTree; import com.google.common.base.Preconditions; import com.google.common.base.Predicates; import com.google.common.collect.Lists; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/PlanFragmentId.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/PlanFragmentId.java b/fe/src/main/java/org/apache/impala/planner/PlanFragmentId.java index 98b08fe..99c96e9 100644 --- a/fe/src/main/java/org/apache/impala/planner/PlanFragmentId.java +++ b/fe/src/main/java/org/apache/impala/planner/PlanFragmentId.java @@ -15,10 +15,10 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; -import com.cloudera.impala.common.Id; -import com.cloudera.impala.common.IdGenerator; +import org.apache.impala.common.Id; +import org.apache.impala.common.IdGenerator; public class PlanFragmentId extends Id<PlanFragmentId> { // Construction only allowed via an IdGenerator. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/PlanId.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/PlanId.java b/fe/src/main/java/org/apache/impala/planner/PlanId.java index 2cecbd8..72ed46f 100644 --- a/fe/src/main/java/org/apache/impala/planner/PlanId.java +++ b/fe/src/main/java/org/apache/impala/planner/PlanId.java @@ -15,10 +15,10 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; -import com.cloudera.impala.common.Id; -import com.cloudera.impala.common.IdGenerator; +import org.apache.impala.common.Id; +import org.apache.impala.common.IdGenerator; public class PlanId extends Id<PlanId> { // Construction only allowed via an IdGenerator. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/PlanNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/PlanNode.java b/fe/src/main/java/org/apache/impala/planner/PlanNode.java index d38f10a..3350364 100644 --- a/fe/src/main/java/org/apache/impala/planner/PlanNode.java +++ b/fe/src/main/java/org/apache/impala/planner/PlanNode.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; import java.util.ArrayList; import java.util.Collection; @@ -26,21 +26,21 @@ import java.util.Set; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.ExprId; -import com.cloudera.impala.analysis.ExprSubstitutionMap; -import com.cloudera.impala.analysis.TupleDescriptor; -import com.cloudera.impala.analysis.TupleId; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.PrintUtils; -import com.cloudera.impala.common.TreeNode; -import com.cloudera.impala.planner.RuntimeFilterGenerator.RuntimeFilter; -import com.cloudera.impala.thrift.TExecStats; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TPlan; -import com.cloudera.impala.thrift.TPlanNode; -import com.cloudera.impala.thrift.TQueryOptions; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.ExprId; +import org.apache.impala.analysis.ExprSubstitutionMap; +import org.apache.impala.analysis.TupleDescriptor; +import org.apache.impala.analysis.TupleId; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.PrintUtils; +import org.apache.impala.common.TreeNode; +import org.apache.impala.planner.RuntimeFilterGenerator.RuntimeFilter; +import org.apache.impala.thrift.TExecStats; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TPlan; +import org.apache.impala.thrift.TPlanNode; +import org.apache.impala.thrift.TQueryOptions; import com.google.common.base.Joiner; import com.google.common.base.Preconditions; import com.google.common.collect.Lists; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/PlanNodeId.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/PlanNodeId.java b/fe/src/main/java/org/apache/impala/planner/PlanNodeId.java index d161e2b..2afad37 100644 --- a/fe/src/main/java/org/apache/impala/planner/PlanNodeId.java +++ b/fe/src/main/java/org/apache/impala/planner/PlanNodeId.java @@ -15,10 +15,10 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; -import com.cloudera.impala.common.Id; -import com.cloudera.impala.common.IdGenerator; +import org.apache.impala.common.Id; +import org.apache.impala.common.IdGenerator; public class PlanNodeId extends Id<PlanNodeId> { // Construction only allowed via an IdGenerator. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/Planner.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/Planner.java b/fe/src/main/java/org/apache/impala/planner/Planner.java index df90df3..e50aca5 100644 --- a/fe/src/main/java/org/apache/impala/planner/Planner.java +++ b/fe/src/main/java/org/apache/impala/planner/Planner.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; import java.util.ArrayList; import java.util.Collections; @@ -24,25 +24,25 @@ import java.util.List; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.AnalysisContext; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.ColumnLineageGraph; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.ExprSubstitutionMap; -import com.cloudera.impala.analysis.InsertStmt; -import com.cloudera.impala.analysis.JoinOperator; -import com.cloudera.impala.analysis.QueryStmt; -import com.cloudera.impala.catalog.HBaseTable; -import com.cloudera.impala.catalog.Table; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.PrintUtils; -import com.cloudera.impala.common.RuntimeEnv; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TQueryCtx; -import com.cloudera.impala.thrift.TQueryExecRequest; -import com.cloudera.impala.thrift.TRuntimeFilterMode; -import com.cloudera.impala.thrift.TTableName; -import com.cloudera.impala.util.MaxRowsProcessedVisitor; +import org.apache.impala.analysis.AnalysisContext; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.ColumnLineageGraph; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.ExprSubstitutionMap; +import org.apache.impala.analysis.InsertStmt; +import org.apache.impala.analysis.JoinOperator; +import org.apache.impala.analysis.QueryStmt; +import org.apache.impala.catalog.HBaseTable; +import org.apache.impala.catalog.Table; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.PrintUtils; +import org.apache.impala.common.RuntimeEnv; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TQueryCtx; +import org.apache.impala.thrift.TQueryExecRequest; +import org.apache.impala.thrift.TRuntimeFilterMode; +import org.apache.impala.thrift.TTableName; +import org.apache.impala.util.MaxRowsProcessedVisitor; import com.google.common.base.Joiner; import com.google.common.base.Preconditions; import com.google.common.collect.Lists; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/PlannerContext.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/PlannerContext.java b/fe/src/main/java/org/apache/impala/planner/PlannerContext.java index fc11287..29cca13 100644 --- a/fe/src/main/java/org/apache/impala/planner/PlannerContext.java +++ b/fe/src/main/java/org/apache/impala/planner/PlannerContext.java @@ -15,16 +15,16 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; import java.util.LinkedList; -import com.cloudera.impala.analysis.AnalysisContext; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.QueryStmt; -import com.cloudera.impala.common.IdGenerator; -import com.cloudera.impala.thrift.TQueryCtx; -import com.cloudera.impala.thrift.TQueryOptions; +import org.apache.impala.analysis.AnalysisContext; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.QueryStmt; +import org.apache.impala.common.IdGenerator; +import org.apache.impala.thrift.TQueryCtx; +import org.apache.impala.thrift.TQueryOptions; import com.google.common.collect.Lists; /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/RuntimeFilterGenerator.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/RuntimeFilterGenerator.java b/fe/src/main/java/org/apache/impala/planner/RuntimeFilterGenerator.java index f0cafd5..f4535a5 100644 --- a/fe/src/main/java/org/apache/impala/planner/RuntimeFilterGenerator.java +++ b/fe/src/main/java/org/apache/impala/planner/RuntimeFilterGenerator.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; import java.util.Collections; import java.util.Comparator; @@ -24,22 +24,22 @@ import java.util.List; import java.util.Map; import java.util.Set; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.BinaryPredicate; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.ExprSubstitutionMap; -import com.cloudera.impala.analysis.Predicate; -import com.cloudera.impala.analysis.SlotDescriptor; -import com.cloudera.impala.analysis.SlotId; -import com.cloudera.impala.analysis.SlotRef; -import com.cloudera.impala.analysis.TupleDescriptor; -import com.cloudera.impala.analysis.TupleId; -import com.cloudera.impala.analysis.TupleIsNullPredicate; -import com.cloudera.impala.catalog.Table; -import com.cloudera.impala.common.IdGenerator; -import com.cloudera.impala.planner.PlanNode; -import com.cloudera.impala.thrift.TRuntimeFilterDesc; -import com.cloudera.impala.thrift.TRuntimeFilterTargetDesc; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.BinaryPredicate; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.ExprSubstitutionMap; +import org.apache.impala.analysis.Predicate; +import org.apache.impala.analysis.SlotDescriptor; +import org.apache.impala.analysis.SlotId; +import org.apache.impala.analysis.SlotRef; +import org.apache.impala.analysis.TupleDescriptor; +import org.apache.impala.analysis.TupleId; +import org.apache.impala.analysis.TupleIsNullPredicate; +import org.apache.impala.catalog.Table; +import org.apache.impala.common.IdGenerator; +import org.apache.impala.planner.PlanNode; +import org.apache.impala.thrift.TRuntimeFilterDesc; +import org.apache.impala.thrift.TRuntimeFilterTargetDesc; import com.google.common.base.Joiner; import com.google.common.base.Preconditions; import com.google.common.collect.Lists; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/RuntimeFilterId.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/RuntimeFilterId.java b/fe/src/main/java/org/apache/impala/planner/RuntimeFilterId.java index 32af78c..9253207 100644 --- a/fe/src/main/java/org/apache/impala/planner/RuntimeFilterId.java +++ b/fe/src/main/java/org/apache/impala/planner/RuntimeFilterId.java @@ -15,10 +15,10 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; -import com.cloudera.impala.common.Id; -import com.cloudera.impala.common.IdGenerator; +import org.apache.impala.common.Id; +import org.apache.impala.common.IdGenerator; public class RuntimeFilterId extends Id<RuntimeFilterId> { // Construction only allowed via an IdGenerator. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/ScanNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/ScanNode.java b/fe/src/main/java/org/apache/impala/planner/ScanNode.java index b442b4a..f444ffa 100644 --- a/fe/src/main/java/org/apache/impala/planner/ScanNode.java +++ b/fe/src/main/java/org/apache/impala/planner/ScanNode.java @@ -15,18 +15,18 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; import java.util.List; -import com.cloudera.impala.analysis.SlotDescriptor; -import com.cloudera.impala.analysis.TupleDescriptor; -import com.cloudera.impala.catalog.HdfsFileFormat; -import com.cloudera.impala.catalog.Type; -import com.cloudera.impala.common.NotImplementedException; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TNetworkAddress; -import com.cloudera.impala.thrift.TScanRangeLocations; +import org.apache.impala.analysis.SlotDescriptor; +import org.apache.impala.analysis.TupleDescriptor; +import org.apache.impala.catalog.HdfsFileFormat; +import org.apache.impala.catalog.Type; +import org.apache.impala.common.NotImplementedException; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TNetworkAddress; +import org.apache.impala.thrift.TScanRangeLocations; import com.google.common.base.Joiner; import com.google.common.base.Objects; import com.google.common.base.Preconditions; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/SelectNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/SelectNode.java b/fe/src/main/java/org/apache/impala/planner/SelectNode.java index b418224..7713520 100644 --- a/fe/src/main/java/org/apache/impala/planner/SelectNode.java +++ b/fe/src/main/java/org/apache/impala/planner/SelectNode.java @@ -15,18 +15,18 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; import java.util.List; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TPlanNode; -import com.cloudera.impala.thrift.TPlanNodeType; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.Expr; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TPlanNode; +import org.apache.impala.thrift.TPlanNodeType; import com.google.common.base.Preconditions; /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/SingleNodePlanner.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/SingleNodePlanner.java b/fe/src/main/java/org/apache/impala/planner/SingleNodePlanner.java index 2212d35..b686fe6 100644 --- a/fe/src/main/java/org/apache/impala/planner/SingleNodePlanner.java +++ b/fe/src/main/java/org/apache/impala/planner/SingleNodePlanner.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; import java.util.ArrayList; import java.util.Collections; @@ -30,43 +30,43 @@ import java.util.Set; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.AggregateInfo; -import com.cloudera.impala.analysis.AnalyticInfo; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.BaseTableRef; -import com.cloudera.impala.analysis.BinaryPredicate; -import com.cloudera.impala.analysis.BinaryPredicate.Operator; -import com.cloudera.impala.analysis.CollectionTableRef; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.ExprId; -import com.cloudera.impala.analysis.ExprSubstitutionMap; -import com.cloudera.impala.analysis.InlineViewRef; -import com.cloudera.impala.analysis.JoinOperator; -import com.cloudera.impala.analysis.NullLiteral; -import com.cloudera.impala.analysis.QueryStmt; -import com.cloudera.impala.analysis.SelectStmt; -import com.cloudera.impala.analysis.SingularRowSrcTableRef; -import com.cloudera.impala.analysis.SlotDescriptor; -import com.cloudera.impala.analysis.SlotId; -import com.cloudera.impala.analysis.SlotRef; -import com.cloudera.impala.analysis.TableRef; -import com.cloudera.impala.analysis.TupleDescriptor; -import com.cloudera.impala.analysis.TupleId; -import com.cloudera.impala.analysis.TupleIsNullPredicate; -import com.cloudera.impala.analysis.UnionStmt; -import com.cloudera.impala.analysis.UnionStmt.UnionOperand; -import com.cloudera.impala.catalog.ColumnStats; -import com.cloudera.impala.catalog.DataSourceTable; -import com.cloudera.impala.catalog.HBaseTable; -import com.cloudera.impala.catalog.HdfsPartition; -import com.cloudera.impala.catalog.HdfsTable; -import com.cloudera.impala.catalog.KuduTable; -import com.cloudera.impala.catalog.Table; -import com.cloudera.impala.catalog.Type; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.common.NotImplementedException; -import com.cloudera.impala.common.Pair; +import org.apache.impala.analysis.AggregateInfo; +import org.apache.impala.analysis.AnalyticInfo; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.BaseTableRef; +import org.apache.impala.analysis.BinaryPredicate; +import org.apache.impala.analysis.BinaryPredicate.Operator; +import org.apache.impala.analysis.CollectionTableRef; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.ExprId; +import org.apache.impala.analysis.ExprSubstitutionMap; +import org.apache.impala.analysis.InlineViewRef; +import org.apache.impala.analysis.JoinOperator; +import org.apache.impala.analysis.NullLiteral; +import org.apache.impala.analysis.QueryStmt; +import org.apache.impala.analysis.SelectStmt; +import org.apache.impala.analysis.SingularRowSrcTableRef; +import org.apache.impala.analysis.SlotDescriptor; +import org.apache.impala.analysis.SlotId; +import org.apache.impala.analysis.SlotRef; +import org.apache.impala.analysis.TableRef; +import org.apache.impala.analysis.TupleDescriptor; +import org.apache.impala.analysis.TupleId; +import org.apache.impala.analysis.TupleIsNullPredicate; +import org.apache.impala.analysis.UnionStmt; +import org.apache.impala.analysis.UnionStmt.UnionOperand; +import org.apache.impala.catalog.ColumnStats; +import org.apache.impala.catalog.DataSourceTable; +import org.apache.impala.catalog.HBaseTable; +import org.apache.impala.catalog.HdfsPartition; +import org.apache.impala.catalog.HdfsTable; +import org.apache.impala.catalog.KuduTable; +import org.apache.impala.catalog.Table; +import org.apache.impala.catalog.Type; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.InternalException; +import org.apache.impala.common.NotImplementedException; +import org.apache.impala.common.Pair; import com.google.common.base.Preconditions; import com.google.common.base.Predicate; import com.google.common.collect.Iterables; @@ -1126,7 +1126,7 @@ public class SingleNodePlanner { Predicate<Expr> isIdentityPredicate = new Predicate<Expr>() { @Override public boolean apply(Expr expr) { - return com.cloudera.impala.analysis.Predicate.isEquivalencePredicate(expr) + return org.apache.impala.analysis.Predicate.isEquivalencePredicate(expr) && ((BinaryPredicate) expr).isInferred() && expr.getChild(0).equals(expr.getChild(1)); } http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/SingularRowSrcNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/SingularRowSrcNode.java b/fe/src/main/java/org/apache/impala/planner/SingularRowSrcNode.java index 88b3d7d..5b66d18 100644 --- a/fe/src/main/java/org/apache/impala/planner/SingularRowSrcNode.java +++ b/fe/src/main/java/org/apache/impala/planner/SingularRowSrcNode.java @@ -15,13 +15,13 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TPlanNode; -import com.cloudera.impala.thrift.TPlanNodeType; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TPlanNode; +import org.apache.impala.thrift.TPlanNodeType; import com.google.common.base.Preconditions; /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/SortNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/SortNode.java b/fe/src/main/java/org/apache/impala/planner/SortNode.java index 02f0df6..3a71f8c 100644 --- a/fe/src/main/java/org/apache/impala/planner/SortNode.java +++ b/fe/src/main/java/org/apache/impala/planner/SortNode.java @@ -15,27 +15,27 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; import java.util.List; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.ExprSubstitutionMap; -import com.cloudera.impala.analysis.SlotDescriptor; -import com.cloudera.impala.analysis.SlotRef; -import com.cloudera.impala.analysis.SortInfo; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.service.BackendConfig; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TPlanNode; -import com.cloudera.impala.thrift.TPlanNodeType; -import com.cloudera.impala.thrift.TQueryOptions; -import com.cloudera.impala.thrift.TSortInfo; -import com.cloudera.impala.thrift.TSortNode; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.ExprSubstitutionMap; +import org.apache.impala.analysis.SlotDescriptor; +import org.apache.impala.analysis.SlotRef; +import org.apache.impala.analysis.SortInfo; +import org.apache.impala.common.InternalException; +import org.apache.impala.service.BackendConfig; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TPlanNode; +import org.apache.impala.thrift.TPlanNodeType; +import org.apache.impala.thrift.TQueryOptions; +import org.apache.impala.thrift.TSortInfo; +import org.apache.impala.thrift.TSortNode; import com.google.common.base.Joiner; import com.google.common.base.Objects; import com.google.common.base.Preconditions; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/SubplanNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/SubplanNode.java b/fe/src/main/java/org/apache/impala/planner/SubplanNode.java index 4512268..6143255 100644 --- a/fe/src/main/java/org/apache/impala/planner/SubplanNode.java +++ b/fe/src/main/java/org/apache/impala/planner/SubplanNode.java @@ -15,13 +15,13 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TPlanNode; -import com.cloudera.impala.thrift.TPlanNodeType; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.common.InternalException; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TPlanNode; +import org.apache.impala.thrift.TPlanNodeType; import com.google.common.base.Preconditions; /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/TableSink.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/TableSink.java b/fe/src/main/java/org/apache/impala/planner/TableSink.java index ae73b54..788bb50 100644 --- a/fe/src/main/java/org/apache/impala/planner/TableSink.java +++ b/fe/src/main/java/org/apache/impala/planner/TableSink.java @@ -15,14 +15,14 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.catalog.HBaseTable; -import com.cloudera.impala.catalog.HdfsTable; -import com.cloudera.impala.catalog.KuduTable; -import com.cloudera.impala.catalog.Table; -import com.cloudera.impala.thrift.TSinkAction; +import org.apache.impala.analysis.Expr; +import org.apache.impala.catalog.HBaseTable; +import org.apache.impala.catalog.HdfsTable; +import org.apache.impala.catalog.KuduTable; +import org.apache.impala.catalog.Table; +import org.apache.impala.thrift.TSinkAction; import com.google.common.base.Preconditions; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/UnionNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/UnionNode.java b/fe/src/main/java/org/apache/impala/planner/UnionNode.java index ef67277..a451ba0 100644 --- a/fe/src/main/java/org/apache/impala/planner/UnionNode.java +++ b/fe/src/main/java/org/apache/impala/planner/UnionNode.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; import java.util.ArrayList; import java.util.Collections; @@ -25,16 +25,16 @@ import java.util.List; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.SlotDescriptor; -import com.cloudera.impala.analysis.TupleId; -import com.cloudera.impala.common.Pair; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TExpr; -import com.cloudera.impala.thrift.TPlanNode; -import com.cloudera.impala.thrift.TPlanNodeType; -import com.cloudera.impala.thrift.TUnionNode; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.SlotDescriptor; +import org.apache.impala.analysis.TupleId; +import org.apache.impala.common.Pair; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TExpr; +import org.apache.impala.thrift.TPlanNode; +import org.apache.impala.thrift.TPlanNodeType; +import org.apache.impala.thrift.TUnionNode; import com.google.common.base.Preconditions; import com.google.common.collect.Lists; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/UnnestNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/UnnestNode.java b/fe/src/main/java/org/apache/impala/planner/UnnestNode.java index 3a45882..35abc55 100644 --- a/fe/src/main/java/org/apache/impala/planner/UnnestNode.java +++ b/fe/src/main/java/org/apache/impala/planner/UnnestNode.java @@ -15,16 +15,16 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.CollectionTableRef; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TPlanNode; -import com.cloudera.impala.thrift.TPlanNodeType; -import com.cloudera.impala.thrift.TUnnestNode; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.CollectionTableRef; +import org.apache.impala.analysis.Expr; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TPlanNode; +import org.apache.impala.thrift.TPlanNodeType; +import org.apache.impala.thrift.TUnnestNode; import com.google.common.base.Joiner; import com.google.common.base.Preconditions; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/ValueRange.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/ValueRange.java b/fe/src/main/java/org/apache/impala/planner/ValueRange.java index e76da9d..492dd3d 100644 --- a/fe/src/main/java/org/apache/impala/planner/ValueRange.java +++ b/fe/src/main/java/org/apache/impala/planner/ValueRange.java @@ -15,19 +15,19 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.BinaryPredicate; -import com.cloudera.impala.analysis.CompoundPredicate; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.Predicate; -import com.cloudera.impala.common.AnalysisException; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.service.FeSupport; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.BinaryPredicate; +import org.apache.impala.analysis.CompoundPredicate; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.Predicate; +import org.apache.impala.common.AnalysisException; +import org.apache.impala.common.InternalException; +import org.apache.impala.service.FeSupport; import com.google.common.base.Preconditions; /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/service/BackendConfig.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/service/BackendConfig.java b/fe/src/main/java/org/apache/impala/service/BackendConfig.java index e98ab571..75dd1f7 100644 --- a/fe/src/main/java/org/apache/impala/service/BackendConfig.java +++ b/fe/src/main/java/org/apache/impala/service/BackendConfig.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.service; +package org.apache.impala.service; /** * This class is meant to provide the FE with impalad backend configuration parameters, http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/service/CatalogOpExecutor.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/service/CatalogOpExecutor.java b/fe/src/main/java/org/apache/impala/service/CatalogOpExecutor.java index 4814503..780bf13 100644 --- a/fe/src/main/java/org/apache/impala/service/CatalogOpExecutor.java +++ b/fe/src/main/java/org/apache/impala/service/CatalogOpExecutor.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.service; +package org.apache.impala.service; import java.util.ArrayList; import java.util.HashMap; @@ -52,103 +52,103 @@ import org.apache.hadoop.hive.metastore.api.StringColumnStatsData; import org.apache.log4j.Logger; import org.apache.thrift.TException; -import com.cloudera.impala.analysis.FunctionName; -import com.cloudera.impala.analysis.TableName; -import com.cloudera.impala.authorization.User; -import com.cloudera.impala.catalog.Catalog; -import com.cloudera.impala.catalog.CatalogException; -import com.cloudera.impala.catalog.CatalogServiceCatalog; -import com.cloudera.impala.catalog.Column; -import com.cloudera.impala.catalog.ColumnNotFoundException; -import com.cloudera.impala.catalog.DataSource; -import com.cloudera.impala.catalog.DatabaseNotFoundException; -import com.cloudera.impala.catalog.Db; -import com.cloudera.impala.catalog.Function; -import com.cloudera.impala.catalog.HBaseTable; -import com.cloudera.impala.catalog.HdfsFileFormat; -import com.cloudera.impala.catalog.HdfsPartition; -import com.cloudera.impala.catalog.HdfsTable; -import com.cloudera.impala.catalog.HiveStorageDescriptorFactory; -import com.cloudera.impala.catalog.IncompleteTable; -import com.cloudera.impala.catalog.MetaStoreClientPool.MetaStoreClient; -import com.cloudera.impala.catalog.PartitionNotFoundException; -import com.cloudera.impala.catalog.PartitionStatsUtil; -import com.cloudera.impala.catalog.Role; -import com.cloudera.impala.catalog.RolePrivilege; -import com.cloudera.impala.catalog.RowFormat; -import com.cloudera.impala.catalog.ScalarFunction; -import com.cloudera.impala.catalog.Table; -import com.cloudera.impala.catalog.TableLoadingException; -import com.cloudera.impala.catalog.TableNotFoundException; -import com.cloudera.impala.catalog.Type; -import com.cloudera.impala.catalog.View; -import com.cloudera.impala.catalog.delegates.DdlDelegate; -import com.cloudera.impala.catalog.delegates.KuduDdlDelegate; -import com.cloudera.impala.catalog.delegates.UnsupportedOpDelegate; -import com.cloudera.impala.common.FileSystemUtil; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.ImpalaRuntimeException; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.common.Pair; -import com.cloudera.impala.thrift.ImpalaInternalServiceConstants; -import com.cloudera.impala.thrift.JniCatalogConstants; -import com.cloudera.impala.thrift.TAlterTableAddPartitionParams; -import com.cloudera.impala.thrift.TAlterTableAddReplaceColsParams; -import com.cloudera.impala.thrift.TAlterTableChangeColParams; -import com.cloudera.impala.thrift.TAlterTableDropColParams; -import com.cloudera.impala.thrift.TAlterTableDropPartitionParams; -import com.cloudera.impala.thrift.TAlterTableParams; -import com.cloudera.impala.thrift.TAlterTableSetCachedParams; -import com.cloudera.impala.thrift.TAlterTableSetFileFormatParams; -import com.cloudera.impala.thrift.TAlterTableSetLocationParams; -import com.cloudera.impala.thrift.TAlterTableSetTblPropertiesParams; -import com.cloudera.impala.thrift.TAlterTableType; -import com.cloudera.impala.thrift.TAlterTableUpdateStatsParams; -import com.cloudera.impala.thrift.TCatalogObject; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.TCatalogUpdateResult; -import com.cloudera.impala.thrift.TColumn; -import com.cloudera.impala.thrift.TColumnStats; -import com.cloudera.impala.thrift.TColumnType; -import com.cloudera.impala.thrift.TColumnValue; -import com.cloudera.impala.thrift.TCreateDataSourceParams; -import com.cloudera.impala.thrift.TCreateDbParams; -import com.cloudera.impala.thrift.TCreateDropRoleParams; -import com.cloudera.impala.thrift.TCreateFunctionParams; -import com.cloudera.impala.thrift.TCreateOrAlterViewParams; -import com.cloudera.impala.thrift.TCreateTableLikeParams; -import com.cloudera.impala.thrift.TCreateTableParams; -import com.cloudera.impala.thrift.TDatabase; -import com.cloudera.impala.thrift.TDdlExecRequest; -import com.cloudera.impala.thrift.TDdlExecResponse; -import com.cloudera.impala.thrift.TDistributeParam; -import com.cloudera.impala.thrift.TDropDataSourceParams; -import com.cloudera.impala.thrift.TDropDbParams; -import com.cloudera.impala.thrift.TDropFunctionParams; -import com.cloudera.impala.thrift.TDropStatsParams; -import com.cloudera.impala.thrift.TDropTableOrViewParams; -import com.cloudera.impala.thrift.TErrorCode; -import com.cloudera.impala.thrift.TFunctionBinaryType; -import com.cloudera.impala.thrift.TGrantRevokePrivParams; -import com.cloudera.impala.thrift.TGrantRevokeRoleParams; -import com.cloudera.impala.thrift.THdfsCachingOp; -import com.cloudera.impala.thrift.THdfsFileFormat; -import com.cloudera.impala.thrift.TPartitionKeyValue; -import com.cloudera.impala.thrift.TPartitionStats; -import com.cloudera.impala.thrift.TPrivilege; -import com.cloudera.impala.thrift.TResetMetadataRequest; -import com.cloudera.impala.thrift.TResetMetadataResponse; -import com.cloudera.impala.thrift.TResultRow; -import com.cloudera.impala.thrift.TResultSet; -import com.cloudera.impala.thrift.TResultSetMetadata; -import com.cloudera.impala.thrift.TStatus; -import com.cloudera.impala.thrift.TTable; -import com.cloudera.impala.thrift.TTableName; -import com.cloudera.impala.thrift.TTableStats; -import com.cloudera.impala.thrift.TTruncateParams; -import com.cloudera.impala.thrift.TUpdateCatalogRequest; -import com.cloudera.impala.thrift.TUpdateCatalogResponse; -import com.cloudera.impala.util.HdfsCachingUtil; +import org.apache.impala.analysis.FunctionName; +import org.apache.impala.analysis.TableName; +import org.apache.impala.authorization.User; +import org.apache.impala.catalog.Catalog; +import org.apache.impala.catalog.CatalogException; +import org.apache.impala.catalog.CatalogServiceCatalog; +import org.apache.impala.catalog.Column; +import org.apache.impala.catalog.ColumnNotFoundException; +import org.apache.impala.catalog.DataSource; +import org.apache.impala.catalog.DatabaseNotFoundException; +import org.apache.impala.catalog.Db; +import org.apache.impala.catalog.Function; +import org.apache.impala.catalog.HBaseTable; +import org.apache.impala.catalog.HdfsFileFormat; +import org.apache.impala.catalog.HdfsPartition; +import org.apache.impala.catalog.HdfsTable; +import org.apache.impala.catalog.HiveStorageDescriptorFactory; +import org.apache.impala.catalog.IncompleteTable; +import org.apache.impala.catalog.MetaStoreClientPool.MetaStoreClient; +import org.apache.impala.catalog.PartitionNotFoundException; +import org.apache.impala.catalog.PartitionStatsUtil; +import org.apache.impala.catalog.Role; +import org.apache.impala.catalog.RolePrivilege; +import org.apache.impala.catalog.RowFormat; +import org.apache.impala.catalog.ScalarFunction; +import org.apache.impala.catalog.Table; +import org.apache.impala.catalog.TableLoadingException; +import org.apache.impala.catalog.TableNotFoundException; +import org.apache.impala.catalog.Type; +import org.apache.impala.catalog.View; +import org.apache.impala.catalog.delegates.DdlDelegate; +import org.apache.impala.catalog.delegates.KuduDdlDelegate; +import org.apache.impala.catalog.delegates.UnsupportedOpDelegate; +import org.apache.impala.common.FileSystemUtil; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.ImpalaRuntimeException; +import org.apache.impala.common.InternalException; +import org.apache.impala.common.Pair; +import org.apache.impala.thrift.ImpalaInternalServiceConstants; +import org.apache.impala.thrift.JniCatalogConstants; +import org.apache.impala.thrift.TAlterTableAddPartitionParams; +import org.apache.impala.thrift.TAlterTableAddReplaceColsParams; +import org.apache.impala.thrift.TAlterTableChangeColParams; +import org.apache.impala.thrift.TAlterTableDropColParams; +import org.apache.impala.thrift.TAlterTableDropPartitionParams; +import org.apache.impala.thrift.TAlterTableParams; +import org.apache.impala.thrift.TAlterTableSetCachedParams; +import org.apache.impala.thrift.TAlterTableSetFileFormatParams; +import org.apache.impala.thrift.TAlterTableSetLocationParams; +import org.apache.impala.thrift.TAlterTableSetTblPropertiesParams; +import org.apache.impala.thrift.TAlterTableType; +import org.apache.impala.thrift.TAlterTableUpdateStatsParams; +import org.apache.impala.thrift.TCatalogObject; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TCatalogUpdateResult; +import org.apache.impala.thrift.TColumn; +import org.apache.impala.thrift.TColumnStats; +import org.apache.impala.thrift.TColumnType; +import org.apache.impala.thrift.TColumnValue; +import org.apache.impala.thrift.TCreateDataSourceParams; +import org.apache.impala.thrift.TCreateDbParams; +import org.apache.impala.thrift.TCreateDropRoleParams; +import org.apache.impala.thrift.TCreateFunctionParams; +import org.apache.impala.thrift.TCreateOrAlterViewParams; +import org.apache.impala.thrift.TCreateTableLikeParams; +import org.apache.impala.thrift.TCreateTableParams; +import org.apache.impala.thrift.TDatabase; +import org.apache.impala.thrift.TDdlExecRequest; +import org.apache.impala.thrift.TDdlExecResponse; +import org.apache.impala.thrift.TDistributeParam; +import org.apache.impala.thrift.TDropDataSourceParams; +import org.apache.impala.thrift.TDropDbParams; +import org.apache.impala.thrift.TDropFunctionParams; +import org.apache.impala.thrift.TDropStatsParams; +import org.apache.impala.thrift.TDropTableOrViewParams; +import org.apache.impala.thrift.TErrorCode; +import org.apache.impala.thrift.TFunctionBinaryType; +import org.apache.impala.thrift.TGrantRevokePrivParams; +import org.apache.impala.thrift.TGrantRevokeRoleParams; +import org.apache.impala.thrift.THdfsCachingOp; +import org.apache.impala.thrift.THdfsFileFormat; +import org.apache.impala.thrift.TPartitionKeyValue; +import org.apache.impala.thrift.TPartitionStats; +import org.apache.impala.thrift.TPrivilege; +import org.apache.impala.thrift.TResetMetadataRequest; +import org.apache.impala.thrift.TResetMetadataResponse; +import org.apache.impala.thrift.TResultRow; +import org.apache.impala.thrift.TResultSet; +import org.apache.impala.thrift.TResultSetMetadata; +import org.apache.impala.thrift.TStatus; +import org.apache.impala.thrift.TTable; +import org.apache.impala.thrift.TTableName; +import org.apache.impala.thrift.TTableStats; +import org.apache.impala.thrift.TTruncateParams; +import org.apache.impala.thrift.TUpdateCatalogRequest; +import org.apache.impala.thrift.TUpdateCatalogResponse; +import org.apache.impala.util.HdfsCachingUtil; import com.google.common.base.Joiner; import com.google.common.base.Preconditions; import com.google.common.collect.Lists; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/service/DescribeResultFactory.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/service/DescribeResultFactory.java b/fe/src/main/java/org/apache/impala/service/DescribeResultFactory.java index c1a9557..eb917a6 100644 --- a/fe/src/main/java/org/apache/impala/service/DescribeResultFactory.java +++ b/fe/src/main/java/org/apache/impala/service/DescribeResultFactory.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.service; +package org.apache.impala.service; import java.util.List; import java.util.Map; @@ -26,15 +26,15 @@ import org.apache.hadoop.hive.metastore.api.PrincipalType; import org.apache.hadoop.hive.metastore.api.PrivilegeGrantInfo; import org.apache.hadoop.hive.ql.metadata.formatting.MetaDataFormatUtils; -import com.cloudera.impala.catalog.Column; -import com.cloudera.impala.catalog.Db; -import com.cloudera.impala.catalog.StructField; -import com.cloudera.impala.catalog.StructType; -import com.cloudera.impala.catalog.Table; -import com.cloudera.impala.thrift.TColumnValue; -import com.cloudera.impala.thrift.TDescribeOutputStyle; -import com.cloudera.impala.thrift.TDescribeResult; -import com.cloudera.impala.thrift.TResultRow; +import org.apache.impala.catalog.Column; +import org.apache.impala.catalog.Db; +import org.apache.impala.catalog.StructField; +import org.apache.impala.catalog.StructType; +import org.apache.impala.catalog.Table; +import org.apache.impala.thrift.TColumnValue; +import org.apache.impala.thrift.TDescribeOutputStyle; +import org.apache.impala.thrift.TDescribeResult; +import org.apache.impala.thrift.TResultRow; import com.google.common.collect.Lists; /* http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/service/FeSupport.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/service/FeSupport.java b/fe/src/main/java/org/apache/impala/service/FeSupport.java index 4014129..f982df3 100644 --- a/fe/src/main/java/org/apache/impala/service/FeSupport.java +++ b/fe/src/main/java/org/apache/impala/service/FeSupport.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.service; +package org.apache.impala.service; import java.util.ArrayList; import java.util.List; @@ -28,28 +28,28 @@ import org.apache.thrift.protocol.TBinaryProtocol; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.BoolLiteral; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.NullLiteral; -import com.cloudera.impala.analysis.TableName; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.thrift.TCacheJarParams; -import com.cloudera.impala.thrift.TCacheJarResult; -import com.cloudera.impala.thrift.TCatalogObject; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.TCatalogServiceRequestHeader; -import com.cloudera.impala.thrift.TColumnValue; -import com.cloudera.impala.thrift.TExprBatch; -import com.cloudera.impala.thrift.TPrioritizeLoadRequest; -import com.cloudera.impala.thrift.TPrioritizeLoadResponse; -import com.cloudera.impala.thrift.TQueryCtx; -import com.cloudera.impala.thrift.TResultRow; -import com.cloudera.impala.thrift.TStatus; -import com.cloudera.impala.thrift.TStartupOptions; -import com.cloudera.impala.thrift.TSymbolLookupParams; -import com.cloudera.impala.thrift.TSymbolLookupResult; -import com.cloudera.impala.thrift.TTable; -import com.cloudera.impala.util.NativeLibUtil; +import org.apache.impala.analysis.BoolLiteral; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.NullLiteral; +import org.apache.impala.analysis.TableName; +import org.apache.impala.common.InternalException; +import org.apache.impala.thrift.TCacheJarParams; +import org.apache.impala.thrift.TCacheJarResult; +import org.apache.impala.thrift.TCatalogObject; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TCatalogServiceRequestHeader; +import org.apache.impala.thrift.TColumnValue; +import org.apache.impala.thrift.TExprBatch; +import org.apache.impala.thrift.TPrioritizeLoadRequest; +import org.apache.impala.thrift.TPrioritizeLoadResponse; +import org.apache.impala.thrift.TQueryCtx; +import org.apache.impala.thrift.TResultRow; +import org.apache.impala.thrift.TStatus; +import org.apache.impala.thrift.TStartupOptions; +import org.apache.impala.thrift.TSymbolLookupParams; +import org.apache.impala.thrift.TSymbolLookupResult; +import org.apache.impala.thrift.TTable; +import org.apache.impala.util.NativeLibUtil; import com.google.common.base.Preconditions; /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/service/Frontend.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/service/Frontend.java b/fe/src/main/java/org/apache/impala/service/Frontend.java index 2d38396..fe1f8f1 100644 --- a/fe/src/main/java/org/apache/impala/service/Frontend.java +++ b/fe/src/main/java/org/apache/impala/service/Frontend.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.service; +package org.apache.impala.service; import java.io.IOException; import java.util.ArrayList; @@ -35,7 +35,7 @@ import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicReference; -import com.cloudera.impala.catalog.KuduTable; +import org.apache.impala.catalog.KuduTable; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; import org.apache.hive.service.cli.thrift.TGetColumnsReq; @@ -45,101 +45,101 @@ import org.apache.hive.service.cli.thrift.TGetTablesReq; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.AnalysisContext; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.CreateDataSrcStmt; -import com.cloudera.impala.analysis.CreateDropRoleStmt; -import com.cloudera.impala.analysis.CreateUdaStmt; -import com.cloudera.impala.analysis.CreateUdfStmt; -import com.cloudera.impala.analysis.DropDataSrcStmt; -import com.cloudera.impala.analysis.DropFunctionStmt; -import com.cloudera.impala.analysis.DropStatsStmt; -import com.cloudera.impala.analysis.DropTableOrViewStmt; -import com.cloudera.impala.analysis.GrantRevokePrivStmt; -import com.cloudera.impala.analysis.GrantRevokeRoleStmt; -import com.cloudera.impala.analysis.InsertStmt; -import com.cloudera.impala.analysis.QueryStmt; -import com.cloudera.impala.analysis.ResetMetadataStmt; -import com.cloudera.impala.analysis.ShowFunctionsStmt; -import com.cloudera.impala.analysis.ShowGrantRoleStmt; -import com.cloudera.impala.analysis.ShowRolesStmt; -import com.cloudera.impala.analysis.TableName; -import com.cloudera.impala.analysis.TruncateStmt; -import com.cloudera.impala.analysis.TupleDescriptor; -import com.cloudera.impala.authorization.AuthorizationChecker; -import com.cloudera.impala.authorization.AuthorizationConfig; -import com.cloudera.impala.authorization.ImpalaInternalAdminUser; -import com.cloudera.impala.authorization.PrivilegeRequest; -import com.cloudera.impala.authorization.PrivilegeRequestBuilder; -import com.cloudera.impala.authorization.User; -import com.cloudera.impala.catalog.AuthorizationException; -import com.cloudera.impala.catalog.Catalog; -import com.cloudera.impala.catalog.CatalogException; -import com.cloudera.impala.catalog.Column; -import com.cloudera.impala.catalog.DataSource; -import com.cloudera.impala.catalog.DataSourceTable; -import com.cloudera.impala.catalog.DatabaseNotFoundException; -import com.cloudera.impala.catalog.Db; -import com.cloudera.impala.catalog.Function; -import com.cloudera.impala.catalog.HBaseTable; -import com.cloudera.impala.catalog.HdfsTable; -import com.cloudera.impala.catalog.ImpaladCatalog; -import com.cloudera.impala.catalog.StructType; -import com.cloudera.impala.catalog.Table; -import com.cloudera.impala.catalog.TableId; -import com.cloudera.impala.catalog.Type; -import com.cloudera.impala.common.AnalysisException; -import com.cloudera.impala.common.FileSystemUtil; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.common.NotImplementedException; -import com.cloudera.impala.common.RuntimeEnv; -import com.cloudera.impala.planner.PlanFragment; -import com.cloudera.impala.planner.Planner; -import com.cloudera.impala.planner.ScanNode; -import com.cloudera.impala.thrift.TCatalogOpRequest; -import com.cloudera.impala.thrift.TCatalogOpType; -import com.cloudera.impala.thrift.TCatalogServiceRequestHeader; -import com.cloudera.impala.thrift.TColumn; -import com.cloudera.impala.thrift.TColumnType; -import com.cloudera.impala.thrift.TColumnValue; -import com.cloudera.impala.thrift.TCreateDropRoleParams; -import com.cloudera.impala.thrift.TDdlExecRequest; -import com.cloudera.impala.thrift.TDdlType; -import com.cloudera.impala.thrift.TDescribeOutputStyle; -import com.cloudera.impala.thrift.TDescribeResult; -import com.cloudera.impala.thrift.TErrorCode; -import com.cloudera.impala.thrift.TExecRequest; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TExplainResult; -import com.cloudera.impala.thrift.TFinalizeParams; -import com.cloudera.impala.thrift.TFunctionCategory; -import com.cloudera.impala.thrift.TGrantRevokePrivParams; -import com.cloudera.impala.thrift.TGrantRevokeRoleParams; -import com.cloudera.impala.thrift.TLineageGraph; -import com.cloudera.impala.thrift.TLoadDataReq; -import com.cloudera.impala.thrift.TLoadDataResp; -import com.cloudera.impala.thrift.TMetadataOpRequest; -import com.cloudera.impala.thrift.TPlanFragment; -import com.cloudera.impala.thrift.TPlanFragmentTree; -import com.cloudera.impala.thrift.TQueryCtx; -import com.cloudera.impala.thrift.TQueryExecRequest; -import com.cloudera.impala.thrift.TResetMetadataRequest; -import com.cloudera.impala.thrift.TResultRow; -import com.cloudera.impala.thrift.TResultSet; -import com.cloudera.impala.thrift.TResultSetMetadata; -import com.cloudera.impala.thrift.TShowFilesParams; -import com.cloudera.impala.thrift.TStatus; -import com.cloudera.impala.thrift.TStmtType; -import com.cloudera.impala.thrift.TTableName; -import com.cloudera.impala.thrift.TUpdateCatalogCacheRequest; -import com.cloudera.impala.thrift.TUpdateCatalogCacheResponse; -import com.cloudera.impala.thrift.TUpdateMembershipRequest; -import com.cloudera.impala.util.EventSequence; -import com.cloudera.impala.util.MembershipSnapshot; -import com.cloudera.impala.util.PatternMatcher; -import com.cloudera.impala.util.TResultRowBuilder; -import com.cloudera.impala.util.TSessionStateUtil; +import org.apache.impala.analysis.AnalysisContext; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.CreateDataSrcStmt; +import org.apache.impala.analysis.CreateDropRoleStmt; +import org.apache.impala.analysis.CreateUdaStmt; +import org.apache.impala.analysis.CreateUdfStmt; +import org.apache.impala.analysis.DropDataSrcStmt; +import org.apache.impala.analysis.DropFunctionStmt; +import org.apache.impala.analysis.DropStatsStmt; +import org.apache.impala.analysis.DropTableOrViewStmt; +import org.apache.impala.analysis.GrantRevokePrivStmt; +import org.apache.impala.analysis.GrantRevokeRoleStmt; +import org.apache.impala.analysis.InsertStmt; +import org.apache.impala.analysis.QueryStmt; +import org.apache.impala.analysis.ResetMetadataStmt; +import org.apache.impala.analysis.ShowFunctionsStmt; +import org.apache.impala.analysis.ShowGrantRoleStmt; +import org.apache.impala.analysis.ShowRolesStmt; +import org.apache.impala.analysis.TableName; +import org.apache.impala.analysis.TruncateStmt; +import org.apache.impala.analysis.TupleDescriptor; +import org.apache.impala.authorization.AuthorizationChecker; +import org.apache.impala.authorization.AuthorizationConfig; +import org.apache.impala.authorization.ImpalaInternalAdminUser; +import org.apache.impala.authorization.PrivilegeRequest; +import org.apache.impala.authorization.PrivilegeRequestBuilder; +import org.apache.impala.authorization.User; +import org.apache.impala.catalog.AuthorizationException; +import org.apache.impala.catalog.Catalog; +import org.apache.impala.catalog.CatalogException; +import org.apache.impala.catalog.Column; +import org.apache.impala.catalog.DataSource; +import org.apache.impala.catalog.DataSourceTable; +import org.apache.impala.catalog.DatabaseNotFoundException; +import org.apache.impala.catalog.Db; +import org.apache.impala.catalog.Function; +import org.apache.impala.catalog.HBaseTable; +import org.apache.impala.catalog.HdfsTable; +import org.apache.impala.catalog.ImpaladCatalog; +import org.apache.impala.catalog.StructType; +import org.apache.impala.catalog.Table; +import org.apache.impala.catalog.TableId; +import org.apache.impala.catalog.Type; +import org.apache.impala.common.AnalysisException; +import org.apache.impala.common.FileSystemUtil; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.InternalException; +import org.apache.impala.common.NotImplementedException; +import org.apache.impala.common.RuntimeEnv; +import org.apache.impala.planner.PlanFragment; +import org.apache.impala.planner.Planner; +import org.apache.impala.planner.ScanNode; +import org.apache.impala.thrift.TCatalogOpRequest; +import org.apache.impala.thrift.TCatalogOpType; +import org.apache.impala.thrift.TCatalogServiceRequestHeader; +import org.apache.impala.thrift.TColumn; +import org.apache.impala.thrift.TColumnType; +import org.apache.impala.thrift.TColumnValue; +import org.apache.impala.thrift.TCreateDropRoleParams; +import org.apache.impala.thrift.TDdlExecRequest; +import org.apache.impala.thrift.TDdlType; +import org.apache.impala.thrift.TDescribeOutputStyle; +import org.apache.impala.thrift.TDescribeResult; +import org.apache.impala.thrift.TErrorCode; +import org.apache.impala.thrift.TExecRequest; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TExplainResult; +import org.apache.impala.thrift.TFinalizeParams; +import org.apache.impala.thrift.TFunctionCategory; +import org.apache.impala.thrift.TGrantRevokePrivParams; +import org.apache.impala.thrift.TGrantRevokeRoleParams; +import org.apache.impala.thrift.TLineageGraph; +import org.apache.impala.thrift.TLoadDataReq; +import org.apache.impala.thrift.TLoadDataResp; +import org.apache.impala.thrift.TMetadataOpRequest; +import org.apache.impala.thrift.TPlanFragment; +import org.apache.impala.thrift.TPlanFragmentTree; +import org.apache.impala.thrift.TQueryCtx; +import org.apache.impala.thrift.TQueryExecRequest; +import org.apache.impala.thrift.TResetMetadataRequest; +import org.apache.impala.thrift.TResultRow; +import org.apache.impala.thrift.TResultSet; +import org.apache.impala.thrift.TResultSetMetadata; +import org.apache.impala.thrift.TShowFilesParams; +import org.apache.impala.thrift.TStatus; +import org.apache.impala.thrift.TStmtType; +import org.apache.impala.thrift.TTableName; +import org.apache.impala.thrift.TUpdateCatalogCacheRequest; +import org.apache.impala.thrift.TUpdateCatalogCacheResponse; +import org.apache.impala.thrift.TUpdateMembershipRequest; +import org.apache.impala.util.EventSequence; +import org.apache.impala.util.MembershipSnapshot; +import org.apache.impala.util.PatternMatcher; +import org.apache.impala.util.TResultRowBuilder; +import org.apache.impala.util.TSessionStateUtil; import com.google.common.base.Joiner; import com.google.common.base.Preconditions; import com.google.common.base.Predicates; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/service/JniCatalog.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/service/JniCatalog.java b/fe/src/main/java/org/apache/impala/service/JniCatalog.java index bc71a49..fc8deaf 100644 --- a/fe/src/main/java/org/apache/impala/service/JniCatalog.java +++ b/fe/src/main/java/org/apache/impala/service/JniCatalog.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.service; +package org.apache.impala.service; import java.util.ArrayList; import java.util.List; @@ -27,35 +27,35 @@ import org.apache.thrift.protocol.TBinaryProtocol; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.authorization.SentryConfig; -import com.cloudera.impala.authorization.User; -import com.cloudera.impala.catalog.CatalogException; -import com.cloudera.impala.catalog.CatalogServiceCatalog; -import com.cloudera.impala.catalog.Db; -import com.cloudera.impala.catalog.Function; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.common.JniUtil; -import com.cloudera.impala.service.BackendConfig; -import com.cloudera.impala.thrift.TCatalogObject; -import com.cloudera.impala.thrift.TDatabase; -import com.cloudera.impala.thrift.TDdlExecRequest; -import com.cloudera.impala.thrift.TFunction; -import com.cloudera.impala.thrift.TGetAllCatalogObjectsResponse; -import com.cloudera.impala.thrift.TGetDbsParams; -import com.cloudera.impala.thrift.TGetDbsResult; -import com.cloudera.impala.thrift.TGetFunctionsRequest; -import com.cloudera.impala.thrift.TGetFunctionsResponse; -import com.cloudera.impala.thrift.TGetTablesParams; -import com.cloudera.impala.thrift.TGetTablesResult; -import com.cloudera.impala.thrift.TLogLevel; -import com.cloudera.impala.thrift.TPrioritizeLoadRequest; -import com.cloudera.impala.thrift.TResetMetadataRequest; -import com.cloudera.impala.thrift.TSentryAdminCheckRequest; -import com.cloudera.impala.thrift.TUniqueId; -import com.cloudera.impala.thrift.TUpdateCatalogRequest; -import com.cloudera.impala.util.GlogAppender; -import com.cloudera.impala.util.PatternMatcher; +import org.apache.impala.authorization.SentryConfig; +import org.apache.impala.authorization.User; +import org.apache.impala.catalog.CatalogException; +import org.apache.impala.catalog.CatalogServiceCatalog; +import org.apache.impala.catalog.Db; +import org.apache.impala.catalog.Function; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.InternalException; +import org.apache.impala.common.JniUtil; +import org.apache.impala.service.BackendConfig; +import org.apache.impala.thrift.TCatalogObject; +import org.apache.impala.thrift.TDatabase; +import org.apache.impala.thrift.TDdlExecRequest; +import org.apache.impala.thrift.TFunction; +import org.apache.impala.thrift.TGetAllCatalogObjectsResponse; +import org.apache.impala.thrift.TGetDbsParams; +import org.apache.impala.thrift.TGetDbsResult; +import org.apache.impala.thrift.TGetFunctionsRequest; +import org.apache.impala.thrift.TGetFunctionsResponse; +import org.apache.impala.thrift.TGetTablesParams; +import org.apache.impala.thrift.TGetTablesResult; +import org.apache.impala.thrift.TLogLevel; +import org.apache.impala.thrift.TPrioritizeLoadRequest; +import org.apache.impala.thrift.TResetMetadataRequest; +import org.apache.impala.thrift.TSentryAdminCheckRequest; +import org.apache.impala.thrift.TUniqueId; +import org.apache.impala.thrift.TUpdateCatalogRequest; +import org.apache.impala.util.GlogAppender; +import org.apache.impala.util.PatternMatcher; import com.google.common.base.Preconditions; import com.google.common.base.Strings; import com.google.common.collect.Lists; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/service/JniFrontend.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/service/JniFrontend.java b/fe/src/main/java/org/apache/impala/service/JniFrontend.java index af9c00c..0b4ce8f 100644 --- a/fe/src/main/java/org/apache/impala/service/JniFrontend.java +++ b/fe/src/main/java/org/apache/impala/service/JniFrontend.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.service; +package org.apache.impala.service; import java.io.File; import java.io.IOException; @@ -41,55 +41,55 @@ import org.apache.thrift.protocol.TBinaryProtocol; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.ToSqlUtils; -import com.cloudera.impala.authorization.AuthorizationConfig; -import com.cloudera.impala.authorization.ImpalaInternalAdminUser; -import com.cloudera.impala.authorization.User; -import com.cloudera.impala.catalog.DataSource; -import com.cloudera.impala.catalog.Db; -import com.cloudera.impala.catalog.Function; -import com.cloudera.impala.catalog.Role; -import com.cloudera.impala.common.FileSystemUtil; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.common.JniUtil; -import com.cloudera.impala.service.BackendConfig; -import com.cloudera.impala.thrift.TCatalogObject; -import com.cloudera.impala.thrift.TDatabase; -import com.cloudera.impala.thrift.TDescribeDbParams; -import com.cloudera.impala.thrift.TDescribeResult; -import com.cloudera.impala.thrift.TDescribeTableParams; -import com.cloudera.impala.thrift.TExecRequest; -import com.cloudera.impala.thrift.TFunctionCategory; -import com.cloudera.impala.thrift.TGetAllHadoopConfigsResponse; -import com.cloudera.impala.thrift.TGetDataSrcsParams; -import com.cloudera.impala.thrift.TGetDataSrcsResult; -import com.cloudera.impala.thrift.TGetDbsParams; -import com.cloudera.impala.thrift.TGetDbsResult; -import com.cloudera.impala.thrift.TGetFunctionsParams; -import com.cloudera.impala.thrift.TGetFunctionsResult; -import com.cloudera.impala.thrift.TGetHadoopConfigRequest; -import com.cloudera.impala.thrift.TGetHadoopConfigResponse; -import com.cloudera.impala.thrift.TGetTablesParams; -import com.cloudera.impala.thrift.TGetTablesResult; -import com.cloudera.impala.thrift.TLoadDataReq; -import com.cloudera.impala.thrift.TLoadDataResp; -import com.cloudera.impala.thrift.TLogLevel; -import com.cloudera.impala.thrift.TMetadataOpRequest; -import com.cloudera.impala.thrift.TQueryCtx; -import com.cloudera.impala.thrift.TResultSet; -import com.cloudera.impala.thrift.TShowFilesParams; -import com.cloudera.impala.thrift.TShowGrantRoleParams; -import com.cloudera.impala.thrift.TShowRolesParams; -import com.cloudera.impala.thrift.TShowRolesResult; -import com.cloudera.impala.thrift.TShowStatsParams; -import com.cloudera.impala.thrift.TTableName; -import com.cloudera.impala.thrift.TUniqueId; -import com.cloudera.impala.thrift.TUpdateCatalogCacheRequest; -import com.cloudera.impala.thrift.TUpdateMembershipRequest; -import com.cloudera.impala.util.GlogAppender; -import com.cloudera.impala.util.PatternMatcher; -import com.cloudera.impala.util.TSessionStateUtil; +import org.apache.impala.analysis.ToSqlUtils; +import org.apache.impala.authorization.AuthorizationConfig; +import org.apache.impala.authorization.ImpalaInternalAdminUser; +import org.apache.impala.authorization.User; +import org.apache.impala.catalog.DataSource; +import org.apache.impala.catalog.Db; +import org.apache.impala.catalog.Function; +import org.apache.impala.catalog.Role; +import org.apache.impala.common.FileSystemUtil; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.InternalException; +import org.apache.impala.common.JniUtil; +import org.apache.impala.service.BackendConfig; +import org.apache.impala.thrift.TCatalogObject; +import org.apache.impala.thrift.TDatabase; +import org.apache.impala.thrift.TDescribeDbParams; +import org.apache.impala.thrift.TDescribeResult; +import org.apache.impala.thrift.TDescribeTableParams; +import org.apache.impala.thrift.TExecRequest; +import org.apache.impala.thrift.TFunctionCategory; +import org.apache.impala.thrift.TGetAllHadoopConfigsResponse; +import org.apache.impala.thrift.TGetDataSrcsParams; +import org.apache.impala.thrift.TGetDataSrcsResult; +import org.apache.impala.thrift.TGetDbsParams; +import org.apache.impala.thrift.TGetDbsResult; +import org.apache.impala.thrift.TGetFunctionsParams; +import org.apache.impala.thrift.TGetFunctionsResult; +import org.apache.impala.thrift.TGetHadoopConfigRequest; +import org.apache.impala.thrift.TGetHadoopConfigResponse; +import org.apache.impala.thrift.TGetTablesParams; +import org.apache.impala.thrift.TGetTablesResult; +import org.apache.impala.thrift.TLoadDataReq; +import org.apache.impala.thrift.TLoadDataResp; +import org.apache.impala.thrift.TLogLevel; +import org.apache.impala.thrift.TMetadataOpRequest; +import org.apache.impala.thrift.TQueryCtx; +import org.apache.impala.thrift.TResultSet; +import org.apache.impala.thrift.TShowFilesParams; +import org.apache.impala.thrift.TShowGrantRoleParams; +import org.apache.impala.thrift.TShowRolesParams; +import org.apache.impala.thrift.TShowRolesResult; +import org.apache.impala.thrift.TShowStatsParams; +import org.apache.impala.thrift.TTableName; +import org.apache.impala.thrift.TUniqueId; +import org.apache.impala.thrift.TUpdateCatalogCacheRequest; +import org.apache.impala.thrift.TUpdateMembershipRequest; +import org.apache.impala.util.GlogAppender; +import org.apache.impala.util.PatternMatcher; +import org.apache.impala.util.TSessionStateUtil; import com.google.common.base.Preconditions; import com.google.common.collect.Lists; import com.google.common.collect.Maps; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/service/MetadataOp.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/service/MetadataOp.java b/fe/src/main/java/org/apache/impala/service/MetadataOp.java index ebfd984..c24f153 100644 --- a/fe/src/main/java/org/apache/impala/service/MetadataOp.java +++ b/fe/src/main/java/org/apache/impala/service/MetadataOp.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.service; +package org.apache.impala.service; import java.sql.DatabaseMetaData; import java.util.HashSet; @@ -25,24 +25,24 @@ import java.util.Set; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.TableName; -import com.cloudera.impala.authorization.User; -import com.cloudera.impala.catalog.Column; -import com.cloudera.impala.catalog.Db; -import com.cloudera.impala.catalog.Function; -import com.cloudera.impala.catalog.ImpaladCatalog; -import com.cloudera.impala.catalog.PrimitiveType; -import com.cloudera.impala.catalog.ScalarType; -import com.cloudera.impala.catalog.Table; -import com.cloudera.impala.catalog.TableLoadingException; -import com.cloudera.impala.catalog.Type; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.thrift.TColumn; -import com.cloudera.impala.thrift.TColumnValue; -import com.cloudera.impala.thrift.TResultRow; -import com.cloudera.impala.thrift.TResultSet; -import com.cloudera.impala.thrift.TResultSetMetadata; -import com.cloudera.impala.util.PatternMatcher; +import org.apache.impala.analysis.TableName; +import org.apache.impala.authorization.User; +import org.apache.impala.catalog.Column; +import org.apache.impala.catalog.Db; +import org.apache.impala.catalog.Function; +import org.apache.impala.catalog.ImpaladCatalog; +import org.apache.impala.catalog.PrimitiveType; +import org.apache.impala.catalog.ScalarType; +import org.apache.impala.catalog.Table; +import org.apache.impala.catalog.TableLoadingException; +import org.apache.impala.catalog.Type; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.thrift.TColumn; +import org.apache.impala.thrift.TColumnValue; +import org.apache.impala.thrift.TResultRow; +import org.apache.impala.thrift.TResultSet; +import org.apache.impala.thrift.TResultSetMetadata; +import org.apache.impala.util.PatternMatcher; import com.google.common.collect.Lists; /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/util/AvroSchemaConverter.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/util/AvroSchemaConverter.java b/fe/src/main/java/org/apache/impala/util/AvroSchemaConverter.java index 0feb1c1..667da34 100644 --- a/fe/src/main/java/org/apache/impala/util/AvroSchemaConverter.java +++ b/fe/src/main/java/org/apache/impala/util/AvroSchemaConverter.java @@ -14,7 +14,7 @@ // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.util; +package org.apache.impala.util; import java.util.Arrays; import java.util.List; @@ -25,15 +25,15 @@ import org.codehaus.jackson.JsonNode; import org.codehaus.jackson.node.IntNode; import org.codehaus.jackson.node.JsonNodeFactory; -import com.cloudera.impala.analysis.ColumnDef; -import com.cloudera.impala.catalog.ArrayType; -import com.cloudera.impala.catalog.Column; -import com.cloudera.impala.catalog.MapType; -import com.cloudera.impala.catalog.ScalarType; -import com.cloudera.impala.catalog.StructField; -import com.cloudera.impala.catalog.StructType; -import com.cloudera.impala.catalog.Table; -import com.cloudera.impala.catalog.Type; +import org.apache.impala.analysis.ColumnDef; +import org.apache.impala.catalog.ArrayType; +import org.apache.impala.catalog.Column; +import org.apache.impala.catalog.MapType; +import org.apache.impala.catalog.ScalarType; +import org.apache.impala.catalog.StructField; +import org.apache.impala.catalog.StructType; +import org.apache.impala.catalog.Table; +import org.apache.impala.catalog.Type; import com.google.common.collect.Lists; /** @@ -206,4 +206,4 @@ public class AvroSchemaConverter { structSchema.setFields(schemaFields); return structSchema; } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/util/AvroSchemaParser.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/util/AvroSchemaParser.java b/fe/src/main/java/org/apache/impala/util/AvroSchemaParser.java index 60b0c7a..36a586b 100644 --- a/fe/src/main/java/org/apache/impala/util/AvroSchemaParser.java +++ b/fe/src/main/java/org/apache/impala/util/AvroSchemaParser.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.util; +package org.apache.impala.util; import static org.apache.avro.Schema.Type.BOOLEAN; import static org.apache.avro.Schema.Type.DOUBLE; @@ -33,15 +33,15 @@ import org.apache.avro.Schema; import org.apache.avro.SchemaParseException; import org.codehaus.jackson.JsonNode; -import com.cloudera.impala.analysis.ColumnDef; -import com.cloudera.impala.analysis.TypeDef; -import com.cloudera.impala.catalog.ArrayType; -import com.cloudera.impala.catalog.MapType; -import com.cloudera.impala.catalog.ScalarType; -import com.cloudera.impala.catalog.StructField; -import com.cloudera.impala.catalog.StructType; -import com.cloudera.impala.catalog.Type; -import com.cloudera.impala.common.AnalysisException; +import org.apache.impala.analysis.ColumnDef; +import org.apache.impala.analysis.TypeDef; +import org.apache.impala.catalog.ArrayType; +import org.apache.impala.catalog.MapType; +import org.apache.impala.catalog.ScalarType; +import org.apache.impala.catalog.StructField; +import org.apache.impala.catalog.StructType; +import org.apache.impala.catalog.Type; +import org.apache.impala.common.AnalysisException; import com.google.common.base.Preconditions; import com.google.common.collect.Lists; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/util/AvroSchemaUtils.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/util/AvroSchemaUtils.java b/fe/src/main/java/org/apache/impala/util/AvroSchemaUtils.java index f86c347..f5b3bb4 100644 --- a/fe/src/main/java/org/apache/impala/util/AvroSchemaUtils.java +++ b/fe/src/main/java/org/apache/impala/util/AvroSchemaUtils.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.util; +package org.apache.impala.util; import java.io.IOException; import java.io.InputStream; @@ -28,10 +28,10 @@ import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hive.serde2.avro.AvroSerdeUtils; -import com.cloudera.impala.analysis.ColumnDef; -import com.cloudera.impala.catalog.PrimitiveType; -import com.cloudera.impala.common.AnalysisException; -import com.cloudera.impala.common.FileSystemUtil; +import org.apache.impala.analysis.ColumnDef; +import org.apache.impala.catalog.PrimitiveType; +import org.apache.impala.common.AnalysisException; +import org.apache.impala.common.FileSystemUtil; import com.google.common.base.Preconditions; import com.google.common.base.Strings; import com.google.common.collect.Lists; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/util/DisjointSet.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/util/DisjointSet.java b/fe/src/main/java/org/apache/impala/util/DisjointSet.java index bce214e..d5543b1 100644 --- a/fe/src/main/java/org/apache/impala/util/DisjointSet.java +++ b/fe/src/main/java/org/apache/impala/util/DisjointSet.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.util; +package org.apache.impala.util; import java.util.Collection; import java.util.Iterator; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/util/EventSequence.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/util/EventSequence.java b/fe/src/main/java/org/apache/impala/util/EventSequence.java index 6b12c2e..8ce286a 100644 --- a/fe/src/main/java/org/apache/impala/util/EventSequence.java +++ b/fe/src/main/java/org/apache/impala/util/EventSequence.java @@ -15,11 +15,11 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.util; +package org.apache.impala.util; import java.util.List; -import com.cloudera.impala.thrift.TEventSequence; +import org.apache.impala.thrift.TEventSequence; import com.google.common.collect.Lists; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/util/FileWatchService.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/util/FileWatchService.java b/fe/src/main/java/org/apache/impala/util/FileWatchService.java index 88a456d..b3d9483 100644 --- a/fe/src/main/java/org/apache/impala/util/FileWatchService.java +++ b/fe/src/main/java/org/apache/impala/util/FileWatchService.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.util; +package org.apache.impala.util; import java.io.File; import java.util.concurrent.Executors; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/util/FsPermissionChecker.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/util/FsPermissionChecker.java b/fe/src/main/java/org/apache/impala/util/FsPermissionChecker.java index 7523cc8..8c7b1cc 100644 --- a/fe/src/main/java/org/apache/impala/util/FsPermissionChecker.java +++ b/fe/src/main/java/org/apache/impala/util/FsPermissionChecker.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.util; +package org.apache.impala.util; import java.io.IOException; import java.util.Arrays; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/util/GlogAppender.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/util/GlogAppender.java b/fe/src/main/java/org/apache/impala/util/GlogAppender.java index a5e1eb1..edefd0f 100644 --- a/fe/src/main/java/org/apache/impala/util/GlogAppender.java +++ b/fe/src/main/java/org/apache/impala/util/GlogAppender.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.util; +package org.apache.impala.util; import java.util.Properties; @@ -25,8 +25,8 @@ import org.apache.log4j.Logger; import org.apache.log4j.PropertyConfigurator; import org.apache.log4j.spi.LoggingEvent; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.thrift.TLogLevel; +import org.apache.impala.common.InternalException; +import org.apache.impala.thrift.TLogLevel; import com.google.common.base.Joiner; import com.google.common.base.Preconditions; @@ -96,7 +96,7 @@ public class GlogAppender extends AppenderSkeleton { * Manually override Log4j root logger configuration. Any values in log4j.properties * not overridden (that is, anything but the root logger and its default level) will * continue to have effect. - * - impalaLogLevel - the maximum log level for com.cloudera.impala.* classes + * - impalaLogLevel - the maximum log level for org.apache.impala.* classes * - otherLogLevel - the maximum log level for all other classes */ public static void Install(TLogLevel impalaLogLevel, TLogLevel otherLogLevel) @@ -116,11 +116,11 @@ public class GlogAppender extends AppenderSkeleton { // // Finally we can configure per-package logging which overrides the rootLogger // setting. In order to control Impala's logging independently of the rest of the - // world, we set the log level for com.cloudera.impala. + // world, we set the log level for org.apache.impala. properties.setProperty("log4j.rootLogger", log4jLevelForTLogLevel(otherLogLevel) + ",glog"); properties.setProperty("log4j.appender.glog.Threshold", "TRACE"); - properties.setProperty("log4j.logger.com.cloudera.impala", + properties.setProperty("log4j.logger.org.apache.impala", log4jLevelForTLogLevel(impalaLogLevel)); PropertyConfigurator.configure(properties); Logger.getLogger(GlogAppender.class).info(String.format("Logging initialized. " +
