hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pa...@apache.org
Subject svn commit: r1151213 [3/6] - in /hive/trunk/metastore: if/ src/gen/thrift/gen-cpp/ src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ src/gen/thrift/gen-php/hive_metastore/ src/gen/thrift/gen-py/hive_metastore/ src/gen/thrift/gen-rb/ src...
Date Tue, 26 Jul 2011 19:02:55 GMT
Modified: hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h?rev=1151213&r1=1151212&r2=1151213&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h Tue Jul 26 19:02:50
2011
@@ -33,6 +33,7 @@ class ThriftHiveMetastoreIf : virtual pu
   virtual void get_all_tables(std::vector<std::string> & _return, const std::string&
db_name) = 0;
   virtual void get_table(Table& _return, const std::string& dbname, const std::string&
tbl_name) = 0;
   virtual void get_table_objects_by_name(std::vector<Table> & _return, const std::string&
dbname, const std::vector<std::string> & tbl_names) = 0;
+  virtual void get_table_names_by_filter(std::vector<std::string> & _return, const
std::string& dbname, const std::string& filter, const int16_t max_tables) = 0;
   virtual void alter_table(const std::string& dbname, const std::string& tbl_name,
const Table& new_tbl) = 0;
   virtual void add_partition(Partition& _return, const Partition& new_part) = 0;
   virtual int32_t add_partitions(const std::vector<Partition> & new_parts) = 0;
@@ -137,6 +138,9 @@ class ThriftHiveMetastoreNull : virtual 
   void get_table_objects_by_name(std::vector<Table> & /* _return */, const std::string&
/* dbname */, const std::vector<std::string> & /* tbl_names */) {
     return;
   }
+  void get_table_names_by_filter(std::vector<std::string> & /* _return */, const
std::string& /* dbname */, const std::string& /* filter */, const int16_t /* max_tables
*/) {
+    return;
+  }
   void alter_table(const std::string& /* dbname */, const std::string& /* tbl_name
*/, const Table& /* new_tbl */) {
     return;
   }
@@ -2324,6 +2328,134 @@ class ThriftHiveMetastore_get_table_obje
 
 };
 
+typedef struct _ThriftHiveMetastore_get_table_names_by_filter_args__isset {
+  _ThriftHiveMetastore_get_table_names_by_filter_args__isset() : dbname(false), filter(false),
max_tables(false) {}
+  bool dbname;
+  bool filter;
+  bool max_tables;
+} _ThriftHiveMetastore_get_table_names_by_filter_args__isset;
+
+class ThriftHiveMetastore_get_table_names_by_filter_args {
+ public:
+
+  ThriftHiveMetastore_get_table_names_by_filter_args() : dbname(""), filter(""), max_tables(-1)
{
+  }
+
+  virtual ~ThriftHiveMetastore_get_table_names_by_filter_args() throw() {}
+
+  std::string dbname;
+  std::string filter;
+  int16_t max_tables;
+
+  _ThriftHiveMetastore_get_table_names_by_filter_args__isset __isset;
+
+  bool operator == (const ThriftHiveMetastore_get_table_names_by_filter_args & rhs) const
+  {
+    if (!(dbname == rhs.dbname))
+      return false;
+    if (!(filter == rhs.filter))
+      return false;
+    if (!(max_tables == rhs.max_tables))
+      return false;
+    return true;
+  }
+  bool operator != (const ThriftHiveMetastore_get_table_names_by_filter_args &rhs) const
{
+    return !(*this == rhs);
+  }
+
+  bool operator < (const ThriftHiveMetastore_get_table_names_by_filter_args & ) const;
+
+  uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+  uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class ThriftHiveMetastore_get_table_names_by_filter_pargs {
+ public:
+
+
+  virtual ~ThriftHiveMetastore_get_table_names_by_filter_pargs() throw() {}
+
+  const std::string* dbname;
+  const std::string* filter;
+  const int16_t* max_tables;
+
+  uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_get_table_names_by_filter_result__isset {
+  _ThriftHiveMetastore_get_table_names_by_filter_result__isset() : success(false), o1(false),
o2(false), o3(false) {}
+  bool success;
+  bool o1;
+  bool o2;
+  bool o3;
+} _ThriftHiveMetastore_get_table_names_by_filter_result__isset;
+
+class ThriftHiveMetastore_get_table_names_by_filter_result {
+ public:
+
+  ThriftHiveMetastore_get_table_names_by_filter_result() {
+  }
+
+  virtual ~ThriftHiveMetastore_get_table_names_by_filter_result() throw() {}
+
+  std::vector<std::string>  success;
+  MetaException o1;
+  InvalidOperationException o2;
+  UnknownDBException o3;
+
+  _ThriftHiveMetastore_get_table_names_by_filter_result__isset __isset;
+
+  bool operator == (const ThriftHiveMetastore_get_table_names_by_filter_result & rhs)
const
+  {
+    if (!(success == rhs.success))
+      return false;
+    if (!(o1 == rhs.o1))
+      return false;
+    if (!(o2 == rhs.o2))
+      return false;
+    if (!(o3 == rhs.o3))
+      return false;
+    return true;
+  }
+  bool operator != (const ThriftHiveMetastore_get_table_names_by_filter_result &rhs)
const {
+    return !(*this == rhs);
+  }
+
+  bool operator < (const ThriftHiveMetastore_get_table_names_by_filter_result & )
const;
+
+  uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+  uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_get_table_names_by_filter_presult__isset {
+  _ThriftHiveMetastore_get_table_names_by_filter_presult__isset() : success(false), o1(false),
o2(false), o3(false) {}
+  bool success;
+  bool o1;
+  bool o2;
+  bool o3;
+} _ThriftHiveMetastore_get_table_names_by_filter_presult__isset;
+
+class ThriftHiveMetastore_get_table_names_by_filter_presult {
+ public:
+
+
+  virtual ~ThriftHiveMetastore_get_table_names_by_filter_presult() throw() {}
+
+  std::vector<std::string> * success;
+  MetaException o1;
+  InvalidOperationException o2;
+  UnknownDBException o3;
+
+  _ThriftHiveMetastore_get_table_names_by_filter_presult__isset __isset;
+
+  uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
 typedef struct _ThriftHiveMetastore_alter_table_args__isset {
   _ThriftHiveMetastore_alter_table_args__isset() : dbname(false), tbl_name(false), new_tbl(false)
{}
   bool dbname;
@@ -7519,6 +7651,9 @@ class ThriftHiveMetastoreClient : virtua
   void get_table_objects_by_name(std::vector<Table> & _return, const std::string&
dbname, const std::vector<std::string> & tbl_names);
   void send_get_table_objects_by_name(const std::string& dbname, const std::vector<std::string>
& tbl_names);
   void recv_get_table_objects_by_name(std::vector<Table> & _return);
+  void get_table_names_by_filter(std::vector<std::string> & _return, const std::string&
dbname, const std::string& filter, const int16_t max_tables);
+  void send_get_table_names_by_filter(const std::string& dbname, const std::string&
filter, const int16_t max_tables);
+  void recv_get_table_names_by_filter(std::vector<std::string> & _return);
   void alter_table(const std::string& dbname, const std::string& tbl_name, const
Table& new_tbl);
   void send_alter_table(const std::string& dbname, const std::string& tbl_name, const
Table& new_tbl);
   void recv_alter_table();
@@ -7674,6 +7809,7 @@ class ThriftHiveMetastoreProcessor : vir
   void process_get_all_tables(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot,
::apache::thrift::protocol::TProtocol* oprot);
   void process_get_table(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol*
oprot);
   void process_get_table_objects_by_name(int32_t seqid, ::apache::thrift::protocol::TProtocol*
iprot, ::apache::thrift::protocol::TProtocol* oprot);
+  void process_get_table_names_by_filter(int32_t seqid, ::apache::thrift::protocol::TProtocol*
iprot, ::apache::thrift::protocol::TProtocol* oprot);
   void process_alter_table(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol*
oprot);
   void process_add_partition(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot,
::apache::thrift::protocol::TProtocol* oprot);
   void process_add_partitions(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot,
::apache::thrift::protocol::TProtocol* oprot);
@@ -7739,6 +7875,7 @@ class ThriftHiveMetastoreProcessor : vir
     processMap_["get_all_tables"] = &ThriftHiveMetastoreProcessor::process_get_all_tables;
     processMap_["get_table"] = &ThriftHiveMetastoreProcessor::process_get_table;
     processMap_["get_table_objects_by_name"] = &ThriftHiveMetastoreProcessor::process_get_table_objects_by_name;
+    processMap_["get_table_names_by_filter"] = &ThriftHiveMetastoreProcessor::process_get_table_names_by_filter;
     processMap_["alter_table"] = &ThriftHiveMetastoreProcessor::process_alter_table;
     processMap_["add_partition"] = &ThriftHiveMetastoreProcessor::process_add_partition;
     processMap_["add_partitions"] = &ThriftHiveMetastoreProcessor::process_add_partitions;
@@ -7994,6 +8131,18 @@ class ThriftHiveMetastoreMultiface : vir
     }
   }
 
+  void get_table_names_by_filter(std::vector<std::string> & _return, const std::string&
dbname, const std::string& filter, const int16_t max_tables) {
+    uint32_t sz = ifaces_.size();
+    for (uint32_t i = 0; i < sz; ++i) {
+      if (i == sz - 1) {
+        ifaces_[i]->get_table_names_by_filter(_return, dbname, filter, max_tables);
+        return;
+      } else {
+        ifaces_[i]->get_table_names_by_filter(_return, dbname, filter, max_tables);
+      }
+    }
+  }
+
   void alter_table(const std::string& dbname, const std::string& tbl_name, const
Table& new_tbl) {
     uint32_t sz = ifaces_.size();
     for (uint32_t i = 0; i < sz; ++i) {

Modified: hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp?rev=1151213&r1=1151212&r2=1151213&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp Tue
Jul 26 19:02:50 2011
@@ -112,6 +112,11 @@ class ThriftHiveMetastoreHandler : virtu
     printf("get_table_objects_by_name\n");
   }
 
+  void get_table_names_by_filter(std::vector<std::string> & _return, const std::string&
dbname, const std::string& filter, const int16_t max_tables) {
+    // Your implementation goes here
+    printf("get_table_names_by_filter\n");
+  }
+
   void alter_table(const std::string& dbname, const std::string& tbl_name, const
Table& new_tbl) {
     // Your implementation goes here
     printf("alter_table\n");

Modified: hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_constants.cpp
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_constants.cpp?rev=1151213&r1=1151212&r2=1151213&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_constants.cpp (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_constants.cpp Tue Jul 26 19:02:50
2011
@@ -12,6 +12,12 @@ const hive_metastoreConstants g_hive_met
 hive_metastoreConstants::hive_metastoreConstants() {
   DDL_TIME = "transient_lastDdlTime";
 
+  HIVE_FILTER_FIELD_OWNER = "hive_filter_field_owner__";
+
+  HIVE_FILTER_FIELD_PARAMS = "hive_filter_field_params__";
+
+  HIVE_FILTER_FIELD_LAST_ACCESS = "hive_filter_field_last_access__";
+
   IS_ARCHIVED = "is_archived";
 
   ORIGINAL_LOCATION = "original_location";

Modified: hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_constants.h
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_constants.h?rev=1151213&r1=1151212&r2=1151213&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_constants.h (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_constants.h Tue Jul 26 19:02:50
2011
@@ -15,6 +15,9 @@ class hive_metastoreConstants {
   hive_metastoreConstants();
 
   std::string DDL_TIME;
+  std::string HIVE_FILTER_FIELD_OWNER;
+  std::string HIVE_FILTER_FIELD_PARAMS;
+  std::string HIVE_FILTER_FIELD_LAST_ACCESS;
   std::string IS_ARCHIVED;
   std::string ORIGINAL_LOCATION;
   std::string META_TABLE_COLUMNS;

Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Constants.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Constants.java?rev=1151213&r1=1151212&r2=1151213&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Constants.java
(original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Constants.java
Tue Jul 26 19:02:50 2011
@@ -24,6 +24,12 @@ public class Constants {
 
   public static final String DDL_TIME = "transient_lastDdlTime";
 
+  public static final String HIVE_FILTER_FIELD_OWNER = "hive_filter_field_owner__";
+
+  public static final String HIVE_FILTER_FIELD_PARAMS = "hive_filter_field_params__";
+
+  public static final String HIVE_FILTER_FIELD_LAST_ACCESS = "hive_filter_field_last_access__";
+
   public static final String IS_ARCHIVED = "is_archived";
 
   public static final String ORIGINAL_LOCATION = "original_location";



Mime
View raw message