http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/Type.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/Type.java b/fe/src/main/java/org/apache/impala/catalog/Type.java index 0162ec6..91fc2e3 100644 --- a/fe/src/main/java/org/apache/impala/catalog/Type.java +++ b/fe/src/main/java/org/apache/impala/catalog/Type.java @@ -15,23 +15,23 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog; +package org.apache.impala.catalog; import java.io.StringReader; import java.util.ArrayList; import java.util.List; -import com.cloudera.impala.analysis.CreateTableStmt; -import com.cloudera.impala.analysis.SqlParser; -import com.cloudera.impala.analysis.SqlScanner; -import com.cloudera.impala.analysis.TypeDef; -import com.cloudera.impala.common.Pair; -import com.cloudera.impala.thrift.TColumnType; -import com.cloudera.impala.thrift.TPrimitiveType; -import com.cloudera.impala.thrift.TScalarType; -import com.cloudera.impala.thrift.TStructField; -import com.cloudera.impala.thrift.TTypeNode; -import com.cloudera.impala.thrift.TTypeNodeType; +import org.apache.impala.analysis.CreateTableStmt; +import org.apache.impala.analysis.SqlParser; +import org.apache.impala.analysis.SqlScanner; +import org.apache.impala.analysis.TypeDef; +import org.apache.impala.common.Pair; +import org.apache.impala.thrift.TColumnType; +import org.apache.impala.thrift.TPrimitiveType; +import org.apache.impala.thrift.TScalarType; +import org.apache.impala.thrift.TStructField; +import org.apache.impala.thrift.TTypeNode; +import org.apache.impala.thrift.TTypeNodeType; 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/View.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/View.java b/fe/src/main/java/org/apache/impala/catalog/View.java index cc82f95..46f089e 100644 --- a/fe/src/main/java/org/apache/impala/catalog/View.java +++ b/fe/src/main/java/org/apache/impala/catalog/View.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.StringReader; import java.util.List; @@ -24,14 +24,14 @@ import java.util.Set; import org.apache.hadoop.hive.metastore.IMetaStoreClient; import org.apache.hadoop.hive.metastore.api.FieldSchema; -import com.cloudera.impala.analysis.ParseNode; -import com.cloudera.impala.analysis.QueryStmt; -import com.cloudera.impala.analysis.SqlParser; -import com.cloudera.impala.analysis.SqlScanner; -import com.cloudera.impala.thrift.TCatalogObjectType; -import com.cloudera.impala.thrift.TTable; -import com.cloudera.impala.thrift.TTableDescriptor; -import com.cloudera.impala.thrift.TTableType; +import org.apache.impala.analysis.ParseNode; +import org.apache.impala.analysis.QueryStmt; +import org.apache.impala.analysis.SqlParser; +import org.apache.impala.analysis.SqlScanner; +import org.apache.impala.thrift.TCatalogObjectType; +import org.apache.impala.thrift.TTable; +import org.apache.impala.thrift.TTableDescriptor; +import org.apache.impala.thrift.TTableType; 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/delegates/DdlDelegate.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/delegates/DdlDelegate.java b/fe/src/main/java/org/apache/impala/catalog/delegates/DdlDelegate.java index a21bd90..6c3ba8e 100644 --- a/fe/src/main/java/org/apache/impala/catalog/delegates/DdlDelegate.java +++ b/fe/src/main/java/org/apache/impala/catalog/delegates/DdlDelegate.java @@ -15,15 +15,15 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog.delegates; +package org.apache.impala.catalog.delegates; import java.util.List; -import com.cloudera.impala.thrift.TDistributeParam; +import org.apache.impala.thrift.TDistributeParam; import org.apache.hadoop.hive.metastore.api.Table; -import com.cloudera.impala.common.ImpalaRuntimeException; -import com.cloudera.impala.thrift.TAlterTableParams; +import org.apache.impala.common.ImpalaRuntimeException; +import org.apache.impala.thrift.TAlterTableParams; /** * Abstract class to implement the storage specific portion of DDL requests. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/delegates/KuduDdlDelegate.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/delegates/KuduDdlDelegate.java b/fe/src/main/java/org/apache/impala/catalog/delegates/KuduDdlDelegate.java index ecfeb1a..8410868 100644 --- a/fe/src/main/java/org/apache/impala/catalog/delegates/KuduDdlDelegate.java +++ b/fe/src/main/java/org/apache/impala/catalog/delegates/KuduDdlDelegate.java @@ -15,11 +15,11 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog.delegates; +package org.apache.impala.catalog.delegates; -import static com.cloudera.impala.util.KuduUtil.compareSchema; -import static com.cloudera.impala.util.KuduUtil.fromImpalaType; -import static com.cloudera.impala.util.KuduUtil.parseKeyColumns; +import static org.apache.impala.util.KuduUtil.compareSchema; +import static org.apache.impala.util.KuduUtil.fromImpalaType; +import static org.apache.impala.util.KuduUtil.parseKeyColumns; import java.util.ArrayList; import java.util.HashSet; @@ -38,10 +38,10 @@ import org.apache.kudu.client.PartialRow; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.catalog.KuduTable; -import com.cloudera.impala.common.ImpalaRuntimeException; -import com.cloudera.impala.thrift.TDistributeParam; -import com.cloudera.impala.util.KuduUtil; +import org.apache.impala.catalog.KuduTable; +import org.apache.impala.common.ImpalaRuntimeException; +import org.apache.impala.thrift.TDistributeParam; +import org.apache.impala.util.KuduUtil; import com.google.common.base.Preconditions; import com.google.common.base.Strings; import com.google.common.collect.Lists; @@ -100,7 +100,7 @@ public class KuduDdlDelegate extends DdlDelegate { // Create a new Schema and map the types accordingly ArrayList<ColumnSchema> columns = Lists.newArrayList(); for (FieldSchema fieldSchema: msTbl_.getSd().getCols()) { - com.cloudera.impala.catalog.Type catalogType = com.cloudera.impala.catalog.Type + org.apache.impala.catalog.Type catalogType = org.apache.impala.catalog.Type .parseColumnType(fieldSchema.getType()); if (catalogType == null) { throw new ImpalaRuntimeException(String.format( http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/catalog/delegates/UnsupportedOpDelegate.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/catalog/delegates/UnsupportedOpDelegate.java b/fe/src/main/java/org/apache/impala/catalog/delegates/UnsupportedOpDelegate.java index 52267be..8aabaa4 100644 --- a/fe/src/main/java/org/apache/impala/catalog/delegates/UnsupportedOpDelegate.java +++ b/fe/src/main/java/org/apache/impala/catalog/delegates/UnsupportedOpDelegate.java @@ -15,9 +15,9 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.catalog.delegates; +package org.apache.impala.catalog.delegates; -import com.cloudera.impala.common.ImpalaRuntimeException; +import org.apache.impala.common.ImpalaRuntimeException; /** * Empty implementation for the DdlDelegate interface that does nothing. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/common/AliasGenerator.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/AliasGenerator.java b/fe/src/main/java/org/apache/impala/common/AliasGenerator.java index 2d75d18..b199b54 100644 --- a/fe/src/main/java/org/apache/impala/common/AliasGenerator.java +++ b/fe/src/main/java/org/apache/impala/common/AliasGenerator.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; import java.util.Set; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/common/AnalysisException.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/AnalysisException.java b/fe/src/main/java/org/apache/impala/common/AnalysisException.java index 464cfa0..cbc4f00 100644 --- a/fe/src/main/java/org/apache/impala/common/AnalysisException.java +++ b/fe/src/main/java/org/apache/impala/common/AnalysisException.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; /** * Thrown for errors encountered during analysis of a SQL statement. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/common/ByteUnits.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/ByteUnits.java b/fe/src/main/java/org/apache/impala/common/ByteUnits.java index f8b43ab..51aeb2f 100644 --- a/fe/src/main/java/org/apache/impala/common/ByteUnits.java +++ b/fe/src/main/java/org/apache/impala/common/ByteUnits.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; /** * Byte unit constants. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/common/ColumnAliasGenerator.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/ColumnAliasGenerator.java b/fe/src/main/java/org/apache/impala/common/ColumnAliasGenerator.java index 51c8ece..49c0f7d 100644 --- a/fe/src/main/java/org/apache/impala/common/ColumnAliasGenerator.java +++ b/fe/src/main/java/org/apache/impala/common/ColumnAliasGenerator.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/common/FileSystemUtil.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/FileSystemUtil.java b/fe/src/main/java/org/apache/impala/common/FileSystemUtil.java index 2239853..fbf8478 100644 --- a/fe/src/main/java/org/apache/impala/common/FileSystemUtil.java +++ b/fe/src/main/java/org/apache/impala/common/FileSystemUtil.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; import java.io.FileNotFoundException; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/common/Id.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/Id.java b/fe/src/main/java/org/apache/impala/common/Id.java index 88f626f..3eee186 100644 --- a/fe/src/main/java/org/apache/impala/common/Id.java +++ b/fe/src/main/java/org/apache/impala/common/Id.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; 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/common/IdGenerator.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/IdGenerator.java b/fe/src/main/java/org/apache/impala/common/IdGenerator.java index cdece7d..f0991f1 100644 --- a/fe/src/main/java/org/apache/impala/common/IdGenerator.java +++ b/fe/src/main/java/org/apache/impala/common/IdGenerator.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; /** * Generator of consecutively numbered integers to be used as ids by subclasses of Id. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/common/ImpalaException.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/ImpalaException.java b/fe/src/main/java/org/apache/impala/common/ImpalaException.java index 6a50bf8..100f682 100644 --- a/fe/src/main/java/org/apache/impala/common/ImpalaException.java +++ b/fe/src/main/java/org/apache/impala/common/ImpalaException.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/common/ImpalaRuntimeException.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/ImpalaRuntimeException.java b/fe/src/main/java/org/apache/impala/common/ImpalaRuntimeException.java index 27a8925..8b74c68 100644 --- a/fe/src/main/java/org/apache/impala/common/ImpalaRuntimeException.java +++ b/fe/src/main/java/org/apache/impala/common/ImpalaRuntimeException.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; /** * Thrown for errors encountered during the execution of a SQL statement. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/common/InternalException.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/InternalException.java b/fe/src/main/java/org/apache/impala/common/InternalException.java index 64a8d5e..775a532 100644 --- a/fe/src/main/java/org/apache/impala/common/InternalException.java +++ b/fe/src/main/java/org/apache/impala/common/InternalException.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; /** * Thrown for internal server errors. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/common/JniUtil.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/JniUtil.java b/fe/src/main/java/org/apache/impala/common/JniUtil.java index 2f11c52..4446a55 100644 --- a/fe/src/main/java/org/apache/impala/common/JniUtil.java +++ b/fe/src/main/java/org/apache/impala/common/JniUtil.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; import java.io.IOException; import java.io.PrintWriter; @@ -33,9 +33,9 @@ import org.apache.thrift.TException; import org.apache.thrift.protocol.TBinaryProtocol; import org.apache.thrift.protocol.TProtocolFactory; -import com.cloudera.impala.thrift.TGetJvmMetricsRequest; -import com.cloudera.impala.thrift.TGetJvmMetricsResponse; -import com.cloudera.impala.thrift.TJvmMemoryPool; +import org.apache.impala.thrift.TGetJvmMetricsRequest; +import org.apache.impala.thrift.TGetJvmMetricsResponse; +import org.apache.impala.thrift.TJvmMemoryPool; /** * Utility class with methods intended for JNI clients http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/common/NotImplementedException.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/NotImplementedException.java b/fe/src/main/java/org/apache/impala/common/NotImplementedException.java index b06a130..8549242 100644 --- a/fe/src/main/java/org/apache/impala/common/NotImplementedException.java +++ b/fe/src/main/java/org/apache/impala/common/NotImplementedException.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; /** * Thrown for SQL statements that require as yet unimplemented functionality. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/common/Pair.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/Pair.java b/fe/src/main/java/org/apache/impala/common/Pair.java index c17c535..685d8e5 100644 --- a/fe/src/main/java/org/apache/impala/common/Pair.java +++ b/fe/src/main/java/org/apache/impala/common/Pair.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; /** * The equivalent of C++'s std::pair<>. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/common/PrintUtils.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/PrintUtils.java b/fe/src/main/java/org/apache/impala/common/PrintUtils.java index 78e0d6d..3062161 100644 --- a/fe/src/main/java/org/apache/impala/common/PrintUtils.java +++ b/fe/src/main/java/org/apache/impala/common/PrintUtils.java @@ -15,13 +15,13 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; -import static com.cloudera.impala.common.ByteUnits.GIGABYTE; -import static com.cloudera.impala.common.ByteUnits.KILOBYTE; -import static com.cloudera.impala.common.ByteUnits.MEGABYTE; -import static com.cloudera.impala.common.ByteUnits.PETABYTE; -import static com.cloudera.impala.common.ByteUnits.TERABYTE; +import static org.apache.impala.common.ByteUnits.GIGABYTE; +import static org.apache.impala.common.ByteUnits.KILOBYTE; +import static org.apache.impala.common.ByteUnits.MEGABYTE; +import static org.apache.impala.common.ByteUnits.PETABYTE; +import static org.apache.impala.common.ByteUnits.TERABYTE; import java.text.DecimalFormat; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/common/Reference.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/Reference.java b/fe/src/main/java/org/apache/impala/common/Reference.java index aff1dae..a157b47 100644 --- a/fe/src/main/java/org/apache/impala/common/Reference.java +++ b/fe/src/main/java/org/apache/impala/common/Reference.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; /** * "Indirection layer" that allows returning an object via an output http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/common/RuntimeEnv.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/RuntimeEnv.java b/fe/src/main/java/org/apache/impala/common/RuntimeEnv.java index febd657..af58b16 100644 --- a/fe/src/main/java/org/apache/impala/common/RuntimeEnv.java +++ b/fe/src/main/java/org/apache/impala/common/RuntimeEnv.java @@ -15,13 +15,13 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.service.FeSupport; -import com.cloudera.impala.thrift.TStartupOptions; +import org.apache.impala.service.FeSupport; +import org.apache.impala.thrift.TStartupOptions; /** * Contains runtime-specific parameters such as the number of CPU cores. Currently only http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/common/TableAliasGenerator.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/TableAliasGenerator.java b/fe/src/main/java/org/apache/impala/common/TableAliasGenerator.java index 6ded288..8fe656c 100644 --- a/fe/src/main/java/org/apache/impala/common/TableAliasGenerator.java +++ b/fe/src/main/java/org/apache/impala/common/TableAliasGenerator.java @@ -15,9 +15,9 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; -import com.cloudera.impala.analysis.Analyzer; +import org.apache.impala.analysis.Analyzer; 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/common/TreeNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/TreeNode.java b/fe/src/main/java/org/apache/impala/common/TreeNode.java index ac8f297..adaee18 100644 --- a/fe/src/main/java/org/apache/impala/common/TreeNode.java +++ b/fe/src/main/java/org/apache/impala/common/TreeNode.java @@ -15,13 +15,13 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.common; +package org.apache.impala.common; import java.util.ArrayList; import java.util.Collection; import java.util.List; -import com.cloudera.impala.util.Visitor; +import org.apache.impala.util.Visitor; import com.google.common.base.Predicate; /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/extdatasource/ApiVersion.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/extdatasource/ApiVersion.java b/fe/src/main/java/org/apache/impala/extdatasource/ApiVersion.java index d2285a4..8d4af15 100644 --- a/fe/src/main/java/org/apache/impala/extdatasource/ApiVersion.java +++ b/fe/src/main/java/org/apache/impala/extdatasource/ApiVersion.java @@ -15,16 +15,16 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.extdatasource; +package org.apache.impala.extdatasource; -import com.cloudera.impala.extdatasource.v1.ExternalDataSource; +import org.apache.impala.extdatasource.v1.ExternalDataSource; import com.google.common.base.Strings; /** * Enumerates the valid versions of the {@link ExternalDataSource} API. */ public enum ApiVersion { - V1(com.cloudera.impala.extdatasource.v1.ExternalDataSource.class); + V1(org.apache.impala.extdatasource.v1.ExternalDataSource.class); private final Class<?> apiInterface_; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/extdatasource/ExternalDataSourceExecutor.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/extdatasource/ExternalDataSourceExecutor.java b/fe/src/main/java/org/apache/impala/extdatasource/ExternalDataSourceExecutor.java index 3af470f..49d9426 100644 --- a/fe/src/main/java/org/apache/impala/extdatasource/ExternalDataSourceExecutor.java +++ b/fe/src/main/java/org/apache/impala/extdatasource/ExternalDataSourceExecutor.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.extdatasource; +package org.apache.impala.extdatasource; import java.io.File; import java.lang.reflect.Constructor; @@ -30,21 +30,21 @@ import org.apache.thrift.protocol.TBinaryProtocol; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.ImpalaRuntimeException; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.common.JniUtil; -import com.cloudera.impala.extdatasource.thrift.TCloseParams; -import com.cloudera.impala.extdatasource.thrift.TCloseResult; -import com.cloudera.impala.extdatasource.thrift.TGetNextParams; -import com.cloudera.impala.extdatasource.thrift.TGetNextResult; -import com.cloudera.impala.extdatasource.thrift.TOpenParams; -import com.cloudera.impala.extdatasource.thrift.TOpenResult; -import com.cloudera.impala.extdatasource.thrift.TPrepareParams; -import com.cloudera.impala.extdatasource.thrift.TPrepareResult; -import com.cloudera.impala.extdatasource.v1.ExternalDataSource; -import com.cloudera.impala.thrift.TErrorCode; -import com.cloudera.impala.thrift.TStatus; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.ImpalaRuntimeException; +import org.apache.impala.common.InternalException; +import org.apache.impala.common.JniUtil; +import org.apache.impala.extdatasource.thrift.TCloseParams; +import org.apache.impala.extdatasource.thrift.TCloseResult; +import org.apache.impala.extdatasource.thrift.TGetNextParams; +import org.apache.impala.extdatasource.thrift.TGetNextResult; +import org.apache.impala.extdatasource.thrift.TOpenParams; +import org.apache.impala.extdatasource.thrift.TOpenResult; +import org.apache.impala.extdatasource.thrift.TPrepareParams; +import org.apache.impala.extdatasource.thrift.TPrepareResult; +import org.apache.impala.extdatasource.v1.ExternalDataSource; +import org.apache.impala.thrift.TErrorCode; +import org.apache.impala.thrift.TStatus; 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/hive/executor/ImpalaBigIntWritable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaBigIntWritable.java b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaBigIntWritable.java index f410ddf..a7fde97 100644 --- a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaBigIntWritable.java +++ b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaBigIntWritable.java @@ -15,11 +15,11 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.hive.executor; +package org.apache.impala.hive.executor; import org.apache.hadoop.io.LongWritable; -import com.cloudera.impala.util.UnsafeUtil; +import org.apache.impala.util.UnsafeUtil; @SuppressWarnings("restriction") public class ImpalaBigIntWritable extends LongWritable { http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/hive/executor/ImpalaBooleanWritable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaBooleanWritable.java b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaBooleanWritable.java index f20f49e..9720715 100644 --- a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaBooleanWritable.java +++ b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaBooleanWritable.java @@ -15,11 +15,11 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.hive.executor; +package org.apache.impala.hive.executor; import org.apache.hadoop.io.BooleanWritable; -import com.cloudera.impala.util.UnsafeUtil; +import org.apache.impala.util.UnsafeUtil; @SuppressWarnings("restriction") public class ImpalaBooleanWritable extends BooleanWritable { http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/hive/executor/ImpalaBytesWritable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaBytesWritable.java b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaBytesWritable.java index ce6fc0c..94824e0 100644 --- a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaBytesWritable.java +++ b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaBytesWritable.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.hive.executor; +package org.apache.impala.hive.executor; import org.apache.hadoop.io.BytesWritable; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/hive/executor/ImpalaDoubleWritable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaDoubleWritable.java b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaDoubleWritable.java index cc96895..2a0bd16 100644 --- a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaDoubleWritable.java +++ b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaDoubleWritable.java @@ -15,11 +15,11 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.hive.executor; +package org.apache.impala.hive.executor; import org.apache.hadoop.hive.serde2.io.DoubleWritable; -import com.cloudera.impala.util.UnsafeUtil; +import org.apache.impala.util.UnsafeUtil; @SuppressWarnings("restriction") public class ImpalaDoubleWritable extends DoubleWritable { http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/hive/executor/ImpalaFloatWritable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaFloatWritable.java b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaFloatWritable.java index b68ee69..c39f596 100644 --- a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaFloatWritable.java +++ b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaFloatWritable.java @@ -15,11 +15,11 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.hive.executor; +package org.apache.impala.hive.executor; import org.apache.hadoop.io.FloatWritable; -import com.cloudera.impala.util.UnsafeUtil; +import org.apache.impala.util.UnsafeUtil; @SuppressWarnings("restriction") public class ImpalaFloatWritable extends FloatWritable { http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/hive/executor/ImpalaIntWritable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaIntWritable.java b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaIntWritable.java index afe59c4..a084dc9 100644 --- a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaIntWritable.java +++ b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaIntWritable.java @@ -15,11 +15,11 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.hive.executor; +package org.apache.impala.hive.executor; import org.apache.hadoop.io.IntWritable; -import com.cloudera.impala.util.UnsafeUtil; +import org.apache.impala.util.UnsafeUtil; @SuppressWarnings("restriction") public class ImpalaIntWritable extends IntWritable { http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/hive/executor/ImpalaSmallIntWritable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaSmallIntWritable.java b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaSmallIntWritable.java index 5a8e346..c79e0d8 100644 --- a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaSmallIntWritable.java +++ b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaSmallIntWritable.java @@ -15,11 +15,11 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.hive.executor; +package org.apache.impala.hive.executor; import org.apache.hadoop.hive.serde2.io.ShortWritable; -import com.cloudera.impala.util.UnsafeUtil; +import org.apache.impala.util.UnsafeUtil; @SuppressWarnings("restriction") public class ImpalaSmallIntWritable extends ShortWritable { http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/hive/executor/ImpalaStringWritable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaStringWritable.java b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaStringWritable.java index a9dca74..2ef6adf 100644 --- a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaStringWritable.java +++ b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaStringWritable.java @@ -15,11 +15,11 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.hive.executor; +package org.apache.impala.hive.executor; import java.nio.ByteBuffer; -import com.cloudera.impala.util.UnsafeUtil; +import org.apache.impala.util.UnsafeUtil; @SuppressWarnings("restriction") /** http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/hive/executor/ImpalaTextWritable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaTextWritable.java b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaTextWritable.java index e17a4df..bae4537 100644 --- a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaTextWritable.java +++ b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaTextWritable.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.hive.executor; +package org.apache.impala.hive.executor; import org.apache.hadoop.io.Text; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/hive/executor/ImpalaTinyIntWritable.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaTinyIntWritable.java b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaTinyIntWritable.java index 17a7b14..a7315ac 100644 --- a/fe/src/main/java/org/apache/impala/hive/executor/ImpalaTinyIntWritable.java +++ b/fe/src/main/java/org/apache/impala/hive/executor/ImpalaTinyIntWritable.java @@ -15,11 +15,11 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.hive.executor; +package org.apache.impala.hive.executor; import org.apache.hadoop.hive.serde2.io.ByteWritable; -import com.cloudera.impala.util.UnsafeUtil; +import org.apache.impala.util.UnsafeUtil; @SuppressWarnings("restriction") public class ImpalaTinyIntWritable extends ByteWritable { http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/hive/executor/UdfExecutor.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/hive/executor/UdfExecutor.java b/fe/src/main/java/org/apache/impala/hive/executor/UdfExecutor.java index 242c704..df48cb7 100644 --- a/fe/src/main/java/org/apache/impala/hive/executor/UdfExecutor.java +++ b/fe/src/main/java/org/apache/impala/hive/executor/UdfExecutor.java @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.hive.executor; +package org.apache.impala.hive.executor; import java.io.File; import java.lang.reflect.Constructor; @@ -40,14 +40,14 @@ import org.apache.hadoop.io.Writable; import org.apache.log4j.Logger; import org.apache.thrift.protocol.TBinaryProtocol; -import com.cloudera.impala.catalog.Type; -import com.cloudera.impala.catalog.PrimitiveType; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.ImpalaRuntimeException; -import com.cloudera.impala.common.JniUtil; -import com.cloudera.impala.thrift.THiveUdfExecutorCtorParams; -import com.cloudera.impala.thrift.TPrimitiveType; -import com.cloudera.impala.util.UnsafeUtil; +import org.apache.impala.catalog.Type; +import org.apache.impala.catalog.PrimitiveType; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.ImpalaRuntimeException; +import org.apache.impala.common.JniUtil; +import org.apache.impala.thrift.THiveUdfExecutorCtorParams; +import org.apache.impala.thrift.TPrimitiveType; +import org.apache.impala.util.UnsafeUtil; 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/AggregationNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/AggregationNode.java b/fe/src/main/java/org/apache/impala/planner/AggregationNode.java index f6bf8a0..57dbd8f 100644 --- a/fe/src/main/java/org/apache/impala/planner/AggregationNode.java +++ b/fe/src/main/java/org/apache/impala/planner/AggregationNode.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,18 +24,18 @@ import java.util.Set; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.AggregateInfo; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.FunctionCallExpr; -import com.cloudera.impala.analysis.SlotId; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.thrift.TAggregationNode; -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.TQueryOptions; +import org.apache.impala.analysis.AggregateInfo; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.FunctionCallExpr; +import org.apache.impala.analysis.SlotId; +import org.apache.impala.common.InternalException; +import org.apache.impala.thrift.TAggregationNode; +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.TQueryOptions; import com.google.common.base.Objects; 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/AnalyticEvalNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/AnalyticEvalNode.java b/fe/src/main/java/org/apache/impala/planner/AnalyticEvalNode.java index ccbdaa2..6e07e79 100644 --- a/fe/src/main/java/org/apache/impala/planner/AnalyticEvalNode.java +++ b/fe/src/main/java/org/apache/impala/planner/AnalyticEvalNode.java @@ -15,24 +15,24 @@ // 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.AnalyticWindow; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.ExprSubstitutionMap; -import com.cloudera.impala.analysis.OrderByElement; -import com.cloudera.impala.analysis.TupleDescriptor; -import com.cloudera.impala.thrift.TAnalyticNode; -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 org.apache.impala.analysis.AnalyticWindow; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.ExprSubstitutionMap; +import org.apache.impala.analysis.OrderByElement; +import org.apache.impala.analysis.TupleDescriptor; +import org.apache.impala.thrift.TAnalyticNode; +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 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/AnalyticPlanner.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/AnalyticPlanner.java b/fe/src/main/java/org/apache/impala/planner/AnalyticPlanner.java index c02096e..e44fc0b 100644 --- a/fe/src/main/java/org/apache/impala/planner/AnalyticPlanner.java +++ b/fe/src/main/java/org/apache/impala/planner/AnalyticPlanner.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,27 +24,27 @@ import java.util.List; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.AggregateInfoBase; -import com.cloudera.impala.analysis.AnalyticExpr; -import com.cloudera.impala.analysis.AnalyticInfo; -import com.cloudera.impala.analysis.AnalyticWindow; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.BinaryPredicate; -import com.cloudera.impala.analysis.BoolLiteral; -import com.cloudera.impala.analysis.CompoundPredicate; -import com.cloudera.impala.analysis.CompoundPredicate.Operator; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.ExprSubstitutionMap; -import com.cloudera.impala.analysis.IsNullPredicate; -import com.cloudera.impala.analysis.OrderByElement; -import com.cloudera.impala.analysis.SlotDescriptor; -import com.cloudera.impala.analysis.SlotRef; -import com.cloudera.impala.analysis.SortInfo; -import com.cloudera.impala.analysis.TupleDescriptor; -import com.cloudera.impala.analysis.TupleId; -import com.cloudera.impala.analysis.TupleIsNullPredicate; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.thrift.TPartitionType; +import org.apache.impala.analysis.AggregateInfoBase; +import org.apache.impala.analysis.AnalyticExpr; +import org.apache.impala.analysis.AnalyticInfo; +import org.apache.impala.analysis.AnalyticWindow; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.BinaryPredicate; +import org.apache.impala.analysis.BoolLiteral; +import org.apache.impala.analysis.CompoundPredicate; +import org.apache.impala.analysis.CompoundPredicate.Operator; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.ExprSubstitutionMap; +import org.apache.impala.analysis.IsNullPredicate; +import org.apache.impala.analysis.OrderByElement; +import org.apache.impala.analysis.SlotDescriptor; +import org.apache.impala.analysis.SlotRef; +import org.apache.impala.analysis.SortInfo; +import org.apache.impala.analysis.TupleDescriptor; +import org.apache.impala.analysis.TupleId; +import org.apache.impala.analysis.TupleIsNullPredicate; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.thrift.TPartitionType; 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/CohortId.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/CohortId.java b/fe/src/main/java/org/apache/impala/planner/CohortId.java index d58e5c4..f7c741d 100644 --- a/fe/src/main/java/org/apache/impala/planner/CohortId.java +++ b/fe/src/main/java/org/apache/impala/planner/CohortId.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 CohortId extends Id<CohortId> { // 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/DataPartition.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/DataPartition.java b/fe/src/main/java/org/apache/impala/planner/DataPartition.java index 3320c2b..f0f16fa 100644 --- a/fe/src/main/java/org/apache/impala/planner/DataPartition.java +++ b/fe/src/main/java/org/apache/impala/planner/DataPartition.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.analysis.ExprSubstitutionMap; -import com.cloudera.impala.thrift.TDataPartition; -import com.cloudera.impala.thrift.TPartitionType; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.ExprSubstitutionMap; +import org.apache.impala.thrift.TDataPartition; +import org.apache.impala.thrift.TPartitionType; 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/DataSink.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/DataSink.java b/fe/src/main/java/org/apache/impala/planner/DataSink.java index ff81b50..b1977f4 100644 --- a/fe/src/main/java/org/apache/impala/planner/DataSink.java +++ b/fe/src/main/java/org/apache/impala/planner/DataSink.java @@ -15,17 +15,17 @@ // 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.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.TDataSink; -import com.cloudera.impala.thrift.TExplainLevel; +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.TDataSink; +import org.apache.impala.thrift.TExplainLevel; /** * A DataSink describes the destination of a plan fragment's output rows. http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/DataSourceScanNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/DataSourceScanNode.java b/fe/src/main/java/org/apache/impala/planner/DataSourceScanNode.java index ab92605..1f5665f 100644 --- a/fe/src/main/java/org/apache/impala/planner/DataSourceScanNode.java +++ b/fe/src/main/java/org/apache/impala/planner/DataSourceScanNode.java @@ -15,47 +15,47 @@ // 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.BoolLiteral; -import com.cloudera.impala.analysis.CompoundPredicate; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.LiteralExpr; -import com.cloudera.impala.analysis.NumericLiteral; -import com.cloudera.impala.analysis.SlotRef; -import com.cloudera.impala.analysis.StringLiteral; -import com.cloudera.impala.analysis.TupleDescriptor; -import com.cloudera.impala.catalog.DataSource; -import com.cloudera.impala.catalog.DataSourceTable; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.extdatasource.ExternalDataSourceExecutor; -import com.cloudera.impala.extdatasource.thrift.TBinaryPredicate; -import com.cloudera.impala.extdatasource.thrift.TColumnDesc; -import com.cloudera.impala.extdatasource.thrift.TComparisonOp; -import com.cloudera.impala.extdatasource.thrift.TPrepareParams; -import com.cloudera.impala.extdatasource.thrift.TPrepareResult; -import com.cloudera.impala.service.FeSupport; -import com.cloudera.impala.thrift.TCacheJarResult; -import com.cloudera.impala.thrift.TColumnValue; -import com.cloudera.impala.thrift.TDataSourceScanNode; -import com.cloudera.impala.thrift.TErrorCode; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TNetworkAddress; -import com.cloudera.impala.thrift.TPlanNode; -import com.cloudera.impala.thrift.TPlanNodeType; -import com.cloudera.impala.thrift.TQueryOptions; -import com.cloudera.impala.thrift.TScanRange; -import com.cloudera.impala.thrift.TScanRangeLocation; -import com.cloudera.impala.thrift.TScanRangeLocations; -import com.cloudera.impala.thrift.TStatus; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.BinaryPredicate; +import org.apache.impala.analysis.BoolLiteral; +import org.apache.impala.analysis.CompoundPredicate; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.LiteralExpr; +import org.apache.impala.analysis.NumericLiteral; +import org.apache.impala.analysis.SlotRef; +import org.apache.impala.analysis.StringLiteral; +import org.apache.impala.analysis.TupleDescriptor; +import org.apache.impala.catalog.DataSource; +import org.apache.impala.catalog.DataSourceTable; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.InternalException; +import org.apache.impala.extdatasource.ExternalDataSourceExecutor; +import org.apache.impala.extdatasource.thrift.TBinaryPredicate; +import org.apache.impala.extdatasource.thrift.TColumnDesc; +import org.apache.impala.extdatasource.thrift.TComparisonOp; +import org.apache.impala.extdatasource.thrift.TPrepareParams; +import org.apache.impala.extdatasource.thrift.TPrepareResult; +import org.apache.impala.service.FeSupport; +import org.apache.impala.thrift.TCacheJarResult; +import org.apache.impala.thrift.TColumnValue; +import org.apache.impala.thrift.TDataSourceScanNode; +import org.apache.impala.thrift.TErrorCode; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TNetworkAddress; +import org.apache.impala.thrift.TPlanNode; +import org.apache.impala.thrift.TPlanNodeType; +import org.apache.impala.thrift.TQueryOptions; +import org.apache.impala.thrift.TScanRange; +import org.apache.impala.thrift.TScanRangeLocation; +import org.apache.impala.thrift.TScanRangeLocations; +import org.apache.impala.thrift.TStatus; 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/DataStreamSink.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/DataStreamSink.java b/fe/src/main/java/org/apache/impala/planner/DataStreamSink.java index 514a791..952215e 100644 --- a/fe/src/main/java/org/apache/impala/planner/DataStreamSink.java +++ b/fe/src/main/java/org/apache/impala/planner/DataStreamSink.java @@ -15,12 +15,12 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; -import com.cloudera.impala.thrift.TDataSink; -import com.cloudera.impala.thrift.TDataSinkType; -import com.cloudera.impala.thrift.TDataStreamSink; -import com.cloudera.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TDataSink; +import org.apache.impala.thrift.TDataSinkType; +import org.apache.impala.thrift.TDataStreamSink; +import org.apache.impala.thrift.TExplainLevel; 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/DistributedPlanner.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/DistributedPlanner.java b/fe/src/main/java/org/apache/impala/planner/DistributedPlanner.java index b38b018..620ea56 100644 --- a/fe/src/main/java/org/apache/impala/planner/DistributedPlanner.java +++ b/fe/src/main/java/org/apache/impala/planner/DistributedPlanner.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; @@ -23,17 +23,17 @@ import java.util.List; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.AggregateInfo; -import com.cloudera.impala.analysis.AnalysisContext; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.InsertStmt; -import com.cloudera.impala.analysis.JoinOperator; -import com.cloudera.impala.analysis.QueryStmt; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.planner.JoinNode.DistributionMode; -import com.cloudera.impala.planner.RuntimeFilterGenerator.RuntimeFilter; +import org.apache.impala.analysis.AggregateInfo; +import org.apache.impala.analysis.AnalysisContext; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.InsertStmt; +import org.apache.impala.analysis.JoinOperator; +import org.apache.impala.analysis.QueryStmt; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.InternalException; +import org.apache.impala.planner.JoinNode.DistributionMode; +import org.apache.impala.planner.RuntimeFilterGenerator.RuntimeFilter; 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/EmptySetNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/EmptySetNode.java b/fe/src/main/java/org/apache/impala/planner/EmptySetNode.java index ed9dc70..2b46bd9 100644 --- a/fe/src/main/java/org/apache/impala/planner/EmptySetNode.java +++ b/fe/src/main/java/org/apache/impala/planner/EmptySetNode.java @@ -15,15 +15,15 @@ // specific language governing permissions and limitations // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; import java.util.ArrayList; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.TupleId; -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.TupleId; +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/ExchangeNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/ExchangeNode.java b/fe/src/main/java/org/apache/impala/planner/ExchangeNode.java index eeef5fe..658aa76 100644 --- a/fe/src/main/java/org/apache/impala/planner/ExchangeNode.java +++ b/fe/src/main/java/org/apache/impala/planner/ExchangeNode.java @@ -15,21 +15,21 @@ // 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.Expr; -import com.cloudera.impala.analysis.SortInfo; -import com.cloudera.impala.analysis.TupleId; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.thrift.TExchangeNode; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TPlanNode; -import com.cloudera.impala.thrift.TPlanNodeType; -import com.cloudera.impala.thrift.TSortInfo; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.SortInfo; +import org.apache.impala.analysis.TupleId; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.thrift.TExchangeNode; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TPlanNode; +import org.apache.impala.thrift.TPlanNodeType; +import org.apache.impala.thrift.TSortInfo; 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/HBaseScanNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/HBaseScanNode.java b/fe/src/main/java/org/apache/impala/planner/HBaseScanNode.java index e31372d..f299131 100644 --- a/fe/src/main/java/org/apache/impala/planner/HBaseScanNode.java +++ b/fe/src/main/java/org/apache/impala/planner/HBaseScanNode.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.io.IOException; import java.nio.ByteBuffer; @@ -34,32 +34,32 @@ import org.apache.hadoop.hbase.util.Bytes; 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.SlotDescriptor; -import com.cloudera.impala.analysis.StringLiteral; -import com.cloudera.impala.analysis.TupleDescriptor; -import com.cloudera.impala.catalog.HBaseColumn; -import com.cloudera.impala.catalog.HBaseTable; -import com.cloudera.impala.catalog.PrimitiveType; -import com.cloudera.impala.catalog.Type; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.common.Pair; -import com.cloudera.impala.service.FeSupport; -import com.cloudera.impala.thrift.TColumnValue; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.THBaseFilter; -import com.cloudera.impala.thrift.THBaseKeyRange; -import com.cloudera.impala.thrift.THBaseScanNode; -import com.cloudera.impala.thrift.TNetworkAddress; -import com.cloudera.impala.thrift.TPlanNode; -import com.cloudera.impala.thrift.TPlanNodeType; -import com.cloudera.impala.thrift.TQueryOptions; -import com.cloudera.impala.thrift.TScanRange; -import com.cloudera.impala.thrift.TScanRangeLocation; -import com.cloudera.impala.thrift.TScanRangeLocations; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.BinaryPredicate; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.SlotDescriptor; +import org.apache.impala.analysis.StringLiteral; +import org.apache.impala.analysis.TupleDescriptor; +import org.apache.impala.catalog.HBaseColumn; +import org.apache.impala.catalog.HBaseTable; +import org.apache.impala.catalog.PrimitiveType; +import org.apache.impala.catalog.Type; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.InternalException; +import org.apache.impala.common.Pair; +import org.apache.impala.service.FeSupport; +import org.apache.impala.thrift.TColumnValue; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.THBaseFilter; +import org.apache.impala.thrift.THBaseKeyRange; +import org.apache.impala.thrift.THBaseScanNode; +import org.apache.impala.thrift.TNetworkAddress; +import org.apache.impala.thrift.TPlanNode; +import org.apache.impala.thrift.TPlanNodeType; +import org.apache.impala.thrift.TQueryOptions; +import org.apache.impala.thrift.TScanRange; +import org.apache.impala.thrift.TScanRangeLocation; +import org.apache.impala.thrift.TScanRangeLocations; import com.google.common.base.Objects; 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/HBaseTableSink.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/HBaseTableSink.java b/fe/src/main/java/org/apache/impala/planner/HBaseTableSink.java index 2a0d1b7..aa77529 100644 --- a/fe/src/main/java/org/apache/impala/planner/HBaseTableSink.java +++ b/fe/src/main/java/org/apache/impala/planner/HBaseTableSink.java @@ -16,15 +16,15 @@ // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; -import com.cloudera.impala.catalog.Table; -import com.cloudera.impala.common.PrintUtils; -import com.cloudera.impala.thrift.TDataSink; -import com.cloudera.impala.thrift.TDataSinkType; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TTableSink; -import com.cloudera.impala.thrift.TTableSinkType; +import org.apache.impala.catalog.Table; +import org.apache.impala.common.PrintUtils; +import org.apache.impala.thrift.TDataSink; +import org.apache.impala.thrift.TDataSinkType; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TTableSink; +import org.apache.impala.thrift.TTableSinkType; /** * Class used to represent a Sink that will transport http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/HashJoinNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/HashJoinNode.java b/fe/src/main/java/org/apache/impala/planner/HashJoinNode.java index 906f732..07cfe9f 100644 --- a/fe/src/main/java/org/apache/impala/planner/HashJoinNode.java +++ b/fe/src/main/java/org/apache/impala/planner/HashJoinNode.java @@ -15,28 +15,28 @@ // 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.ExprSubstitutionMap; -import com.cloudera.impala.analysis.JoinOperator; -import com.cloudera.impala.catalog.Type; -import com.cloudera.impala.common.AnalysisException; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.thrift.TEqJoinCondition; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.THashJoinNode; -import com.cloudera.impala.thrift.TPlanNode; -import com.cloudera.impala.thrift.TPlanNodeType; -import com.cloudera.impala.thrift.TQueryOptions; +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.JoinOperator; +import org.apache.impala.catalog.Type; +import org.apache.impala.common.AnalysisException; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.InternalException; +import org.apache.impala.thrift.TEqJoinCondition; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.THashJoinNode; +import org.apache.impala.thrift.TPlanNode; +import org.apache.impala.thrift.TPlanNodeType; +import org.apache.impala.thrift.TQueryOptions; import com.google.common.base.Objects; 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/HdfsPartitionFilter.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/HdfsPartitionFilter.java b/fe/src/main/java/org/apache/impala/planner/HdfsPartitionFilter.java index d1710aa..3345c1b 100644 --- a/fe/src/main/java/org/apache/impala/planner/HdfsPartitionFilter.java +++ b/fe/src/main/java/org/apache/impala/planner/HdfsPartitionFilter.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.HashMap; @@ -24,19 +24,19 @@ import java.util.HashSet; 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.SlotId; -import com.cloudera.impala.analysis.SlotRef; -import com.cloudera.impala.catalog.Column; -import com.cloudera.impala.catalog.HdfsPartition; -import com.cloudera.impala.catalog.HdfsTable; -import com.cloudera.impala.common.InternalException; -import com.cloudera.impala.service.FeSupport; -import com.cloudera.impala.thrift.TColumnValue; -import com.cloudera.impala.thrift.TResultRow; +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.SlotId; +import org.apache.impala.analysis.SlotRef; +import org.apache.impala.catalog.Column; +import org.apache.impala.catalog.HdfsPartition; +import org.apache.impala.catalog.HdfsTable; +import org.apache.impala.common.InternalException; +import org.apache.impala.service.FeSupport; +import org.apache.impala.thrift.TColumnValue; +import org.apache.impala.thrift.TResultRow; 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/planner/HdfsPartitionPruner.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/HdfsPartitionPruner.java b/fe/src/main/java/org/apache/impala/planner/HdfsPartitionPruner.java index 9606dc5..5efd474 100644 --- a/fe/src/main/java/org/apache/impala/planner/HdfsPartitionPruner.java +++ b/fe/src/main/java/org/apache/impala/planner/HdfsPartitionPruner.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.HashSet; @@ -29,24 +29,24 @@ import java.util.TreeMap; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.cloudera.impala.analysis.Analyzer; -import com.cloudera.impala.analysis.BetweenPredicate; -import com.cloudera.impala.analysis.BinaryPredicate; -import com.cloudera.impala.analysis.BinaryPredicate.Operator; -import com.cloudera.impala.analysis.CompoundPredicate; -import com.cloudera.impala.analysis.Expr; -import com.cloudera.impala.analysis.InPredicate; -import com.cloudera.impala.analysis.IsNullPredicate; -import com.cloudera.impala.analysis.LiteralExpr; -import com.cloudera.impala.analysis.NullLiteral; -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.catalog.HdfsPartition; -import com.cloudera.impala.catalog.HdfsTable; -import com.cloudera.impala.common.AnalysisException; -import com.cloudera.impala.common.InternalException; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.BetweenPredicate; +import org.apache.impala.analysis.BinaryPredicate; +import org.apache.impala.analysis.BinaryPredicate.Operator; +import org.apache.impala.analysis.CompoundPredicate; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.InPredicate; +import org.apache.impala.analysis.IsNullPredicate; +import org.apache.impala.analysis.LiteralExpr; +import org.apache.impala.analysis.NullLiteral; +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.catalog.HdfsPartition; +import org.apache.impala.catalog.HdfsTable; +import org.apache.impala.common.AnalysisException; +import org.apache.impala.common.InternalException; 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/HdfsScanNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/HdfsScanNode.java b/fe/src/main/java/org/apache/impala/planner/HdfsScanNode.java index 9b83902..4052867 100644 --- a/fe/src/main/java/org/apache/impala/planner/HdfsScanNode.java +++ b/fe/src/main/java/org/apache/impala/planner/HdfsScanNode.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.HashSet; @@ -25,36 +25,36 @@ import java.util.Map; 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.TableRef; -import com.cloudera.impala.analysis.TupleDescriptor; -import com.cloudera.impala.analysis.TupleId; -import com.cloudera.impala.catalog.Column; -import com.cloudera.impala.catalog.HdfsFileFormat; -import com.cloudera.impala.catalog.HdfsPartition; -import com.cloudera.impala.catalog.HdfsPartition.FileBlock; -import com.cloudera.impala.catalog.HdfsTable; -import com.cloudera.impala.catalog.Type; -import com.cloudera.impala.common.ImpalaException; -import com.cloudera.impala.common.NotImplementedException; -import com.cloudera.impala.common.PrintUtils; -import com.cloudera.impala.common.RuntimeEnv; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TExpr; -import com.cloudera.impala.thrift.THdfsFileBlock; -import com.cloudera.impala.thrift.THdfsFileSplit; -import com.cloudera.impala.thrift.THdfsScanNode; -import com.cloudera.impala.thrift.TNetworkAddress; -import com.cloudera.impala.thrift.TPlanNode; -import com.cloudera.impala.thrift.TPlanNodeType; -import com.cloudera.impala.thrift.TQueryOptions; -import com.cloudera.impala.thrift.TReplicaPreference; -import com.cloudera.impala.thrift.TScanRange; -import com.cloudera.impala.thrift.TScanRangeLocation; -import com.cloudera.impala.thrift.TScanRangeLocations; -import com.cloudera.impala.util.MembershipSnapshot; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.Expr; +import org.apache.impala.analysis.SlotDescriptor; +import org.apache.impala.analysis.TableRef; +import org.apache.impala.analysis.TupleDescriptor; +import org.apache.impala.analysis.TupleId; +import org.apache.impala.catalog.Column; +import org.apache.impala.catalog.HdfsFileFormat; +import org.apache.impala.catalog.HdfsPartition; +import org.apache.impala.catalog.HdfsPartition.FileBlock; +import org.apache.impala.catalog.HdfsTable; +import org.apache.impala.catalog.Type; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.common.NotImplementedException; +import org.apache.impala.common.PrintUtils; +import org.apache.impala.common.RuntimeEnv; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TExpr; +import org.apache.impala.thrift.THdfsFileBlock; +import org.apache.impala.thrift.THdfsFileSplit; +import org.apache.impala.thrift.THdfsScanNode; +import org.apache.impala.thrift.TNetworkAddress; +import org.apache.impala.thrift.TPlanNode; +import org.apache.impala.thrift.TPlanNodeType; +import org.apache.impala.thrift.TQueryOptions; +import org.apache.impala.thrift.TReplicaPreference; +import org.apache.impala.thrift.TScanRange; +import org.apache.impala.thrift.TScanRangeLocation; +import org.apache.impala.thrift.TScanRangeLocations; +import org.apache.impala.util.MembershipSnapshot; import com.google.common.base.Joiner; import com.google.common.base.Objects; import com.google.common.base.Objects.ToStringHelper; http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/b2c2fe78/fe/src/main/java/org/apache/impala/planner/HdfsTableSink.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/HdfsTableSink.java b/fe/src/main/java/org/apache/impala/planner/HdfsTableSink.java index 7b97773..3a217b9 100644 --- a/fe/src/main/java/org/apache/impala/planner/HdfsTableSink.java +++ b/fe/src/main/java/org/apache/impala/planner/HdfsTableSink.java @@ -15,21 +15,21 @@ // 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.Expr; -import com.cloudera.impala.catalog.HdfsFileFormat; -import com.cloudera.impala.catalog.HdfsTable; -import com.cloudera.impala.catalog.Table; -import com.cloudera.impala.common.PrintUtils; -import com.cloudera.impala.thrift.TDataSink; -import com.cloudera.impala.thrift.TDataSinkType; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.THdfsTableSink; -import com.cloudera.impala.thrift.TTableSink; -import com.cloudera.impala.thrift.TTableSinkType; +import org.apache.impala.analysis.Expr; +import org.apache.impala.catalog.HdfsFileFormat; +import org.apache.impala.catalog.HdfsTable; +import org.apache.impala.catalog.Table; +import org.apache.impala.common.PrintUtils; +import org.apache.impala.thrift.TDataSink; +import org.apache.impala.thrift.TDataSinkType; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.THdfsTableSink; +import org.apache.impala.thrift.TTableSink; +import org.apache.impala.thrift.TTableSinkType; 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/JoinBuildSink.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/JoinBuildSink.java b/fe/src/main/java/org/apache/impala/planner/JoinBuildSink.java index 25da277..e214fa6 100644 --- a/fe/src/main/java/org/apache/impala/planner/JoinBuildSink.java +++ b/fe/src/main/java/org/apache/impala/planner/JoinBuildSink.java @@ -15,24 +15,24 @@ // 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.common.ImpalaException; -import com.cloudera.impala.thrift.TDataSink; -import com.cloudera.impala.thrift.TDataSinkType; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TJoinBuildSink; -import com.cloudera.impala.thrift.TPlanNode; -import com.cloudera.impala.thrift.TPlanNodeType; -import com.cloudera.impala.thrift.TQueryOptions; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.BinaryPredicate; +import org.apache.impala.analysis.Expr; +import org.apache.impala.common.ImpalaException; +import org.apache.impala.thrift.TDataSink; +import org.apache.impala.thrift.TDataSinkType; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TJoinBuildSink; +import org.apache.impala.thrift.TPlanNode; +import org.apache.impala.thrift.TPlanNodeType; +import org.apache.impala.thrift.TQueryOptions; import com.google.common.base.Objects; 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/JoinNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/JoinNode.java b/fe/src/main/java/org/apache/impala/planner/JoinNode.java index ebc9b51..3362047 100644 --- a/fe/src/main/java/org/apache/impala/planner/JoinNode.java +++ b/fe/src/main/java/org/apache/impala/planner/JoinNode.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.List; @@ -23,15 +23,15 @@ 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.SlotDescriptor; -import com.cloudera.impala.analysis.SlotRef; -import com.cloudera.impala.catalog.ColumnStats; -import com.cloudera.impala.catalog.Table; -import com.cloudera.impala.common.ImpalaException; +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.SlotDescriptor; +import org.apache.impala.analysis.SlotRef; +import org.apache.impala.catalog.ColumnStats; +import org.apache.impala.catalog.Table; +import org.apache.impala.common.ImpalaException; 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/JoinTableId.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/JoinTableId.java b/fe/src/main/java/org/apache/impala/planner/JoinTableId.java index 5cf7a2b..5f96c90 100644 --- a/fe/src/main/java/org/apache/impala/planner/JoinTableId.java +++ b/fe/src/main/java/org/apache/impala/planner/JoinTableId.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 JoinTableId extends Id<JoinTableId> { // 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/KuduScanNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/KuduScanNode.java b/fe/src/main/java/org/apache/impala/planner/KuduScanNode.java index 4f654a9..a2473ae 100644 --- a/fe/src/main/java/org/apache/impala/planner/KuduScanNode.java +++ b/fe/src/main/java/org/apache/impala/planner/KuduScanNode.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.io.IOException; import java.util.List; @@ -34,27 +34,27 @@ import org.apache.kudu.client.LocatedTablet; 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.BoolLiteral; -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.SlotDescriptor; -import com.cloudera.impala.analysis.SlotRef; -import com.cloudera.impala.analysis.StringLiteral; -import com.cloudera.impala.analysis.TupleDescriptor; -import com.cloudera.impala.catalog.KuduTable; -import com.cloudera.impala.common.ImpalaRuntimeException; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TKuduScanNode; -import com.cloudera.impala.thrift.TNetworkAddress; -import com.cloudera.impala.thrift.TPlanNode; -import com.cloudera.impala.thrift.TPlanNodeType; -import com.cloudera.impala.thrift.TScanRange; -import com.cloudera.impala.thrift.TScanRangeLocation; -import com.cloudera.impala.thrift.TScanRangeLocations; +import org.apache.impala.analysis.Analyzer; +import org.apache.impala.analysis.BinaryPredicate; +import org.apache.impala.analysis.BoolLiteral; +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.SlotDescriptor; +import org.apache.impala.analysis.SlotRef; +import org.apache.impala.analysis.StringLiteral; +import org.apache.impala.analysis.TupleDescriptor; +import org.apache.impala.catalog.KuduTable; +import org.apache.impala.common.ImpalaRuntimeException; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TKuduScanNode; +import org.apache.impala.thrift.TNetworkAddress; +import org.apache.impala.thrift.TPlanNode; +import org.apache.impala.thrift.TPlanNodeType; +import org.apache.impala.thrift.TScanRange; +import org.apache.impala.thrift.TScanRangeLocation; +import org.apache.impala.thrift.TScanRangeLocations; import com.google.common.base.Charsets; import com.google.common.collect.Iterables; 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/KuduTableSink.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/KuduTableSink.java b/fe/src/main/java/org/apache/impala/planner/KuduTableSink.java index 8e8ac63..2fb9af7 100644 --- a/fe/src/main/java/org/apache/impala/planner/KuduTableSink.java +++ b/fe/src/main/java/org/apache/impala/planner/KuduTableSink.java @@ -16,19 +16,19 @@ // under the License. -package com.cloudera.impala.planner; +package org.apache.impala.planner; import java.util.ArrayList; import java.util.List; -import com.cloudera.impala.catalog.Table; -import com.cloudera.impala.common.PrintUtils; -import com.cloudera.impala.thrift.TDataSink; -import com.cloudera.impala.thrift.TDataSinkType; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TKuduTableSink; -import com.cloudera.impala.thrift.TTableSink; -import com.cloudera.impala.thrift.TTableSinkType; +import org.apache.impala.catalog.Table; +import org.apache.impala.common.PrintUtils; +import org.apache.impala.thrift.TDataSink; +import org.apache.impala.thrift.TDataSinkType; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TKuduTableSink; +import org.apache.impala.thrift.TTableSink; +import org.apache.impala.thrift.TTableSinkType; 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/NestedLoopJoinNode.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/planner/NestedLoopJoinNode.java b/fe/src/main/java/org/apache/impala/planner/NestedLoopJoinNode.java index e989438..cbaf370 100644 --- a/fe/src/main/java/org/apache/impala/planner/NestedLoopJoinNode.java +++ b/fe/src/main/java/org/apache/impala/planner/NestedLoopJoinNode.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.List; @@ -23,16 +23,16 @@ 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.common.ImpalaException; -import com.cloudera.impala.thrift.TExplainLevel; -import com.cloudera.impala.thrift.TNestedLoopJoinNode; -import com.cloudera.impala.thrift.TPlanNode; -import com.cloudera.impala.thrift.TPlanNodeType; -import com.cloudera.impala.thrift.TQueryOptions; +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.common.ImpalaException; +import org.apache.impala.thrift.TExplainLevel; +import org.apache.impala.thrift.TNestedLoopJoinNode; +import org.apache.impala.thrift.TPlanNode; +import org.apache.impala.thrift.TPlanNodeType; +import org.apache.impala.thrift.TQueryOptions; import com.google.common.base.Objects; import com.google.common.base.Preconditions;
