hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ga...@apache.org
Subject svn commit: r1670993 - /hive/branches/hbase-metastore/metastore/src/java/org/apache/hadoop/hive/metastore/hbase/HBaseReadWrite.java
Date Thu, 02 Apr 2015 23:46:04 GMT
Author: gates
Date: Thu Apr  2 23:46:04 2015
New Revision: 1670993

URL: http://svn.apache.org/r1670993
Log:
HIVE-10205 A few lines accidentally removed from HBaseReadWrite (Alan Gates)

Modified:
    hive/branches/hbase-metastore/metastore/src/java/org/apache/hadoop/hive/metastore/hbase/HBaseReadWrite.java

Modified: hive/branches/hbase-metastore/metastore/src/java/org/apache/hadoop/hive/metastore/hbase/HBaseReadWrite.java
URL: http://svn.apache.org/viewvc/hive/branches/hbase-metastore/metastore/src/java/org/apache/hadoop/hive/metastore/hbase/HBaseReadWrite.java?rev=1670993&r1=1670992&r2=1670993&view=diff
==============================================================================
--- hive/branches/hbase-metastore/metastore/src/java/org/apache/hadoop/hive/metastore/hbase/HBaseReadWrite.java
(original)
+++ hive/branches/hbase-metastore/metastore/src/java/org/apache/hadoop/hive/metastore/hbase/HBaseReadWrite.java
Thu Apr  2 23:46:04 2015
@@ -1433,6 +1433,12 @@ class HBaseReadWrite {
     String hbaseTable = getStatisticsTable(partVals);
     byte[][] colnames = new byte[stats.getStatsObjSize()][];
     byte[][] serialized = new byte[stats.getStatsObjSize()][];
+    for (int i = 0; i < stats.getStatsObjSize(); i++) {
+      ColumnStatisticsObj obj = stats.getStatsObj().get(i);
+      serialized[i] = HBaseUtils.serializeStatsForOneColumn(stats, obj);
+      String colname = obj.getColName();
+      colnames[i] = HBaseUtils.buildKey(colname);
+    }
     store(hbaseTable, key, STATS_CF, colnames, serialized);
   }
 
@@ -1440,7 +1446,7 @@ class HBaseReadWrite {
    * Get statistics for a table
    *
    * @param dbName name of database table is in
-   * @param tableName name of table
+   * @param tblName name of table
    * @param colNames list of column names to get statistics for
    * @return column statistics for indicated table
    * @throws IOException
@@ -1477,7 +1483,7 @@ class HBaseReadWrite {
    * Get statistics for a set of partitions
    *
    * @param dbName name of database table is in
-   * @param tableName table partitions are in
+   * @param tblName table partitions are in
    * @param partNames names of the partitions, used only to set values inside the return
stats
    *          objects
    * @param partVals partition values for each partition, needed because this class doesn't
know how



Mime
View raw message