You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by el...@apache.org on 2016/04/20 00:42:10 UTC
[06/10] phoenix git commit: PHOENIX-2743 HivePhoenixHandler for
big-big join with predicate push down
http://git-wip-us.apache.org/repos/asf/phoenix/blob/f34c186a/phoenix-hive/src/main/java/org/apache/phoenix/hive/util/PhoenixUtil.java
----------------------------------------------------------------------
diff --git a/phoenix-hive/src/main/java/org/apache/phoenix/hive/util/PhoenixUtil.java b/phoenix-hive/src/main/java/org/apache/phoenix/hive/util/PhoenixUtil.java
new file mode 100644
index 0000000..5f9b0ba
--- /dev/null
+++ b/phoenix-hive/src/main/java/org/apache/phoenix/hive/util/PhoenixUtil.java
@@ -0,0 +1,208 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.phoenix.hive.util;
+
+import com.google.common.base.CharMatcher;
+import com.google.common.base.Splitter;
+import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.TableName;
+import org.apache.hadoop.hbase.client.HBaseAdmin;
+import org.apache.phoenix.coprocessor.MetaDataProtocol.MetaDataMutationResult;
+import org.apache.phoenix.hive.constants.PhoenixStorageHandlerConstants;
+import org.apache.phoenix.jdbc.PhoenixConnection;
+import org.apache.phoenix.schema.MetaDataClient;
+import org.apache.phoenix.schema.PTable;
+import org.apache.phoenix.schema.TableNotFoundException;
+import org.apache.phoenix.util.ColumnInfo;
+import org.apache.phoenix.util.PhoenixRuntime;
+
+import java.io.IOException;
+import java.sql.Connection;
+import java.sql.DatabaseMetaData;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.Properties;
+
+/**
+ * Misc utils
+ */
+public class PhoenixUtil {
+
+ private static final Log LOG = LogFactory.getLog(PhoenixUtil.class);
+
+ public static String getPhoenixType(String hiveTypeName) {
+ if (hiveTypeName.startsWith("array")) {
+ List<String> tokenList = Lists.newArrayList(Splitter.on(CharMatcher.is('<').or
+ (CharMatcher.is('>'))).split(hiveTypeName));
+ return getPhoenixType(tokenList.get(1)) + "[]";
+ } else if (hiveTypeName.startsWith("int")) {
+ return "integer";
+ } else if (hiveTypeName.equals("string")) {
+ return "varchar";
+ } else {
+ return hiveTypeName;
+ }
+ }
+
+ public static boolean existTable(Connection conn, String tableName) throws SQLException {
+ boolean exist = false;
+ DatabaseMetaData dbMeta = conn.getMetaData();
+
+ try (ResultSet rs = dbMeta.getTables(null, null, tableName.toUpperCase(), null)) {
+ exist = rs.next();
+
+ if (LOG.isDebugEnabled()) {
+ if (exist) {
+ LOG.debug(rs.getString("TABLE_NAME") + " table exist. ");
+ } else {
+ LOG.debug("table " + tableName + " doesn't exist.");
+ }
+ }
+ }
+
+ return exist;
+ }
+
+ public static List<String> getPrimaryKeyColumnList(Connection conn, String tableName) throws
+ SQLException {
+ Map<Short, String> primaryKeyColumnInfoMap = Maps.newHashMap();
+ DatabaseMetaData dbMeta = conn.getMetaData();
+
+ try (ResultSet rs = dbMeta.getPrimaryKeys(null, null, tableName.toUpperCase())) {
+ while (rs.next()) {
+ primaryKeyColumnInfoMap.put(rs.getShort("KEY_SEQ"), rs.getString("COLUMN_NAME"));
+ }
+
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("PK-columns : " + primaryKeyColumnInfoMap);
+ }
+ }
+
+ return Lists.newArrayList(primaryKeyColumnInfoMap.values());
+ }
+
+ public static List<String> getPrimaryKeyColumnList(Configuration config, String tableName) {
+ List<String> pkColumnNameList = null;
+
+ try (Connection conn = PhoenixConnectionUtil.getInputConnection(config, new Properties())) {
+ pkColumnNameList = getPrimaryKeyColumnList(conn, tableName);
+ } catch (SQLException e) {
+ throw new RuntimeException(e);
+ }
+
+ return pkColumnNameList;
+ }
+
+ public static void createTable(Connection conn, String createTableStatement) throws
+ SQLException {
+ conn.createStatement().execute(createTableStatement);
+ }
+
+ public static void dropTable(Connection conn, String tableName) throws SQLException {
+ conn.createStatement().execute("drop table " + tableName);
+ }
+
+ public static List<ColumnInfo> getColumnInfoList(Connection conn, String tableName) throws
+ SQLException {
+ List<ColumnInfo> columnInfoList = null;
+
+ try {
+ columnInfoList = PhoenixRuntime.generateColumnInfo(conn, tableName, null);
+ } catch (TableNotFoundException e) {
+ // Exception can be occurred when table create.
+ columnInfoList = Collections.emptyList();
+ }
+
+ return columnInfoList;
+ }
+
+ public static String[] getTableSchema(String tableName) {
+ String[] schemaInfo = new String[2];
+ String[] tokens = tableName.split("\\.");
+
+ if (tokens.length == 2) {
+ schemaInfo = tokens;
+ } else {
+ schemaInfo[1] = tokens[0];
+ }
+
+ return schemaInfo;
+ }
+
+ public static boolean isDisabledWal(MetaDataClient metaDataClient, String tableName) throws
+ SQLException {
+ String[] schemaInfo = getTableSchema(tableName.toUpperCase());
+ MetaDataMutationResult result = metaDataClient.updateCache(schemaInfo[0], schemaInfo[1]);
+ PTable dataTable = result.getTable();
+
+ return dataTable.isWALDisabled();
+ }
+
+ public static void alterTableForWalDisable(Connection conn, String tableName, boolean
+ disableMode) throws SQLException {
+ conn.createStatement().execute("alter table " + tableName + " set disable_wal=" +
+ disableMode);
+ }
+
+ public static void flush(Connection conn, String tableName) throws SQLException {
+ try (HBaseAdmin admin = ((PhoenixConnection) conn).getQueryServices().getAdmin()) {
+ admin.flush(TableName.valueOf(tableName));
+ } catch (IOException e) {
+ throw new SQLException(e);
+ }
+ }
+
+ public static String constructDeleteStatement(Connection conn, String tableName) throws
+ SQLException {
+ StringBuilder deleteQuery = new StringBuilder("delete from ").append(tableName).append(" " +
+ "where ");
+
+ List<String> primaryKeyColumnList = getPrimaryKeyColumnList(conn, tableName);
+ for (int i = 0, limit = primaryKeyColumnList.size(); i < limit; i++) {
+ String pkColumn = primaryKeyColumnList.get(i);
+ deleteQuery.append(pkColumn).append(PhoenixStorageHandlerConstants.EQUAL).append
+ (PhoenixStorageHandlerConstants.QUESTION);
+
+ if ((i + 1) != primaryKeyColumnList.size()) {
+ deleteQuery.append(" and ");
+ }
+ }
+
+ return deleteQuery.toString();
+ }
+
+ public static void closeResource(Statement stmt) throws SQLException {
+ if (stmt != null && !stmt.isClosed()) {
+ stmt.close();
+ }
+ }
+
+ public static void closeResource(Connection conn) throws SQLException {
+ if (conn != null && !conn.isClosed()) {
+ conn.close();
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/phoenix/blob/f34c186a/phoenix-server/pom.xml
----------------------------------------------------------------------
diff --git a/phoenix-server/pom.xml b/phoenix-server/pom.xml
index 19115a2..2b1ce72 100644
--- a/phoenix-server/pom.xml
+++ b/phoenix-server/pom.xml
@@ -102,6 +102,12 @@
<scope>test</scope>
</dependency>
<dependency>
+ <groupId>org.apache.hadoop</groupId>
+ <artifactId>hadoop-auth</artifactId>
+ <version>2.7.1</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
<groupId>org.apache.hbase</groupId>
<artifactId>hbase-testing-util</artifactId>
<scope>test</scope>
http://git-wip-us.apache.org/repos/asf/phoenix/blob/f34c186a/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 11e01d2..7fa62f5 100644
--- a/pom.xml
+++ b/pom.xml
@@ -30,6 +30,7 @@
<module>phoenix-server</module>
<module>phoenix-pherf</module>
<module>phoenix-spark</module>
+ <module>phoenix-hive</module>
<module>phoenix-assembly</module>
<module>phoenix-tracing-webapp</module>
</modules>
@@ -62,11 +63,12 @@
<!-- Hadoop Versions -->
<hbase.version>1.0.3</hbase.version>
- <hadoop-two.version>2.5.1</hadoop-two.version>
+ <hadoop-two.version>2.7.1</hadoop-two.version>
<!-- Dependency versions -->
<commons-cli.version>1.2</commons-cli.version>
- <hadoop.version>2.5.1</hadoop.version>
+ <hive.version>1.2.1</hive.version>
+ <hadoop.version>2.7.1</hadoop.version>
<pig.version>0.13.0</pig.version>
<jackson.version>1.9.2</jackson.version>
<antlr.version>3.5.2</antlr.version>
@@ -575,6 +577,39 @@
<scope>test</scope>
</dependency>
+ <!-- Required for mini-cluster since hbase built against old version of hadoop -->
+ <dependency>
+ <groupId>org.apache.hadoop</groupId>
+ <artifactId>hadoop-auth</artifactId>
+ <version>${hadoop-two.version}</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.hadoop</groupId>
+ <artifactId>hadoop-mapreduce-client-common</artifactId>
+ <version>${hadoop-two.version}</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.hadoop</groupId>
+ <artifactId>hadoop-mapreduce-client-jobclient</artifactId>
+ <version>${hadoop-two.version}</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.hadoop</groupId>
+ <artifactId>hadoop-hdfs</artifactId>
+ <version>${hadoop-two.version}</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.hadoop</groupId>
+ <artifactId>hadoop-hdfs</artifactId>
+ <version>${hadoop-two.version}</version>
+ <type>test-jar</type>
+ <scope>test</scope>
+ </dependency>
+
<!-- General Dependencies -->
<dependency>
<groupId>org.apache.pig</groupId>