hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From na...@apache.org
Subject svn commit: r1334053 [7/9] - in /hive/trunk: contrib/src/java/org/apache/hadoop/hive/metastore/hooks/ metastore/if/ metastore/src/gen/thrift/gen-cpp/ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ metastore/src/gen/thrift/g...
Date Fri, 04 May 2012 16:40:27 GMT
Modified: hive/trunk/metastore/src/gen/thrift/gen-php/hive_metastore/hive_metastore_types.php
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-php/hive_metastore/hive_metastore_types.php?rev=1334053&r1=1334052&r2=1334053&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-php/hive_metastore/hive_metastore_types.php (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-php/hive_metastore/hive_metastore_types.php Fri
May  4 16:40:25 2012
@@ -3309,6 +3309,112 @@ class Schema {
 
 }
 
+class EnvironmentContext {
+  static $_TSPEC;
+
+  public $properties = null;
+
+  public function __construct($vals=null) {
+    if (!isset(self::$_TSPEC)) {
+      self::$_TSPEC = array(
+        1 => array(
+          'var' => 'properties',
+          'type' => TType::MAP,
+          'ktype' => TType::STRING,
+          'vtype' => TType::STRING,
+          'key' => array(
+            'type' => TType::STRING,
+          ),
+          'val' => array(
+            'type' => TType::STRING,
+            ),
+          ),
+        );
+    }
+    if (is_array($vals)) {
+      if (isset($vals['properties'])) {
+        $this->properties = $vals['properties'];
+      }
+    }
+  }
+
+  public function getName() {
+    return 'EnvironmentContext';
+  }
+
+  public function read($input)
+  {
+    $xfer = 0;
+    $fname = null;
+    $ftype = 0;
+    $fid = 0;
+    $xfer += $input->readStructBegin($fname);
+    while (true)
+    {
+      $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+      if ($ftype == TType::STOP) {
+        break;
+      }
+      switch ($fid)
+      {
+        case 1:
+          if ($ftype == TType::MAP) {
+            $this->properties = array();
+            $_size174 = 0;
+            $_ktype175 = 0;
+            $_vtype176 = 0;
+            $xfer += $input->readMapBegin($_ktype175, $_vtype176, $_size174);
+            for ($_i178 = 0; $_i178 < $_size174; ++$_i178)
+            {
+              $key179 = '';
+              $val180 = '';
+              $xfer += $input->readString($key179);
+              $xfer += $input->readString($val180);
+              $this->properties[$key179] = $val180;
+            }
+            $xfer += $input->readMapEnd();
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        default:
+          $xfer += $input->skip($ftype);
+          break;
+      }
+      $xfer += $input->readFieldEnd();
+    }
+    $xfer += $input->readStructEnd();
+    return $xfer;
+  }
+
+  public function write($output) {
+    $xfer = 0;
+    $xfer += $output->writeStructBegin('EnvironmentContext');
+    if ($this->properties !== null) {
+      if (!is_array($this->properties)) {
+        throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+      }
+      $xfer += $output->writeFieldBegin('properties', TType::MAP, 1);
+      {
+        $output->writeMapBegin(TType::STRING, TType::STRING, count($this->properties));
+        {
+          foreach ($this->properties as $kiter181 => $viter182)
+          {
+            $xfer += $output->writeString($kiter181);
+            $xfer += $output->writeString($viter182);
+          }
+        }
+        $output->writeMapEnd();
+      }
+      $xfer += $output->writeFieldEnd();
+    }
+    $xfer += $output->writeFieldStop();
+    $xfer += $output->writeStructEnd();
+    return $xfer;
+  }
+
+}
+
 class MetaException extends TException {
   static $_TSPEC;
 

Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote?rev=1334053&r1=1334052&r2=1334053&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote Fri
May  4 16:40:25 2012
@@ -34,6 +34,7 @@ if len(sys.argv) <= 1 or sys.argv[1] == 
   print '   get_fields(string db_name, string table_name)'
   print '   get_schema(string db_name, string table_name)'
   print '  void create_table(Table tbl)'
+  print '  void create_table_with_environment_context(Table tbl, EnvironmentContext environment_context)'
   print '  void drop_table(string dbname, string name, bool deleteData)'
   print '   get_tables(string db_name, string pattern)'
   print '   get_all_tables(string db_name)'
@@ -41,7 +42,9 @@ if len(sys.argv) <= 1 or sys.argv[1] == 
   print '   get_table_objects_by_name(string dbname,  tbl_names)'
   print '   get_table_names_by_filter(string dbname, string filter, i16 max_tables)'
   print '  void alter_table(string dbname, string tbl_name, Table new_tbl)'
+  print '  void alter_table_with_environment_context(string dbname, string tbl_name, Table
new_tbl, EnvironmentContext environment_context)'
   print '  Partition add_partition(Partition new_part)'
+  print '  Partition add_partition_with_environment_context(Partition new_part, EnvironmentContext
environment_context)'
   print '  i32 add_partitions( new_parts)'
   print '  Partition append_partition(string db_name, string tbl_name,  part_vals)'
   print '  Partition append_partition_by_name(string db_name, string tbl_name, string part_name)'
@@ -59,6 +62,7 @@ if len(sys.argv) <= 1 or sys.argv[1] == 
   print '   get_partitions_by_filter(string db_name, string tbl_name, string filter, i16
max_parts)'
   print '   get_partitions_by_names(string db_name, string tbl_name,  names)'
   print '  void alter_partition(string db_name, string tbl_name, Partition new_part)'
+  print '  void alter_partition_with_environment_context(string db_name, string tbl_name,
Partition new_part, EnvironmentContext environment_context)'
   print '  void rename_partition(string db_name, string tbl_name,  part_vals, Partition new_part)'
   print '  string get_config_value(string name, string defaultValue)'
   print '   partition_name_to_vals(string part_name)'
@@ -213,6 +217,12 @@ elif cmd == 'create_table':
     sys.exit(1)
   pp.pprint(client.create_table(eval(args[0]),))
 
+elif cmd == 'create_table_with_environment_context':
+  if len(args) != 2:
+    print 'create_table_with_environment_context requires 2 args'
+    sys.exit(1)
+  pp.pprint(client.create_table_with_environment_context(eval(args[0]),eval(args[1]),))
+
 elif cmd == 'drop_table':
   if len(args) != 3:
     print 'drop_table requires 3 args'
@@ -255,12 +265,24 @@ elif cmd == 'alter_table':
     sys.exit(1)
   pp.pprint(client.alter_table(args[0],args[1],eval(args[2]),))
 
+elif cmd == 'alter_table_with_environment_context':
+  if len(args) != 4:
+    print 'alter_table_with_environment_context requires 4 args'
+    sys.exit(1)
+  pp.pprint(client.alter_table_with_environment_context(args[0],args[1],eval(args[2]),eval(args[3]),))
+
 elif cmd == 'add_partition':
   if len(args) != 1:
     print 'add_partition requires 1 args'
     sys.exit(1)
   pp.pprint(client.add_partition(eval(args[0]),))
 
+elif cmd == 'add_partition_with_environment_context':
+  if len(args) != 2:
+    print 'add_partition_with_environment_context requires 2 args'
+    sys.exit(1)
+  pp.pprint(client.add_partition_with_environment_context(eval(args[0]),eval(args[1]),))
+
 elif cmd == 'add_partitions':
   if len(args) != 1:
     print 'add_partitions requires 1 args'
@@ -363,6 +385,12 @@ elif cmd == 'alter_partition':
     sys.exit(1)
   pp.pprint(client.alter_partition(args[0],args[1],eval(args[2]),))
 
+elif cmd == 'alter_partition_with_environment_context':
+  if len(args) != 4:
+    print 'alter_partition_with_environment_context requires 4 args'
+    sys.exit(1)
+  pp.pprint(client.alter_partition_with_environment_context(args[0],args[1],eval(args[2]),eval(args[3]),))
+
 elif cmd == 'rename_partition':
   if len(args) != 4:
     print 'rename_partition requires 4 args'



Mime
View raw message