hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jd...@apache.org
Subject [29/50] [abbrv] hive git commit: HIVE-12730: MetadataUpdater: provide a mechanism to edit the basic statistics of a table (or a partition) (Pengcheng Xiong, reviewed by Ashutosh Chauhan)
Date Tue, 23 Feb 2016 19:17:28 GMT
http://git-wip-us.apache.org/repos/asf/hive/blob/78a85f82/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h b/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
index edcfa76..078c1cd 100644
--- a/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
+++ b/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
@@ -84,6 +84,7 @@ class ThriftHiveMetastoreIf : virtual public  ::facebook::fb303::FacebookService
   virtual void get_partitions_by_names(std::vector<Partition> & _return, const
std::string& db_name, const std::string& tbl_name, const std::vector<std::string>
& names) = 0;
   virtual void alter_partition(const std::string& db_name, const std::string& tbl_name,
const Partition& new_part) = 0;
   virtual void alter_partitions(const std::string& db_name, const std::string& tbl_name,
const std::vector<Partition> & new_parts) = 0;
+  virtual void alter_partitions_with_environment_context(const std::string& db_name,
const std::string& tbl_name, const std::vector<Partition> & new_parts, const
EnvironmentContext& environment_context) = 0;
   virtual void alter_partition_with_environment_context(const std::string& db_name, const
std::string& tbl_name, const Partition& new_part, const EnvironmentContext& environment_context)
= 0;
   virtual void rename_partition(const std::string& db_name, const std::string& tbl_name,
const std::vector<std::string> & part_vals, const Partition& new_part) = 0;
   virtual bool partition_name_has_valid_characters(const std::vector<std::string> &
part_vals, const bool throw_exception) = 0;
@@ -380,6 +381,9 @@ class ThriftHiveMetastoreNull : virtual public ThriftHiveMetastoreIf ,
virtual p
   void alter_partitions(const std::string& /* db_name */, const std::string& /* tbl_name
*/, const std::vector<Partition> & /* new_parts */) {
     return;
   }
+  void alter_partitions_with_environment_context(const std::string& /* db_name */, const
std::string& /* tbl_name */, const std::vector<Partition> & /* new_parts */,
const EnvironmentContext& /* environment_context */) {
+    return;
+  }
   void alter_partition_with_environment_context(const std::string& /* db_name */, const
std::string& /* tbl_name */, const Partition& /* new_part */, const EnvironmentContext&
/* environment_context */) {
     return;
   }
@@ -8822,6 +8826,139 @@ class ThriftHiveMetastore_alter_partitions_presult {
 
 };
 
+typedef struct _ThriftHiveMetastore_alter_partitions_with_environment_context_args__isset
{
+  _ThriftHiveMetastore_alter_partitions_with_environment_context_args__isset() : db_name(false),
tbl_name(false), new_parts(false), environment_context(false) {}
+  bool db_name :1;
+  bool tbl_name :1;
+  bool new_parts :1;
+  bool environment_context :1;
+} _ThriftHiveMetastore_alter_partitions_with_environment_context_args__isset;
+
+class ThriftHiveMetastore_alter_partitions_with_environment_context_args {
+ public:
+
+  ThriftHiveMetastore_alter_partitions_with_environment_context_args(const ThriftHiveMetastore_alter_partitions_with_environment_context_args&);
+  ThriftHiveMetastore_alter_partitions_with_environment_context_args& operator=(const
ThriftHiveMetastore_alter_partitions_with_environment_context_args&);
+  ThriftHiveMetastore_alter_partitions_with_environment_context_args() : db_name(), tbl_name()
{
+  }
+
+  virtual ~ThriftHiveMetastore_alter_partitions_with_environment_context_args() throw();
+  std::string db_name;
+  std::string tbl_name;
+  std::vector<Partition>  new_parts;
+  EnvironmentContext environment_context;
+
+  _ThriftHiveMetastore_alter_partitions_with_environment_context_args__isset __isset;
+
+  void __set_db_name(const std::string& val);
+
+  void __set_tbl_name(const std::string& val);
+
+  void __set_new_parts(const std::vector<Partition> & val);
+
+  void __set_environment_context(const EnvironmentContext& val);
+
+  bool operator == (const ThriftHiveMetastore_alter_partitions_with_environment_context_args
& rhs) const
+  {
+    if (!(db_name == rhs.db_name))
+      return false;
+    if (!(tbl_name == rhs.tbl_name))
+      return false;
+    if (!(new_parts == rhs.new_parts))
+      return false;
+    if (!(environment_context == rhs.environment_context))
+      return false;
+    return true;
+  }
+  bool operator != (const ThriftHiveMetastore_alter_partitions_with_environment_context_args
&rhs) const {
+    return !(*this == rhs);
+  }
+
+  bool operator < (const ThriftHiveMetastore_alter_partitions_with_environment_context_args
& ) const;
+
+  uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+  uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class ThriftHiveMetastore_alter_partitions_with_environment_context_pargs {
+ public:
+
+
+  virtual ~ThriftHiveMetastore_alter_partitions_with_environment_context_pargs() throw();
+  const std::string* db_name;
+  const std::string* tbl_name;
+  const std::vector<Partition> * new_parts;
+  const EnvironmentContext* environment_context;
+
+  uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_alter_partitions_with_environment_context_result__isset
{
+  _ThriftHiveMetastore_alter_partitions_with_environment_context_result__isset() : o1(false),
o2(false) {}
+  bool o1 :1;
+  bool o2 :1;
+} _ThriftHiveMetastore_alter_partitions_with_environment_context_result__isset;
+
+class ThriftHiveMetastore_alter_partitions_with_environment_context_result {
+ public:
+
+  ThriftHiveMetastore_alter_partitions_with_environment_context_result(const ThriftHiveMetastore_alter_partitions_with_environment_context_result&);
+  ThriftHiveMetastore_alter_partitions_with_environment_context_result& operator=(const
ThriftHiveMetastore_alter_partitions_with_environment_context_result&);
+  ThriftHiveMetastore_alter_partitions_with_environment_context_result() {
+  }
+
+  virtual ~ThriftHiveMetastore_alter_partitions_with_environment_context_result() throw();
+  InvalidOperationException o1;
+  MetaException o2;
+
+  _ThriftHiveMetastore_alter_partitions_with_environment_context_result__isset __isset;
+
+  void __set_o1(const InvalidOperationException& val);
+
+  void __set_o2(const MetaException& val);
+
+  bool operator == (const ThriftHiveMetastore_alter_partitions_with_environment_context_result
& rhs) const
+  {
+    if (!(o1 == rhs.o1))
+      return false;
+    if (!(o2 == rhs.o2))
+      return false;
+    return true;
+  }
+  bool operator != (const ThriftHiveMetastore_alter_partitions_with_environment_context_result
&rhs) const {
+    return !(*this == rhs);
+  }
+
+  bool operator < (const ThriftHiveMetastore_alter_partitions_with_environment_context_result
& ) const;
+
+  uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+  uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_alter_partitions_with_environment_context_presult__isset
{
+  _ThriftHiveMetastore_alter_partitions_with_environment_context_presult__isset() : o1(false),
o2(false) {}
+  bool o1 :1;
+  bool o2 :1;
+} _ThriftHiveMetastore_alter_partitions_with_environment_context_presult__isset;
+
+class ThriftHiveMetastore_alter_partitions_with_environment_context_presult {
+ public:
+
+
+  virtual ~ThriftHiveMetastore_alter_partitions_with_environment_context_presult() throw();
+  InvalidOperationException o1;
+  MetaException o2;
+
+  _ThriftHiveMetastore_alter_partitions_with_environment_context_presult__isset __isset;
+
+  uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
 typedef struct _ThriftHiveMetastore_alter_partition_with_environment_context_args__isset
{
   _ThriftHiveMetastore_alter_partition_with_environment_context_args__isset() : db_name(false),
tbl_name(false), new_part(false), environment_context(false) {}
   bool db_name :1;
@@ -17575,6 +17712,9 @@ class ThriftHiveMetastoreClient : virtual public ThriftHiveMetastoreIf,
public
   void alter_partitions(const std::string& db_name, const std::string& tbl_name,
const std::vector<Partition> & new_parts);
   void send_alter_partitions(const std::string& db_name, const std::string& tbl_name,
const std::vector<Partition> & new_parts);
   void recv_alter_partitions();
+  void alter_partitions_with_environment_context(const std::string& db_name, const std::string&
tbl_name, const std::vector<Partition> & new_parts, const EnvironmentContext&
environment_context);
+  void send_alter_partitions_with_environment_context(const std::string& db_name, const
std::string& tbl_name, const std::vector<Partition> & new_parts, const EnvironmentContext&
environment_context);
+  void recv_alter_partitions_with_environment_context();
   void alter_partition_with_environment_context(const std::string& db_name, const std::string&
tbl_name, const Partition& new_part, const EnvironmentContext& environment_context);
   void send_alter_partition_with_environment_context(const std::string& db_name, const
std::string& tbl_name, const Partition& new_part, const EnvironmentContext& environment_context);
   void recv_alter_partition_with_environment_context();
@@ -17863,6 +18003,7 @@ class ThriftHiveMetastoreProcessor : public  ::facebook::fb303::FacebookServiceP
   void process_get_partitions_by_names(int32_t seqid, ::apache::thrift::protocol::TProtocol*
iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
   void process_alter_partition(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot,
::apache::thrift::protocol::TProtocol* oprot, void* callContext);
   void process_alter_partitions(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot,
::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+  void process_alter_partitions_with_environment_context(int32_t seqid, ::apache::thrift::protocol::TProtocol*
iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
   void process_alter_partition_with_environment_context(int32_t seqid, ::apache::thrift::protocol::TProtocol*
iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
   void process_rename_partition(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot,
::apache::thrift::protocol::TProtocol* oprot, void* callContext);
   void process_partition_name_has_valid_characters(int32_t seqid, ::apache::thrift::protocol::TProtocol*
iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
@@ -18001,6 +18142,7 @@ class ThriftHiveMetastoreProcessor : public  ::facebook::fb303::FacebookServiceP
     processMap_["get_partitions_by_names"] = &ThriftHiveMetastoreProcessor::process_get_partitions_by_names;
     processMap_["alter_partition"] = &ThriftHiveMetastoreProcessor::process_alter_partition;
     processMap_["alter_partitions"] = &ThriftHiveMetastoreProcessor::process_alter_partitions;
+    processMap_["alter_partitions_with_environment_context"] = &ThriftHiveMetastoreProcessor::process_alter_partitions_with_environment_context;
     processMap_["alter_partition_with_environment_context"] = &ThriftHiveMetastoreProcessor::process_alter_partition_with_environment_context;
     processMap_["rename_partition"] = &ThriftHiveMetastoreProcessor::process_rename_partition;
     processMap_["partition_name_has_valid_characters"] = &ThriftHiveMetastoreProcessor::process_partition_name_has_valid_characters;
@@ -18704,6 +18846,15 @@ class ThriftHiveMetastoreMultiface : virtual public ThriftHiveMetastoreIf,
publi
     ifaces_[i]->alter_partitions(db_name, tbl_name, new_parts);
   }
 
+  void alter_partitions_with_environment_context(const std::string& db_name, const std::string&
tbl_name, const std::vector<Partition> & new_parts, const EnvironmentContext&
environment_context) {
+    size_t sz = ifaces_.size();
+    size_t i = 0;
+    for (; i < (sz - 1); ++i) {
+      ifaces_[i]->alter_partitions_with_environment_context(db_name, tbl_name, new_parts,
environment_context);
+    }
+    ifaces_[i]->alter_partitions_with_environment_context(db_name, tbl_name, new_parts,
environment_context);
+  }
+
   void alter_partition_with_environment_context(const std::string& db_name, const std::string&
tbl_name, const Partition& new_part, const EnvironmentContext& environment_context)
{
     size_t sz = ifaces_.size();
     size_t i = 0;
@@ -19596,6 +19747,9 @@ class ThriftHiveMetastoreConcurrentClient : virtual public ThriftHiveMetastoreIf
   void alter_partitions(const std::string& db_name, const std::string& tbl_name,
const std::vector<Partition> & new_parts);
   int32_t send_alter_partitions(const std::string& db_name, const std::string& tbl_name,
const std::vector<Partition> & new_parts);
   void recv_alter_partitions(const int32_t seqid);
+  void alter_partitions_with_environment_context(const std::string& db_name, const std::string&
tbl_name, const std::vector<Partition> & new_parts, const EnvironmentContext&
environment_context);
+  int32_t send_alter_partitions_with_environment_context(const std::string& db_name,
const std::string& tbl_name, const std::vector<Partition> & new_parts, const
EnvironmentContext& environment_context);
+  void recv_alter_partitions_with_environment_context(const int32_t seqid);
   void alter_partition_with_environment_context(const std::string& db_name, const std::string&
tbl_name, const Partition& new_part, const EnvironmentContext& environment_context);
   int32_t send_alter_partition_with_environment_context(const std::string& db_name, const
std::string& tbl_name, const Partition& new_part, const EnvironmentContext& environment_context);
   void recv_alter_partition_with_environment_context(const int32_t seqid);

http://git-wip-us.apache.org/repos/asf/hive/blob/78a85f82/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp b/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
index 6a75113..6e21a9a 100644
--- a/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
+++ b/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
@@ -332,6 +332,11 @@ class ThriftHiveMetastoreHandler : virtual public ThriftHiveMetastoreIf
{
     printf("alter_partitions\n");
   }
 
+  void alter_partitions_with_environment_context(const std::string& db_name, const std::string&
tbl_name, const std::vector<Partition> & new_parts, const EnvironmentContext&
environment_context) {
+    // Your implementation goes here
+    printf("alter_partitions_with_environment_context\n");
+  }
+
   void alter_partition_with_environment_context(const std::string& db_name, const std::string&
tbl_name, const Partition& new_part, const EnvironmentContext& environment_context)
{
     // Your implementation goes here
     printf("alter_partition_with_environment_context\n");

http://git-wip-us.apache.org/repos/asf/hive/blob/78a85f82/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetChangeVersionRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetChangeVersionRequest.java
b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetChangeVersionRequest.java
index 0215256..a410331 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetChangeVersionRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetChangeVersionRequest.java
@@ -110,7 +110,7 @@ public class GetChangeVersionRequest implements org.apache.thrift.TBase<GetChang
   public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
   static {
     Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields,
org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
-    tmpMap.put(_Fields.TOPIC, new org.apache.thrift.meta_data.FieldMetaData("topic", org.apache.thrift.TFieldRequirementType.REQUIRED,
+    tmpMap.put(_Fields.TOPIC, new org.apache.thrift.meta_data.FieldMetaData("topic", org.apache.thrift.TFieldRequirementType.REQUIRED,

         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
     metaDataMap = Collections.unmodifiableMap(tmpMap);
     org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetChangeVersionRequest.class,
metaDataMap);
@@ -327,7 +327,7 @@ public class GetChangeVersionRequest implements org.apache.thrift.TBase<GetChang
       while (true)
       {
         schemeField = iprot.readFieldBegin();
-        if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+        if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
           break;
         }
         switch (schemeField.id) {
@@ -335,7 +335,7 @@ public class GetChangeVersionRequest implements org.apache.thrift.TBase<GetChang
             if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
               struct.topic = iprot.readString();
               struct.setTopicIsSet(true);
-            } else {
+            } else { 
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
             }
             break;
@@ -386,3 +386,4 @@ public class GetChangeVersionRequest implements org.apache.thrift.TBase<GetChang
   }
 
 }
+

http://git-wip-us.apache.org/repos/asf/hive/blob/78a85f82/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetChangeVersionResult.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetChangeVersionResult.java
b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetChangeVersionResult.java
index 2b3f73d..7a2f74c 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetChangeVersionResult.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetChangeVersionResult.java
@@ -112,7 +112,7 @@ public class GetChangeVersionResult implements org.apache.thrift.TBase<GetChange
   public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
   static {
     Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields,
org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
-    tmpMap.put(_Fields.VERSION, new org.apache.thrift.meta_data.FieldMetaData("version",
org.apache.thrift.TFieldRequirementType.REQUIRED,
+    tmpMap.put(_Fields.VERSION, new org.apache.thrift.meta_data.FieldMetaData("version",
org.apache.thrift.TFieldRequirementType.REQUIRED, 
         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
     metaDataMap = Collections.unmodifiableMap(tmpMap);
     org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetChangeVersionResult.class,
metaDataMap);
@@ -327,7 +327,7 @@ public class GetChangeVersionResult implements org.apache.thrift.TBase<GetChange
       while (true)
       {
         schemeField = iprot.readFieldBegin();
-        if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+        if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
           break;
         }
         switch (schemeField.id) {
@@ -335,7 +335,7 @@ public class GetChangeVersionResult implements org.apache.thrift.TBase<GetChange
             if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
               struct.version = iprot.readI64();
               struct.setVersionIsSet(true);
-            } else {
+            } else { 
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
             }
             break;
@@ -384,3 +384,4 @@ public class GetChangeVersionResult implements org.apache.thrift.TBase<GetChange
   }
 
 }
+


Mime
View raw message