http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/analysis/UnionStmt.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/analysis/UnionStmt.java b/fe/src/main/java/org/apache/impala/analysis/UnionStmt.java index 10758c7..4f65e0f 100644 --- a/fe/src/main/java/org/apache/impala/analysis/UnionStmt.java +++ b/fe/src/main/java/org/apache/impala/analysis/UnionStmt.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.analysis; +package org.apache.impala.analysis; import java.util.ArrayList; import java.util.List; @@ -23,8 +23,8 @@ import java.util.List; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.catalog.ColumnStats; -import com.cloudera.impala.common.AnalysisException; +import org.apache.impala.catalog.ColumnStats; +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/analysis/UpdateStmt.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/analysis/UpdateStmt.java b/fe/src/main/java/org/apache/impala/analysis/UpdateStmt.java index 34e907b..8b0d96d 100644 --- a/fe/src/main/java/org/apache/impala/analysis/UpdateStmt.java +++ b/fe/src/main/java/org/apache/impala/analysis/UpdateStmt.java @@ -15,14 +15,14 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.analysis; +package org.apache.impala.analysis; import java.util.List; -import com.cloudera.impala.common.Pair; -import com.cloudera.impala.planner.DataSink; -import com.cloudera.impala.planner.KuduTableSink; -import com.cloudera.impala.planner.TableSink; +import org.apache.impala.common.Pair; +import org.apache.impala.planner.DataSink; +import org.apache.impala.planner.KuduTableSink; +import org.apache.impala.planner.TableSink; import com.google.common.base.Preconditions; import com.google.common.collect.ImmutableList; 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/analysis/UseStmt.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/analysis/UseStmt.java b/fe/src/main/java/org/apache/impala/analysis/UseStmt.java index c62c454..040f013 100644 --- a/fe/src/main/java/org/apache/impala/analysis/UseStmt.java +++ b/fe/src/main/java/org/apache/impala/analysis/UseStmt.java @@ -15,12 +15,12 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.analysis; +package org.apache.impala.analysis; -import com.cloudera.impala.authorization.Privilege; -import com.cloudera.impala.catalog.Catalog; -import com.cloudera.impala.common.AnalysisException; -import com.cloudera.impala.thrift.TUseDbParams; +import org.apache.impala.authorization.Privilege; +import org.apache.impala.catalog.Catalog; +import org.apache.impala.common.AnalysisException; +import org.apache.impala.thrift.TUseDbParams; /** * Representation of a USE db statement. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/analysis/ValuesStmt.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/analysis/ValuesStmt.java b/fe/src/main/java/org/apache/impala/analysis/ValuesStmt.java index ed3339d..42cce7a 100644 --- a/fe/src/main/java/org/apache/impala/analysis/ValuesStmt.java +++ b/fe/src/main/java/org/apache/impala/analysis/ValuesStmt.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.analysis; +package org.apache.impala.analysis; import java.util.ArrayList; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/analysis/WithClause.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/analysis/WithClause.java b/fe/src/main/java/org/apache/impala/analysis/WithClause.java index 70e1f29..3e70764 100644 --- a/fe/src/main/java/org/apache/impala/analysis/WithClause.java +++ b/fe/src/main/java/org/apache/impala/analysis/WithClause.java @@ -15,14 +15,14 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.analysis; +package org.apache.impala.analysis; import java.util.ArrayList; import java.util.List; -import com.cloudera.impala.authorization.PrivilegeRequest; -import com.cloudera.impala.catalog.View; -import com.cloudera.impala.common.AnalysisException; +import org.apache.impala.authorization.PrivilegeRequest; +import org.apache.impala.catalog.View; +import org.apache.impala.common.AnalysisException; 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/authorization/AuthorizationChecker.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/authorization/AuthorizationChecker.java b/fe/src/main/java/org/apache/impala/authorization/AuthorizationChecker.java index 32f60df..b9a6440 100644 --- a/fe/src/main/java/org/apache/impala/authorization/AuthorizationChecker.java +++ b/fe/src/main/java/org/apache/impala/authorization/AuthorizationChecker.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.authorization; +package org.apache.impala.authorization; import java.util.EnumSet; import java.util.List; @@ -33,9 +33,9 @@ import org.apache.sentry.provider.common.ProviderBackendContext; import org.apache.sentry.provider.common.ResourceAuthorizationProvider; import org.apache.sentry.provider.file.SimpleFileProviderBackend; -import com.cloudera.impala.catalog.AuthorizationException; -import com.cloudera.impala.catalog.AuthorizationPolicy; -import com.cloudera.impala.common.InternalException; +import org.apache.impala.catalog.AuthorizationException; +import org.apache.impala.catalog.AuthorizationPolicy; +import org.apache.impala.common.InternalException; 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/authorization/AuthorizationConfig.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/authorization/AuthorizationConfig.java b/fe/src/main/java/org/apache/impala/authorization/AuthorizationConfig.java index 34dbada..80611d1 100644 --- a/fe/src/main/java/org/apache/impala/authorization/AuthorizationConfig.java +++ b/fe/src/main/java/org/apache/impala/authorization/AuthorizationConfig.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.authorization; +package org.apache.impala.authorization; import org.apache.sentry.provider.common.HadoopGroupResourceAuthorizationProvider; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/authorization/Authorizeable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/authorization/Authorizeable.java b/fe/src/main/java/org/apache/impala/authorization/Authorizeable.java index 5782ed5..7e30332 100644 --- a/fe/src/main/java/org/apache/impala/authorization/Authorizeable.java +++ b/fe/src/main/java/org/apache/impala/authorization/Authorizeable.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.authorization; +package org.apache.impala.authorization; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/authorization/AuthorizeableColumn.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/authorization/AuthorizeableColumn.java b/fe/src/main/java/org/apache/impala/authorization/AuthorizeableColumn.java index d5c9cd0..0af3dfd 100644 --- a/fe/src/main/java/org/apache/impala/authorization/AuthorizeableColumn.java +++ b/fe/src/main/java/org/apache/impala/authorization/AuthorizeableColumn.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.authorization; +package org.apache.impala.authorization; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/authorization/AuthorizeableDb.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/authorization/AuthorizeableDb.java b/fe/src/main/java/org/apache/impala/authorization/AuthorizeableDb.java index e27ac52..b358528 100644 --- a/fe/src/main/java/org/apache/impala/authorization/AuthorizeableDb.java +++ b/fe/src/main/java/org/apache/impala/authorization/AuthorizeableDb.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.authorization; +package org.apache.impala.authorization; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/authorization/AuthorizeableFn.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/authorization/AuthorizeableFn.java b/fe/src/main/java/org/apache/impala/authorization/AuthorizeableFn.java index 0ff4ca3..e74b435 100644 --- a/fe/src/main/java/org/apache/impala/authorization/AuthorizeableFn.java +++ b/fe/src/main/java/org/apache/impala/authorization/AuthorizeableFn.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.authorization; +package org.apache.impala.authorization; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/authorization/AuthorizeableServer.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/authorization/AuthorizeableServer.java b/fe/src/main/java/org/apache/impala/authorization/AuthorizeableServer.java index 4ca3218..3046726 100644 --- a/fe/src/main/java/org/apache/impala/authorization/AuthorizeableServer.java +++ b/fe/src/main/java/org/apache/impala/authorization/AuthorizeableServer.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.authorization; +package org.apache.impala.authorization; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/authorization/AuthorizeableTable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/authorization/AuthorizeableTable.java b/fe/src/main/java/org/apache/impala/authorization/AuthorizeableTable.java index e28d5a1..9526272 100644 --- a/fe/src/main/java/org/apache/impala/authorization/AuthorizeableTable.java +++ b/fe/src/main/java/org/apache/impala/authorization/AuthorizeableTable.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.authorization; +package org.apache.impala.authorization; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/authorization/AuthorizeableUri.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/authorization/AuthorizeableUri.java b/fe/src/main/java/org/apache/impala/authorization/AuthorizeableUri.java index 1997457..ebef8f9 100644 --- a/fe/src/main/java/org/apache/impala/authorization/AuthorizeableUri.java +++ b/fe/src/main/java/org/apache/impala/authorization/AuthorizeableUri.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.authorization; +package org.apache.impala.authorization; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/authorization/ImpalaInternalAdminUser.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/authorization/ImpalaInternalAdminUser.java b/fe/src/main/java/org/apache/impala/authorization/ImpalaInternalAdminUser.java index a5c14c1..b68e8ea 100644 --- a/fe/src/main/java/org/apache/impala/authorization/ImpalaInternalAdminUser.java +++ b/fe/src/main/java/org/apache/impala/authorization/ImpalaInternalAdminUser.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.authorization; +package org.apache.impala.authorization; /* * A singleton class that represents a special user type used for internal Impala http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/authorization/Privilege.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/authorization/Privilege.java b/fe/src/main/java/org/apache/impala/authorization/Privilege.java index 9b44517..c087b73 100644 --- a/fe/src/main/java/org/apache/impala/authorization/Privilege.java +++ b/fe/src/main/java/org/apache/impala/authorization/Privilege.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.authorization; +package org.apache.impala.authorization; import java.util.EnumSet; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/authorization/PrivilegeRequest.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/authorization/PrivilegeRequest.java b/fe/src/main/java/org/apache/impala/authorization/PrivilegeRequest.java index bacc4b2..7dbc23a 100644 --- a/fe/src/main/java/org/apache/impala/authorization/PrivilegeRequest.java +++ b/fe/src/main/java/org/apache/impala/authorization/PrivilegeRequest.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.authorization; +package org.apache.impala.authorization; 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/authorization/PrivilegeRequestBuilder.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/authorization/PrivilegeRequestBuilder.java b/fe/src/main/java/org/apache/impala/authorization/PrivilegeRequestBuilder.java index 13dc909..8cf146c 100644 --- a/fe/src/main/java/org/apache/impala/authorization/PrivilegeRequestBuilder.java +++ b/fe/src/main/java/org/apache/impala/authorization/PrivilegeRequestBuilder.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.authorization; +package org.apache.impala.authorization; 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/authorization/SentryConfig.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/authorization/SentryConfig.java b/fe/src/main/java/org/apache/impala/authorization/SentryConfig.java index 48300f4..8ce74d1 100644 --- a/fe/src/main/java/org/apache/impala/authorization/SentryConfig.java +++ b/fe/src/main/java/org/apache/impala/authorization/SentryConfig.java @@ -15,14 +15,14 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.authorization; +package org.apache.impala.authorization; import java.io.File; import java.net.MalformedURLException; import org.apache.hadoop.conf.Configuration; -import com.cloudera.impala.common.FileSystemUtil; +import org.apache.impala.common.FileSystemUtil; import com.google.common.base.Strings; /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/authorization/User.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/authorization/User.java b/fe/src/main/java/org/apache/impala/authorization/User.java index a282e54..190419b 100644 --- a/fe/src/main/java/org/apache/impala/authorization/User.java +++ b/fe/src/main/java/org/apache/impala/authorization/User.java @@ -15,13 +15,13 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.authorization; +package org.apache.impala.authorization; import com.google.common.base.Preconditions; import com.google.common.annotations.VisibleForTesting; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.common.RuntimeEnv; -import com.cloudera.impala.service.BackendConfig; +import org.apache.impala.common.InternalException; +import org.apache.impala.common.RuntimeEnv; +import org.apache.impala.service.BackendConfig; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/AggregateFunction.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/AggregateFunction.java b/fe/src/main/java/org/apache/impala/catalog/AggregateFunction.java index eb968fd..ba8f972 100644 --- a/fe/src/main/java/org/apache/impala/catalog/AggregateFunction.java +++ b/fe/src/main/java/org/apache/impala/catalog/AggregateFunction.java @@ -15,16 +15,16 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.ArrayList; import java.util.List; -import com.cloudera.impala.analysis.FunctionName; -import com.cloudera.impala.analysis.HdfsUri; -import com.cloudera.impala.thrift.TAggregateFunction; -import com.cloudera.impala.thrift.TFunction; -import com.cloudera.impala.thrift.TFunctionBinaryType; +import org.apache.impala.analysis.FunctionName; +import org.apache.impala.analysis.HdfsUri; +import org.apache.impala.thrift.TAggregateFunction; +import org.apache.impala.thrift.TFunction; +import org.apache.impala.thrift.TFunctionBinaryType; /** * Internal representation of an aggregate function. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/ArrayType.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/ArrayType.java b/fe/src/main/java/org/apache/impala/catalog/ArrayType.java index 25edde2..e635aa5 100644 --- a/fe/src/main/java/org/apache/impala/catalog/ArrayType.java +++ b/fe/src/main/java/org/apache/impala/catalog/ArrayType.java @@ -15,13 +15,13 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import org.apache.commons.lang3.StringUtils; -import com.cloudera.impala.thrift.TColumnType; -import com.cloudera.impala.thrift.TTypeNode; -import com.cloudera.impala.thrift.TTypeNodeType; +import org.apache.impala.thrift.TColumnType; +import org.apache.impala.thrift.TTypeNode; +import org.apache.impala.thrift.TTypeNodeType; 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/catalog/AuthorizationException.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/AuthorizationException.java b/fe/src/main/java/org/apache/impala/catalog/AuthorizationException.java index ab97c83..909a75b 100644 --- a/fe/src/main/java/org/apache/impala/catalog/AuthorizationException.java +++ b/fe/src/main/java/org/apache/impala/catalog/AuthorizationException.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/AuthorizationPolicy.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/AuthorizationPolicy.java b/fe/src/main/java/org/apache/impala/catalog/AuthorizationPolicy.java index f37f3dc..946ca30 100644 --- a/fe/src/main/java/org/apache/impala/catalog/AuthorizationPolicy.java +++ b/fe/src/main/java/org/apache/impala/catalog/AuthorizationPolicy.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.List; import java.util.Map; @@ -26,12 +26,12 @@ import org.apache.log4j.Logger; import org.apache.sentry.core.common.ActiveRoleSet; import org.apache.sentry.provider.cache.PrivilegeCache; -import com.cloudera.impala.thrift.TColumn; -import com.cloudera.impala.thrift.TPrivilege; -import com.cloudera.impala.thrift.TResultRow; -import com.cloudera.impala.thrift.TResultSet; -import com.cloudera.impala.thrift.TResultSetMetadata; -import com.cloudera.impala.util.TResultRowBuilder; +import org.apache.impala.thrift.TColumn; +import org.apache.impala.thrift.TPrivilege; +import org.apache.impala.thrift.TResultRow; +import org.apache.impala.thrift.TResultSet; +import org.apache.impala.thrift.TResultSetMetadata; +import org.apache.impala.util.TResultRowBuilder; import com.google.common.base.Strings; 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/catalog/BuiltinsDb.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/BuiltinsDb.java b/fe/src/main/java/org/apache/impala/catalog/BuiltinsDb.java index 972756c..fb4accc 100644 --- a/fe/src/main/java/org/apache/impala/catalog/BuiltinsDb.java +++ b/fe/src/main/java/org/apache/impala/catalog/BuiltinsDb.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.ArrayList; import java.util.Collections; @@ -23,15 +23,15 @@ import java.util.Map; import org.apache.hadoop.hive.metastore.api.Database; -import com.cloudera.impala.analysis.ArithmeticExpr; -import com.cloudera.impala.analysis.BinaryPredicate; -import com.cloudera.impala.analysis.CaseExpr; -import com.cloudera.impala.analysis.CastExpr; -import com.cloudera.impala.analysis.CompoundPredicate; -import com.cloudera.impala.analysis.InPredicate; -import com.cloudera.impala.analysis.IsNullPredicate; -import com.cloudera.impala.analysis.LikePredicate; -import com.cloudera.impala.builtins.ScalarBuiltins; +import org.apache.impala.analysis.ArithmeticExpr; +import org.apache.impala.analysis.BinaryPredicate; +import org.apache.impala.analysis.CaseExpr; +import org.apache.impala.analysis.CastExpr; +import org.apache.impala.analysis.CompoundPredicate; +import org.apache.impala.analysis.InPredicate; +import org.apache.impala.analysis.IsNullPredicate; +import org.apache.impala.analysis.LikePredicate; +import org.apache.impala.builtins.ScalarBuiltins; import com.google.common.collect.ImmutableMap; 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/catalog/Catalog.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/Catalog.java b/fe/src/main/java/org/apache/impala/catalog/Catalog.java index 4cd1c42..41573ed 100644 --- a/fe/src/main/java/org/apache/impala/catalog/Catalog.java +++ b/fe/src/main/java/org/apache/impala/catalog/Catalog.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.Collections; import java.util.Comparator; @@ -25,13 +25,13 @@ import java.util.concurrent.atomic.AtomicReference; import org.apache.log4j.Logger; -import com.cloudera.impala.analysis.FunctionName; -import com.cloudera.impala.catalog.MetaStoreClientPool.MetaStoreClient; -import com.cloudera.impala.thrift.TCatalogObject; -import com.cloudera.impala.thrift.TFunction; -import com.cloudera.impala.thrift.TPartitionKeyValue; -import com.cloudera.impala.thrift.TTableName; -import com.cloudera.impala.util.PatternMatcher; +import org.apache.impala.analysis.FunctionName; +import org.apache.impala.catalog.MetaStoreClientPool.MetaStoreClient; +import org.apache.impala.thrift.TCatalogObject; +import org.apache.impala.thrift.TFunction; +import org.apache.impala.thrift.TPartitionKeyValue; +import org.apache.impala.thrift.TTableName; +import org.apache.impala.util.PatternMatcher; 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/catalog/CatalogDeltaLog.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/CatalogDeltaLog.java b/fe/src/main/java/org/apache/impala/catalog/CatalogDeltaLog.java index 72e4990..27839b3 100644 --- a/fe/src/main/java/org/apache/impala/catalog/CatalogDeltaLog.java +++ b/fe/src/main/java/org/apache/impala/catalog/CatalogDeltaLog.java @@ -15,14 +15,14 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.Map; import java.util.SortedMap; import java.util.TreeMap; -import com.cloudera.impala.thrift.TCatalogObject; -import com.cloudera.impala.thrift.TTable; +import org.apache.impala.thrift.TCatalogObject; +import org.apache.impala.thrift.TTable; 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/catalog/CatalogException.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/CatalogException.java b/fe/src/main/java/org/apache/impala/catalog/CatalogException.java index 92fc3a0..d963a97 100644 --- a/fe/src/main/java/org/apache/impala/catalog/CatalogException.java +++ b/fe/src/main/java/org/apache/impala/catalog/CatalogException.java @@ -15,9 +15,9 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; -import com.cloudera.impala.common.ImpalaException; +import org.apache.impala.common.ImpalaException; /** * Base class for exceptions related to accessing objects in the Catalog. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/CatalogObject.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/CatalogObject.java b/fe/src/main/java/org/apache/impala/catalog/CatalogObject.java index e98bcde..a2d8ca9 100644 --- a/fe/src/main/java/org/apache/impala/catalog/CatalogObject.java +++ b/fe/src/main/java/org/apache/impala/catalog/CatalogObject.java @@ -15,9 +15,9 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; -import com.cloudera.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TCatalogObjectType; /** * Interface that all catalog objects implement. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/CatalogObjectCache.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/CatalogObjectCache.java b/fe/src/main/java/org/apache/impala/catalog/CatalogObjectCache.java index bd9e3f0..9132905 100644 --- a/fe/src/main/java/org/apache/impala/catalog/CatalogObjectCache.java +++ b/fe/src/main/java/org/apache/impala/catalog/CatalogObjectCache.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.Iterator; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/CatalogServiceCatalog.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/CatalogServiceCatalog.java b/fe/src/main/java/org/apache/impala/catalog/CatalogServiceCatalog.java index 27d25e1..41c8d62 100644 --- a/fe/src/main/java/org/apache/impala/catalog/CatalogServiceCatalog.java +++ b/fe/src/main/java/org/apache/impala/catalog/CatalogServiceCatalog.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.io.IOException; import java.lang.reflect.Method; @@ -52,28 +52,28 @@ import org.apache.log4j.Logger; import org.apache.thrift.protocol.TCompactProtocol; import org.apache.thrift.TException; -import com.cloudera.impala.analysis.TableName; -import com.cloudera.impala.authorization.SentryConfig; -import com.cloudera.impala.catalog.MetaStoreClientPool.MetaStoreClient; -import com.cloudera.impala.common.FileSystemUtil; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.ImpalaRuntimeException; -import com.cloudera.impala.common.JniUtil; -import com.cloudera.impala.common.Pair; -import com.cloudera.impala.hive.executor.UdfExecutor; -import com.cloudera.impala.thrift.TCatalog; -import com.cloudera.impala.thrift.TCatalogObject; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.TFunction; -import com.cloudera.impala.thrift.TFunctionBinaryType; -import com.cloudera.impala.thrift.TGetAllCatalogObjectsResponse; -import com.cloudera.impala.thrift.TPartitionKeyValue; -import com.cloudera.impala.thrift.TPrivilege; -import com.cloudera.impala.thrift.TTable; -import com.cloudera.impala.thrift.TTableName; -import com.cloudera.impala.thrift.TUniqueId; -import com.cloudera.impala.util.PatternMatcher; -import com.cloudera.impala.util.SentryProxy; +import org.apache.impala.analysis.TableName; +import org.apache.impala.authorization.SentryConfig; +import org.apache.impala.catalog.MetaStoreClientPool.MetaStoreClient; +import org.apache.impala.common.FileSystemUtil; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.ImpalaRuntimeException; +import org.apache.impala.common.JniUtil; +import org.apache.impala.common.Pair; +import org.apache.impala.hive.executor.UdfExecutor; +import org.apache.impala.thrift.TCatalog; +import org.apache.impala.thrift.TCatalogObject; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TFunction; +import org.apache.impala.thrift.TFunctionBinaryType; +import org.apache.impala.thrift.TGetAllCatalogObjectsResponse; +import org.apache.impala.thrift.TPartitionKeyValue; +import org.apache.impala.thrift.TPrivilege; +import org.apache.impala.thrift.TTable; +import org.apache.impala.thrift.TTableName; +import org.apache.impala.thrift.TUniqueId; +import org.apache.impala.util.PatternMatcher; +import org.apache.impala.util.SentryProxy; 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/catalog/Column.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/Column.java b/fe/src/main/java/org/apache/impala/catalog/Column.java index b2d7416..ab064e7 100644 --- a/fe/src/main/java/org/apache/impala/catalog/Column.java +++ b/fe/src/main/java/org/apache/impala/catalog/Column.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.List; @@ -24,8 +24,8 @@ import org.apache.hadoop.hive.metastore.api.FieldSchema; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.thrift.TColumn; -import com.cloudera.impala.thrift.TColumnStats; +import org.apache.impala.thrift.TColumn; +import org.apache.impala.thrift.TColumnStats; import com.google.common.base.Function; 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/catalog/ColumnNotFoundException.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/ColumnNotFoundException.java b/fe/src/main/java/org/apache/impala/catalog/ColumnNotFoundException.java index 4ea47c1..80582b6 100644 --- a/fe/src/main/java/org/apache/impala/catalog/ColumnNotFoundException.java +++ b/fe/src/main/java/org/apache/impala/catalog/ColumnNotFoundException.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/ColumnStats.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/ColumnStats.java b/fe/src/main/java/org/apache/impala/catalog/ColumnStats.java index 8f8e4b3..0b161df 100644 --- a/fe/src/main/java/org/apache/impala/catalog/ColumnStats.java +++ b/fe/src/main/java/org/apache/impala/catalog/ColumnStats.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.Set; @@ -29,9 +29,9 @@ import org.apache.hadoop.hive.metastore.api.StringColumnStatsData; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.SlotRef; -import com.cloudera.impala.thrift.TColumnStats; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.SlotRef; +import org.apache.impala.thrift.TColumnStats; import com.google.common.base.Objects; import com.google.common.base.Preconditions; 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/catalog/DataSource.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/DataSource.java b/fe/src/main/java/org/apache/impala/catalog/DataSource.java index ed0d9ee..e9601d7 100644 --- a/fe/src/main/java/org/apache/impala/catalog/DataSource.java +++ b/fe/src/main/java/org/apache/impala/catalog/DataSource.java @@ -15,12 +15,12 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import org.apache.hadoop.fs.Path; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.TDataSource; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TDataSource; import com.google.common.base.Objects; /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/DataSourceTable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/DataSourceTable.java b/fe/src/main/java/org/apache/impala/catalog/DataSourceTable.java index c42c804..25fe10d 100644 --- a/fe/src/main/java/org/apache/impala/catalog/DataSourceTable.java +++ b/fe/src/main/java/org/apache/impala/catalog/DataSourceTable.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.List; import java.util.Set; @@ -25,17 +25,17 @@ import org.apache.hadoop.hive.metastore.api.FieldSchema; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.extdatasource.v1.ExternalDataSource; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.TColumn; -import com.cloudera.impala.thrift.TDataSource; -import com.cloudera.impala.thrift.TDataSourceTable; -import com.cloudera.impala.thrift.TResultSet; -import com.cloudera.impala.thrift.TResultSetMetadata; -import com.cloudera.impala.thrift.TTable; -import com.cloudera.impala.thrift.TTableDescriptor; -import com.cloudera.impala.thrift.TTableType; -import com.cloudera.impala.util.TResultRowBuilder; +import org.apache.impala.extdatasource.v1.ExternalDataSource; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TColumn; +import org.apache.impala.thrift.TDataSource; +import org.apache.impala.thrift.TDataSourceTable; +import org.apache.impala.thrift.TResultSet; +import org.apache.impala.thrift.TResultSetMetadata; +import org.apache.impala.thrift.TTable; +import org.apache.impala.thrift.TTableDescriptor; +import org.apache.impala.thrift.TTableType; +import org.apache.impala.util.TResultRowBuilder; 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/catalog/DatabaseNotFoundException.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/DatabaseNotFoundException.java b/fe/src/main/java/org/apache/impala/catalog/DatabaseNotFoundException.java index 8affb11..9193441 100644 --- a/fe/src/main/java/org/apache/impala/catalog/DatabaseNotFoundException.java +++ b/fe/src/main/java/org/apache/impala/catalog/DatabaseNotFoundException.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/Db.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/Db.java b/fe/src/main/java/org/apache/impala/catalog/Db.java index a9150fe..d6fb185 100644 --- a/fe/src/main/java/org/apache/impala/catalog/Db.java +++ b/fe/src/main/java/org/apache/impala/catalog/Db.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.Collections; import java.util.Comparator; @@ -30,16 +30,16 @@ import org.apache.thrift.TSerializer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.catalog.Function; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.ImpalaRuntimeException; -import com.cloudera.impala.common.JniUtil; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.TDatabase; -import com.cloudera.impala.thrift.TFunction; -import com.cloudera.impala.thrift.TFunctionBinaryType; -import com.cloudera.impala.thrift.TFunctionCategory; -import com.cloudera.impala.util.PatternMatcher; +import org.apache.impala.catalog.Function; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.ImpalaRuntimeException; +import org.apache.impala.common.JniUtil; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TDatabase; +import org.apache.impala.thrift.TFunction; +import org.apache.impala.thrift.TFunctionBinaryType; +import org.apache.impala.thrift.TFunctionCategory; +import org.apache.impala.util.PatternMatcher; 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/catalog/Function.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/Function.java b/fe/src/main/java/org/apache/impala/catalog/Function.java index 406e958..74df8c9 100644 --- a/fe/src/main/java/org/apache/impala/catalog/Function.java +++ b/fe/src/main/java/org/apache/impala/catalog/Function.java @@ -15,25 +15,25 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.List; -import com.cloudera.impala.analysis.FunctionName; -import com.cloudera.impala.analysis.HdfsUri; -import com.cloudera.impala.common.AnalysisException; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.service.FeSupport; -import com.cloudera.impala.thrift.TAggregateFunction; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.TColumnType; -import com.cloudera.impala.thrift.TFunction; -import com.cloudera.impala.thrift.TFunctionBinaryType; -import com.cloudera.impala.thrift.TFunctionCategory; -import com.cloudera.impala.thrift.TScalarFunction; -import com.cloudera.impala.thrift.TSymbolLookupParams; -import com.cloudera.impala.thrift.TSymbolLookupResult; -import com.cloudera.impala.thrift.TSymbolType; +import org.apache.impala.analysis.FunctionName; +import org.apache.impala.analysis.HdfsUri; +import org.apache.impala.common.AnalysisException; +import org.apache.impala.common.InternalException; +import org.apache.impala.service.FeSupport; +import org.apache.impala.thrift.TAggregateFunction; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TColumnType; +import org.apache.impala.thrift.TFunction; +import org.apache.impala.thrift.TFunctionBinaryType; +import org.apache.impala.thrift.TFunctionCategory; +import org.apache.impala.thrift.TScalarFunction; +import org.apache.impala.thrift.TSymbolLookupParams; +import org.apache.impala.thrift.TSymbolLookupResult; +import org.apache.impala.thrift.TSymbolType; 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/catalog/HBaseColumn.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/HBaseColumn.java b/fe/src/main/java/org/apache/impala/catalog/HBaseColumn.java index 37fa853..dae03fb 100644 --- a/fe/src/main/java/org/apache/impala/catalog/HBaseColumn.java +++ b/fe/src/main/java/org/apache/impala/catalog/HBaseColumn.java @@ -15,9 +15,9 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; -import com.cloudera.impala.thrift.TColumn; +import org.apache.impala.thrift.TColumn; // Describes an HBase column mapped to a Hive column (as described in the metastore). // this.name describes the column name in Hive. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/HBaseTable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/HBaseTable.java b/fe/src/main/java/org/apache/impala/catalog/HBaseTable.java index d96314e..3930610 100644 --- a/fe/src/main/java/org/apache/impala/catalog/HBaseTable.java +++ b/fe/src/main/java/org/apache/impala/catalog/HBaseTable.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.io.IOException; import java.util.ArrayList; @@ -56,17 +56,17 @@ import org.apache.hadoop.hive.metastore.api.StorageDescriptor; import org.apache.hadoop.hive.serde2.SerDeException; import org.apache.log4j.Logger; -import com.cloudera.impala.common.Pair; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.TColumn; -import com.cloudera.impala.thrift.THBaseTable; -import com.cloudera.impala.thrift.TResultSet; -import com.cloudera.impala.thrift.TResultSetMetadata; -import com.cloudera.impala.thrift.TTable; -import com.cloudera.impala.thrift.TTableDescriptor; -import com.cloudera.impala.thrift.TTableType; -import com.cloudera.impala.util.StatsHelper; -import com.cloudera.impala.util.TResultRowBuilder; +import org.apache.impala.common.Pair; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TColumn; +import org.apache.impala.thrift.THBaseTable; +import org.apache.impala.thrift.TResultSet; +import org.apache.impala.thrift.TResultSetMetadata; +import org.apache.impala.thrift.TTable; +import org.apache.impala.thrift.TTableDescriptor; +import org.apache.impala.thrift.TTableType; +import org.apache.impala.util.StatsHelper; +import org.apache.impala.util.TResultRowBuilder; 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/catalog/HdfsCachePool.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/HdfsCachePool.java b/fe/src/main/java/org/apache/impala/catalog/HdfsCachePool.java index b8ff102..398bc87 100644 --- a/fe/src/main/java/org/apache/impala/catalog/HdfsCachePool.java +++ b/fe/src/main/java/org/apache/impala/catalog/HdfsCachePool.java @@ -15,12 +15,12 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import org.apache.hadoop.hdfs.protocol.CachePoolInfo; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.THdfsCachePool; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.THdfsCachePool; 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/catalog/HdfsCompression.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/HdfsCompression.java b/fe/src/main/java/org/apache/impala/catalog/HdfsCompression.java index 302ec99..36a1e9e 100644 --- a/fe/src/main/java/org/apache/impala/catalog/HdfsCompression.java +++ b/fe/src/main/java/org/apache/impala/catalog/HdfsCompression.java @@ -15,9 +15,9 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; -import com.cloudera.impala.thrift.THdfsCompression; +import org.apache.impala.thrift.THdfsCompression; import com.google.common.base.Preconditions; import com.google.common.collect.ImmutableMap; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/HdfsFileFormat.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/HdfsFileFormat.java b/fe/src/main/java/org/apache/impala/catalog/HdfsFileFormat.java index 475a8d7..86a65bd 100644 --- a/fe/src/main/java/org/apache/impala/catalog/HdfsFileFormat.java +++ b/fe/src/main/java/org/apache/impala/catalog/HdfsFileFormat.java @@ -15,12 +15,12 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.List; import java.util.Map; -import com.cloudera.impala.thrift.THdfsFileFormat; +import org.apache.impala.thrift.THdfsFileFormat; import com.google.common.base.Preconditions; import com.google.common.collect.ImmutableMap; 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/catalog/HdfsPartition.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/HdfsPartition.java b/fe/src/main/java/org/apache/impala/catalog/HdfsPartition.java index f408468..8718419 100644 --- a/fe/src/main/java/org/apache/impala/catalog/HdfsPartition.java +++ b/fe/src/main/java/org/apache/impala/catalog/HdfsPartition.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.ArrayList; import java.util.Arrays; @@ -29,25 +29,25 @@ import org.apache.hadoop.fs.Path; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.LiteralExpr; -import com.cloudera.impala.analysis.NullLiteral; -import com.cloudera.impala.analysis.PartitionKeyValue; -import com.cloudera.impala.analysis.ToSqlUtils; -import com.cloudera.impala.common.FileSystemUtil; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.thrift.ImpalaInternalServiceConstants; -import com.cloudera.impala.thrift.TAccessLevel; -import com.cloudera.impala.thrift.TExpr; -import com.cloudera.impala.thrift.TExprNode; -import com.cloudera.impala.thrift.THdfsCompression; -import com.cloudera.impala.thrift.THdfsFileBlock; -import com.cloudera.impala.thrift.THdfsFileDesc; -import com.cloudera.impala.thrift.THdfsPartition; -import com.cloudera.impala.thrift.TNetworkAddress; -import com.cloudera.impala.thrift.TPartitionStats; -import com.cloudera.impala.thrift.TTableStats; -import com.cloudera.impala.util.HdfsCachingUtil; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.LiteralExpr; +import org.apache.impala.analysis.NullLiteral; +import org.apache.impala.analysis.PartitionKeyValue; +import org.apache.impala.analysis.ToSqlUtils; +import org.apache.impala.common.FileSystemUtil; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.thrift.ImpalaInternalServiceConstants; +import org.apache.impala.thrift.TAccessLevel; +import org.apache.impala.thrift.TExpr; +import org.apache.impala.thrift.TExprNode; +import org.apache.impala.thrift.THdfsCompression; +import org.apache.impala.thrift.THdfsFileBlock; +import org.apache.impala.thrift.THdfsFileDesc; +import org.apache.impala.thrift.THdfsPartition; +import org.apache.impala.thrift.TNetworkAddress; +import org.apache.impala.thrift.TPartitionStats; +import org.apache.impala.thrift.TTableStats; +import org.apache.impala.util.HdfsCachingUtil; import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Joiner; import com.google.common.base.Objects; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/HdfsPartitionLocationCompressor.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/HdfsPartitionLocationCompressor.java b/fe/src/main/java/org/apache/impala/catalog/HdfsPartitionLocationCompressor.java index b72b846..ce53c2d 100644 --- a/fe/src/main/java/org/apache/impala/catalog/HdfsPartitionLocationCompressor.java +++ b/fe/src/main/java/org/apache/impala/catalog/HdfsPartitionLocationCompressor.java @@ -15,15 +15,15 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.ArrayList; import java.util.HashMap; import java.util.List; -import com.cloudera.impala.common.Pair; -import com.cloudera.impala.thrift.THdfsPartitionLocation; -import com.cloudera.impala.util.ListMap; +import org.apache.impala.common.Pair; +import org.apache.impala.thrift.THdfsPartitionLocation; +import org.apache.impala.util.ListMap; 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/catalog/HdfsStorageDescriptor.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/HdfsStorageDescriptor.java b/fe/src/main/java/org/apache/impala/catalog/HdfsStorageDescriptor.java index f018ce3..93121c0 100644 --- a/fe/src/main/java/org/apache/impala/catalog/HdfsStorageDescriptor.java +++ b/fe/src/main/java/org/apache/impala/catalog/HdfsStorageDescriptor.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.List; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/HdfsTable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/HdfsTable.java b/fe/src/main/java/org/apache/impala/catalog/HdfsTable.java index 2464376..e664f6f 100644 --- a/fe/src/main/java/org/apache/impala/catalog/HdfsTable.java +++ b/fe/src/main/java/org/apache/impala/catalog/HdfsTable.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.io.IOException; import java.net.URI; @@ -50,44 +50,44 @@ import org.apache.hadoop.util.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.ColumnDef; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.LiteralExpr; -import com.cloudera.impala.analysis.NullLiteral; -import com.cloudera.impala.analysis.NumericLiteral; -import com.cloudera.impala.analysis.PartitionKeyValue; -import com.cloudera.impala.catalog.HdfsPartition.BlockReplica; -import com.cloudera.impala.catalog.HdfsPartition.FileBlock; -import com.cloudera.impala.catalog.HdfsPartition.FileDescriptor; -import com.cloudera.impala.common.AnalysisException; -import com.cloudera.impala.common.FileSystemUtil; -import com.cloudera.impala.common.Pair; -import com.cloudera.impala.common.PrintUtils; -import com.cloudera.impala.thrift.ImpalaInternalServiceConstants; -import com.cloudera.impala.thrift.TAccessLevel; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.TColumn; -import com.cloudera.impala.thrift.THdfsFileBlock; -import com.cloudera.impala.thrift.THdfsPartition; -import com.cloudera.impala.thrift.THdfsPartitionLocation; -import com.cloudera.impala.thrift.THdfsTable; -import com.cloudera.impala.thrift.TNetworkAddress; -import com.cloudera.impala.thrift.TPartitionKeyValue; -import com.cloudera.impala.thrift.TResultRow; -import com.cloudera.impala.thrift.TResultSet; -import com.cloudera.impala.thrift.TResultSetMetadata; -import com.cloudera.impala.thrift.TTable; -import com.cloudera.impala.thrift.TTableDescriptor; -import com.cloudera.impala.thrift.TTableType; -import com.cloudera.impala.util.AvroSchemaConverter; -import com.cloudera.impala.util.AvroSchemaParser; -import com.cloudera.impala.util.AvroSchemaUtils; -import com.cloudera.impala.util.FsPermissionChecker; -import com.cloudera.impala.util.HdfsCachingUtil; -import com.cloudera.impala.util.ListMap; -import com.cloudera.impala.util.MetaStoreUtil; -import com.cloudera.impala.util.TAccessLevelUtil; -import com.cloudera.impala.util.TResultRowBuilder; +import org.apache.impala.analysis.ColumnDef; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.LiteralExpr; +import org.apache.impala.analysis.NullLiteral; +import org.apache.impala.analysis.NumericLiteral; +import org.apache.impala.analysis.PartitionKeyValue; +import org.apache.impala.catalog.HdfsPartition.BlockReplica; +import org.apache.impala.catalog.HdfsPartition.FileBlock; +import org.apache.impala.catalog.HdfsPartition.FileDescriptor; +import org.apache.impala.common.AnalysisException; +import org.apache.impala.common.FileSystemUtil; +import org.apache.impala.common.Pair; +import org.apache.impala.common.PrintUtils; +import org.apache.impala.thrift.ImpalaInternalServiceConstants; +import org.apache.impala.thrift.TAccessLevel; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TColumn; +import org.apache.impala.thrift.THdfsFileBlock; +import org.apache.impala.thrift.THdfsPartition; +import org.apache.impala.thrift.THdfsPartitionLocation; +import org.apache.impala.thrift.THdfsTable; +import org.apache.impala.thrift.TNetworkAddress; +import org.apache.impala.thrift.TPartitionKeyValue; +import org.apache.impala.thrift.TResultRow; +import org.apache.impala.thrift.TResultSet; +import org.apache.impala.thrift.TResultSetMetadata; +import org.apache.impala.thrift.TTable; +import org.apache.impala.thrift.TTableDescriptor; +import org.apache.impala.thrift.TTableType; +import org.apache.impala.util.AvroSchemaConverter; +import org.apache.impala.util.AvroSchemaParser; +import org.apache.impala.util.AvroSchemaUtils; +import org.apache.impala.util.FsPermissionChecker; +import org.apache.impala.util.HdfsCachingUtil; +import org.apache.impala.util.ListMap; +import org.apache.impala.util.MetaStoreUtil; +import org.apache.impala.util.TAccessLevelUtil; +import org.apache.impala.util.TResultRowBuilder; 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/catalog/HiveStorageDescriptorFactory.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/HiveStorageDescriptorFactory.java b/fe/src/main/java/org/apache/impala/catalog/HiveStorageDescriptorFactory.java index 9644bbb..342e8d7 100644 --- a/fe/src/main/java/org/apache/impala/catalog/HiveStorageDescriptorFactory.java +++ b/fe/src/main/java/org/apache/impala/catalog/HiveStorageDescriptorFactory.java @@ -15,13 +15,13 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.HashMap; import org.apache.hadoop.hive.metastore.api.StorageDescriptor; -import com.cloudera.impala.thrift.THdfsFileFormat; +import org.apache.impala.thrift.THdfsFileFormat; import com.google.common.base.Preconditions; public class HiveStorageDescriptorFactory { http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/ImpaladCatalog.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/ImpaladCatalog.java b/fe/src/main/java/org/apache/impala/catalog/ImpaladCatalog.java index 02c9747..c416bee 100644 --- a/fe/src/main/java/org/apache/impala/catalog/ImpaladCatalog.java +++ b/fe/src/main/java/org/apache/impala/catalog/ImpaladCatalog.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.concurrent.atomic.AtomicBoolean; @@ -25,19 +25,19 @@ import org.apache.hadoop.hive.metastore.api.NoSuchObjectException; import org.apache.log4j.Logger; import org.apache.thrift.TException; -import com.cloudera.impala.catalog.MetaStoreClientPool.MetaStoreClient; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.thrift.TCatalogObject; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.TDataSource; -import com.cloudera.impala.thrift.TDatabase; -import com.cloudera.impala.thrift.TFunction; -import com.cloudera.impala.thrift.TPrivilege; -import com.cloudera.impala.thrift.TRole; -import com.cloudera.impala.thrift.TTable; -import com.cloudera.impala.thrift.TUniqueId; -import com.cloudera.impala.thrift.TUpdateCatalogCacheRequest; -import com.cloudera.impala.thrift.TUpdateCatalogCacheResponse; +import org.apache.impala.catalog.MetaStoreClientPool.MetaStoreClient; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.thrift.TCatalogObject; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TDataSource; +import org.apache.impala.thrift.TDatabase; +import org.apache.impala.thrift.TFunction; +import org.apache.impala.thrift.TPrivilege; +import org.apache.impala.thrift.TRole; +import org.apache.impala.thrift.TTable; +import org.apache.impala.thrift.TUniqueId; +import org.apache.impala.thrift.TUpdateCatalogCacheRequest; +import org.apache.impala.thrift.TUpdateCatalogCacheResponse; /** * Thread safe Catalog for an Impalad. The Impalad catalog can be updated either via http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/IncompleteTable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/IncompleteTable.java b/fe/src/main/java/org/apache/impala/catalog/IncompleteTable.java index 88bab5e..ec42036 100644 --- a/fe/src/main/java/org/apache/impala/catalog/IncompleteTable.java +++ b/fe/src/main/java/org/apache/impala/catalog/IncompleteTable.java @@ -15,20 +15,20 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.List; import java.util.Set; import org.apache.hadoop.hive.metastore.IMetaStoreClient; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.JniUtil; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.TErrorCode; -import com.cloudera.impala.thrift.TStatus; -import com.cloudera.impala.thrift.TTable; -import com.cloudera.impala.thrift.TTableDescriptor; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.JniUtil; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TErrorCode; +import org.apache.impala.thrift.TStatus; +import org.apache.impala.thrift.TTable; +import org.apache.impala.thrift.TTableDescriptor; import com.google.common.base.Joiner; 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/catalog/KuduColumn.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/KuduColumn.java b/fe/src/main/java/org/apache/impala/catalog/KuduColumn.java index 5e272d8..404dbf5 100644 --- a/fe/src/main/java/org/apache/impala/catalog/KuduColumn.java +++ b/fe/src/main/java/org/apache/impala/catalog/KuduColumn.java @@ -15,9 +15,9 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; -import com.cloudera.impala.thrift.TColumn; +import org.apache.impala.thrift.TColumn; /** * Describes a Kudu column mapped to a Hive column (as described in the metastore). http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/KuduTable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/KuduTable.java b/fe/src/main/java/org/apache/impala/catalog/KuduTable.java index 71d897d..d55f8da 100644 --- a/fe/src/main/java/org/apache/impala/catalog/KuduTable.java +++ b/fe/src/main/java/org/apache/impala/catalog/KuduTable.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.ArrayList; import java.util.List; @@ -31,17 +31,17 @@ import org.apache.log4j.Logger; import org.apache.kudu.client.KuduClient; import org.apache.kudu.client.LocatedTablet; -import com.cloudera.impala.common.ImpalaRuntimeException; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.TColumn; -import com.cloudera.impala.thrift.TKuduTable; -import com.cloudera.impala.thrift.TResultSet; -import com.cloudera.impala.thrift.TResultSetMetadata; -import com.cloudera.impala.thrift.TTable; -import com.cloudera.impala.thrift.TTableDescriptor; -import com.cloudera.impala.thrift.TTableType; -import com.cloudera.impala.util.KuduUtil; -import com.cloudera.impala.util.TResultRowBuilder; +import org.apache.impala.common.ImpalaRuntimeException; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TColumn; +import org.apache.impala.thrift.TKuduTable; +import org.apache.impala.thrift.TResultSet; +import org.apache.impala.thrift.TResultSetMetadata; +import org.apache.impala.thrift.TTable; +import org.apache.impala.thrift.TTableDescriptor; +import org.apache.impala.thrift.TTableType; +import org.apache.impala.util.KuduUtil; +import org.apache.impala.util.TResultRowBuilder; import com.google.common.base.Joiner; import com.google.common.base.Preconditions; import com.google.common.collect.ImmutableList; @@ -146,7 +146,7 @@ public class KuduTable extends Table { Set<String> columnNames = Sets.newHashSet(); int pos = 0; for (FieldSchema field: schema) { - com.cloudera.impala.catalog.Type type = parseColumnType(field); + org.apache.impala.catalog.Type type = parseColumnType(field); // TODO(kudu-merge): Check for decimal types? boolean isKey = keyColumns.contains(field.getName()); KuduColumn col = new KuduColumn(field.getName(), isKey, !isKey, type, http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/MapType.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/MapType.java b/fe/src/main/java/org/apache/impala/catalog/MapType.java index 8bc7b05..4235181 100644 --- a/fe/src/main/java/org/apache/impala/catalog/MapType.java +++ b/fe/src/main/java/org/apache/impala/catalog/MapType.java @@ -15,13 +15,13 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import org.apache.commons.lang3.StringUtils; -import com.cloudera.impala.thrift.TColumnType; -import com.cloudera.impala.thrift.TTypeNode; -import com.cloudera.impala.thrift.TTypeNodeType; +import org.apache.impala.thrift.TColumnType; +import org.apache.impala.thrift.TTypeNode; +import org.apache.impala.thrift.TTypeNodeType; 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/catalog/MetaStoreClientPool.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/MetaStoreClientPool.java b/fe/src/main/java/org/apache/impala/catalog/MetaStoreClientPool.java index 40eb4cf..372fe37 100644 --- a/fe/src/main/java/org/apache/impala/catalog/MetaStoreClientPool.java +++ b/fe/src/main/java/org/apache/impala/catalog/MetaStoreClientPool.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.concurrent.ConcurrentLinkedQueue; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/PartitionNotFoundException.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/PartitionNotFoundException.java b/fe/src/main/java/org/apache/impala/catalog/PartitionNotFoundException.java index 9964a3c..60707ef 100644 --- a/fe/src/main/java/org/apache/impala/catalog/PartitionNotFoundException.java +++ b/fe/src/main/java/org/apache/impala/catalog/PartitionNotFoundException.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/PartitionStatsUtil.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/PartitionStatsUtil.java b/fe/src/main/java/org/apache/impala/catalog/PartitionStatsUtil.java index 2f2022f..222f252 100644 --- a/fe/src/main/java/org/apache/impala/catalog/PartitionStatsUtil.java +++ b/fe/src/main/java/org/apache/impala/catalog/PartitionStatsUtil.java @@ -15,13 +15,13 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; -import com.cloudera.impala.thrift.TPartitionStats; -import com.cloudera.impala.common.JniUtil; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.ImpalaRuntimeException; -import com.cloudera.impala.util.MetaStoreUtil; +import org.apache.impala.thrift.TPartitionStats; +import org.apache.impala.common.JniUtil; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.ImpalaRuntimeException; +import org.apache.impala.util.MetaStoreUtil; import java.util.Iterator; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/PrimitiveType.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/PrimitiveType.java b/fe/src/main/java/org/apache/impala/catalog/PrimitiveType.java index 4344b61..fa53c6c 100644 --- a/fe/src/main/java/org/apache/impala/catalog/PrimitiveType.java +++ b/fe/src/main/java/org/apache/impala/catalog/PrimitiveType.java @@ -15,11 +15,11 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.List; -import com.cloudera.impala.thrift.TPrimitiveType; +import org.apache.impala.thrift.TPrimitiveType; import com.google.common.collect.Lists; public enum PrimitiveType { http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/Role.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/Role.java b/fe/src/main/java/org/apache/impala/catalog/Role.java index 7ba1bac..0b89866 100644 --- a/fe/src/main/java/org/apache/impala/catalog/Role.java +++ b/fe/src/main/java/org/apache/impala/catalog/Role.java @@ -15,14 +15,14 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.List; import java.util.Set; import java.util.concurrent.atomic.AtomicInteger; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.TRole; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TRole; 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/catalog/RolePrivilege.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/RolePrivilege.java b/fe/src/main/java/org/apache/impala/catalog/RolePrivilege.java index 37d91d8..58bb906 100644 --- a/fe/src/main/java/org/apache/impala/catalog/RolePrivilege.java +++ b/fe/src/main/java/org/apache/impala/catalog/RolePrivilege.java @@ -15,16 +15,16 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.List; import org.apache.log4j.Logger; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.TPrivilege; -import com.cloudera.impala.thrift.TPrivilegeLevel; -import com.cloudera.impala.thrift.TPrivilegeScope; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TPrivilege; +import org.apache.impala.thrift.TPrivilegeLevel; +import org.apache.impala.thrift.TPrivilegeScope; 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/catalog/RowFormat.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/RowFormat.java b/fe/src/main/java/org/apache/impala/catalog/RowFormat.java index 76dcacb..832d115 100644 --- a/fe/src/main/java/org/apache/impala/catalog/RowFormat.java +++ b/fe/src/main/java/org/apache/impala/catalog/RowFormat.java @@ -15,14 +15,14 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.Map; import org.apache.hadoop.hive.metastore.api.StorageDescriptor; -import com.cloudera.impala.analysis.StringLiteral; -import com.cloudera.impala.thrift.TTableRowFormat; +import org.apache.impala.analysis.StringLiteral; +import org.apache.impala.thrift.TTableRowFormat; 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/catalog/ScalarFunction.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/ScalarFunction.java b/fe/src/main/java/org/apache/impala/catalog/ScalarFunction.java index b921015..766111e 100644 --- a/fe/src/main/java/org/apache/impala/catalog/ScalarFunction.java +++ b/fe/src/main/java/org/apache/impala/catalog/ScalarFunction.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.ArrayList; import java.util.List; @@ -25,14 +25,14 @@ import org.apache.hadoop.hive.metastore.api.PrincipalType; import org.apache.hadoop.hive.metastore.api.ResourceType; import org.apache.hadoop.hive.metastore.api.ResourceUri; -import com.cloudera.impala.analysis.FunctionName; -import com.cloudera.impala.analysis.HdfsUri; -import com.cloudera.impala.common.AnalysisException; -import com.cloudera.impala.hive.executor.UdfExecutor.JavaUdfDataType; -import com.cloudera.impala.thrift.TFunction; -import com.cloudera.impala.thrift.TFunctionBinaryType; -import com.cloudera.impala.thrift.TScalarFunction; -import com.cloudera.impala.thrift.TSymbolType; +import org.apache.impala.analysis.FunctionName; +import org.apache.impala.analysis.HdfsUri; +import org.apache.impala.common.AnalysisException; +import org.apache.impala.hive.executor.UdfExecutor.JavaUdfDataType; +import org.apache.impala.thrift.TFunction; +import org.apache.impala.thrift.TFunctionBinaryType; +import org.apache.impala.thrift.TScalarFunction; +import org.apache.impala.thrift.TSymbolType; 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/catalog/ScalarType.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/ScalarType.java b/fe/src/main/java/org/apache/impala/catalog/ScalarType.java index ae955f8..5f98b7c 100644 --- a/fe/src/main/java/org/apache/impala/catalog/ScalarType.java +++ b/fe/src/main/java/org/apache/impala/catalog/ScalarType.java @@ -15,15 +15,15 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import org.apache.commons.lang3.StringUtils; -import com.cloudera.impala.analysis.TypesUtil; -import com.cloudera.impala.thrift.TColumnType; -import com.cloudera.impala.thrift.TScalarType; -import com.cloudera.impala.thrift.TTypeNode; -import com.cloudera.impala.thrift.TTypeNodeType; +import org.apache.impala.analysis.TypesUtil; +import org.apache.impala.thrift.TColumnType; +import org.apache.impala.thrift.TScalarType; +import org.apache.impala.thrift.TTypeNode; +import org.apache.impala.thrift.TTypeNodeType; 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/catalog/StructField.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/StructField.java b/fe/src/main/java/org/apache/impala/catalog/StructField.java index 4b9cb80..6e44714 100644 --- a/fe/src/main/java/org/apache/impala/catalog/StructField.java +++ b/fe/src/main/java/org/apache/impala/catalog/StructField.java @@ -15,13 +15,13 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import org.apache.commons.lang3.StringUtils; -import com.cloudera.impala.thrift.TColumnType; -import com.cloudera.impala.thrift.TStructField; -import com.cloudera.impala.thrift.TTypeNode; +import org.apache.impala.thrift.TColumnType; +import org.apache.impala.thrift.TStructField; +import org.apache.impala.thrift.TTypeNode; /** * TODO: Support comments for struct fields. The Metastore does not properly store http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/StructType.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/StructType.java b/fe/src/main/java/org/apache/impala/catalog/StructType.java index 3600b6b..421e74e 100644 --- a/fe/src/main/java/org/apache/impala/catalog/StructType.java +++ b/fe/src/main/java/org/apache/impala/catalog/StructType.java @@ -15,17 +15,17 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.ArrayList; import java.util.HashMap; import org.apache.commons.lang3.StringUtils; -import com.cloudera.impala.thrift.TColumnType; -import com.cloudera.impala.thrift.TStructField; -import com.cloudera.impala.thrift.TTypeNode; -import com.cloudera.impala.thrift.TTypeNodeType; +import org.apache.impala.thrift.TColumnType; +import org.apache.impala.thrift.TStructField; +import org.apache.impala.thrift.TTypeNode; +import org.apache.impala.thrift.TTypeNodeType; 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/catalog/Table.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/Table.java b/fe/src/main/java/org/apache/impala/catalog/Table.java index f794d7e..6145cc5 100644 --- a/fe/src/main/java/org/apache/impala/catalog/Table.java +++ b/fe/src/main/java/org/apache/impala/catalog/Table.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.ArrayList; import java.util.EnumSet; @@ -30,19 +30,19 @@ import org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj; import org.apache.hadoop.hive.metastore.api.FieldSchema; import org.apache.log4j.Logger; -import com.cloudera.impala.analysis.TableName; -import com.cloudera.impala.common.AnalysisException; -import com.cloudera.impala.common.ImpalaRuntimeException; -import com.cloudera.impala.common.Pair; -import com.cloudera.impala.thrift.TAccessLevel; -import com.cloudera.impala.thrift.TCatalogObject; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.TColumn; -import com.cloudera.impala.thrift.TColumnDescriptor; -import com.cloudera.impala.thrift.TTable; -import com.cloudera.impala.thrift.TTableDescriptor; -import com.cloudera.impala.thrift.TTableStats; -import com.cloudera.impala.util.HdfsCachingUtil; +import org.apache.impala.analysis.TableName; +import org.apache.impala.common.AnalysisException; +import org.apache.impala.common.ImpalaRuntimeException; +import org.apache.impala.common.Pair; +import org.apache.impala.thrift.TAccessLevel; +import org.apache.impala.thrift.TCatalogObject; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TColumn; +import org.apache.impala.thrift.TColumnDescriptor; +import org.apache.impala.thrift.TTable; +import org.apache.impala.thrift.TTableDescriptor; +import org.apache.impala.thrift.TTableStats; +import org.apache.impala.util.HdfsCachingUtil; 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/catalog/TableId.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/TableId.java b/fe/src/main/java/org/apache/impala/catalog/TableId.java index 1918029..2b1dabc 100644 --- a/fe/src/main/java/org/apache/impala/catalog/TableId.java +++ b/fe/src/main/java/org/apache/impala/catalog/TableId.java @@ -15,10 +15,10 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; -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 TableId extends Id<TableId> { // 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/catalog/TableLoader.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/TableLoader.java b/fe/src/main/java/org/apache/impala/catalog/TableLoader.java index 78b58f6..764abe0 100644 --- a/fe/src/main/java/org/apache/impala/catalog/TableLoader.java +++ b/fe/src/main/java/org/apache/impala/catalog/TableLoader.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.EnumSet; import java.util.Set; @@ -24,7 +24,7 @@ import org.apache.hadoop.hive.metastore.TableType; import org.apache.hadoop.hive.metastore.api.NoSuchObjectException; import org.apache.log4j.Logger; -import com.cloudera.impala.catalog.MetaStoreClientPool.MetaStoreClient; +import org.apache.impala.catalog.MetaStoreClientPool.MetaStoreClient; /** * Class that implements the logic for how a table's metadata should be loaded from http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/TableLoadingException.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/TableLoadingException.java b/fe/src/main/java/org/apache/impala/catalog/TableLoadingException.java index ab55675..89b405b 100644 --- a/fe/src/main/java/org/apache/impala/catalog/TableLoadingException.java +++ b/fe/src/main/java/org/apache/impala/catalog/TableLoadingException.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/TableLoadingMgr.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/TableLoadingMgr.java b/fe/src/main/java/org/apache/impala/catalog/TableLoadingMgr.java index 57cc513..5f64b6d 100644 --- a/fe/src/main/java/org/apache/impala/catalog/TableLoadingMgr.java +++ b/fe/src/main/java/org/apache/impala/catalog/TableLoadingMgr.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.util.Collections; import java.util.HashSet; @@ -33,8 +33,8 @@ import java.util.concurrent.LinkedBlockingQueue; import org.apache.log4j.Logger; -import com.cloudera.impala.thrift.TTableName; -import com.cloudera.impala.util.HdfsCachingUtil; +import org.apache.impala.thrift.TTableName; +import org.apache.impala.util.HdfsCachingUtil; import com.google.common.base.Preconditions; 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/catalog/TableNotFoundException.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/TableNotFoundException.java b/fe/src/main/java/org/apache/impala/catalog/TableNotFoundException.java index 26686d1..7b93a20 100644 --- a/fe/src/main/java/org/apache/impala/catalog/TableNotFoundException.java +++ b/fe/src/main/java/org/apache/impala/catalog/TableNotFoundException.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; /**
