hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xu...@apache.org
Subject svn commit: r1669775 [8/35] - in /hive/branches/spark: ./ ant/src/org/apache/hadoop/hive/ant/ beeline/src/java/org/apache/hive/beeline/ common/src/java/org/apache/hadoop/hive/common/ common/src/java/org/apache/hadoop/hive/common/type/ common/src/java/o...
Date Sat, 28 Mar 2015 14:03:49 GMT
Modified: hive/branches/spark/metastore/src/gen/thrift/gen-php/metastore/Types.php
URL: http://svn.apache.org/viewvc/hive/branches/spark/metastore/src/gen/thrift/gen-php/metastore/Types.php?rev=1669775&r1=1669774&r2=1669775&view=diff
==============================================================================
--- hive/branches/spark/metastore/src/gen/thrift/gen-php/metastore/Types.php (original)
+++ hive/branches/spark/metastore/src/gen/thrift/gen-php/metastore/Types.php Sat Mar 28 14:03:43
2015
@@ -11707,6 +11707,164 @@ class ShowCompactResponse {
 
 }
 
+class AddDynamicPartitions {
+  static $_TSPEC;
+
+  public $txnid = null;
+  public $dbname = null;
+  public $tablename = null;
+  public $partitionnames = null;
+
+  public function __construct($vals=null) {
+    if (!isset(self::$_TSPEC)) {
+      self::$_TSPEC = array(
+        1 => array(
+          'var' => 'txnid',
+          'type' => TType::I64,
+          ),
+        2 => array(
+          'var' => 'dbname',
+          'type' => TType::STRING,
+          ),
+        3 => array(
+          'var' => 'tablename',
+          'type' => TType::STRING,
+          ),
+        4 => array(
+          'var' => 'partitionnames',
+          'type' => TType::LST,
+          'etype' => TType::STRING,
+          'elem' => array(
+            'type' => TType::STRING,
+            ),
+          ),
+        );
+    }
+    if (is_array($vals)) {
+      if (isset($vals['txnid'])) {
+        $this->txnid = $vals['txnid'];
+      }
+      if (isset($vals['dbname'])) {
+        $this->dbname = $vals['dbname'];
+      }
+      if (isset($vals['tablename'])) {
+        $this->tablename = $vals['tablename'];
+      }
+      if (isset($vals['partitionnames'])) {
+        $this->partitionnames = $vals['partitionnames'];
+      }
+    }
+  }
+
+  public function getName() {
+    return 'AddDynamicPartitions';
+  }
+
+  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::I64) {
+            $xfer += $input->readI64($this->txnid);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 2:
+          if ($ftype == TType::STRING) {
+            $xfer += $input->readString($this->dbname);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 3:
+          if ($ftype == TType::STRING) {
+            $xfer += $input->readString($this->tablename);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 4:
+          if ($ftype == TType::LST) {
+            $this->partitionnames = array();
+            $_size437 = 0;
+            $_etype440 = 0;
+            $xfer += $input->readListBegin($_etype440, $_size437);
+            for ($_i441 = 0; $_i441 < $_size437; ++$_i441)
+            {
+              $elem442 = null;
+              $xfer += $input->readString($elem442);
+              $this->partitionnames []= $elem442;
+            }
+            $xfer += $input->readListEnd();
+          } 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('AddDynamicPartitions');
+    if ($this->txnid !== null) {
+      $xfer += $output->writeFieldBegin('txnid', TType::I64, 1);
+      $xfer += $output->writeI64($this->txnid);
+      $xfer += $output->writeFieldEnd();
+    }
+    if ($this->dbname !== null) {
+      $xfer += $output->writeFieldBegin('dbname', TType::STRING, 2);
+      $xfer += $output->writeString($this->dbname);
+      $xfer += $output->writeFieldEnd();
+    }
+    if ($this->tablename !== null) {
+      $xfer += $output->writeFieldBegin('tablename', TType::STRING, 3);
+      $xfer += $output->writeString($this->tablename);
+      $xfer += $output->writeFieldEnd();
+    }
+    if ($this->partitionnames !== null) {
+      if (!is_array($this->partitionnames)) {
+        throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+      }
+      $xfer += $output->writeFieldBegin('partitionnames', TType::LST, 4);
+      {
+        $output->writeListBegin(TType::STRING, count($this->partitionnames));
+        {
+          foreach ($this->partitionnames as $iter443)
+          {
+            $xfer += $output->writeString($iter443);
+          }
+        }
+        $output->writeListEnd();
+      }
+      $xfer += $output->writeFieldEnd();
+    }
+    $xfer += $output->writeFieldStop();
+    $xfer += $output->writeStructEnd();
+    return $xfer;
+  }
+
+}
+
 class NotificationEventRequest {
   static $_TSPEC;
 
@@ -12019,15 +12177,15 @@ class NotificationEventResponse {
         case 1:
           if ($ftype == TType::LST) {
             $this->events = array();
-            $_size437 = 0;
-            $_etype440 = 0;
-            $xfer += $input->readListBegin($_etype440, $_size437);
-            for ($_i441 = 0; $_i441 < $_size437; ++$_i441)
+            $_size444 = 0;
+            $_etype447 = 0;
+            $xfer += $input->readListBegin($_etype447, $_size444);
+            for ($_i448 = 0; $_i448 < $_size444; ++$_i448)
             {
-              $elem442 = null;
-              $elem442 = new \metastore\NotificationEvent();
-              $xfer += $elem442->read($input);
-              $this->events []= $elem442;
+              $elem449 = null;
+              $elem449 = new \metastore\NotificationEvent();
+              $xfer += $elem449->read($input);
+              $this->events []= $elem449;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -12055,9 +12213,9 @@ class NotificationEventResponse {
       {
         $output->writeListBegin(TType::STRUCT, count($this->events));
         {
-          foreach ($this->events as $iter443)
+          foreach ($this->events as $iter450)
           {
-            $xfer += $iter443->write($output);
+            $xfer += $iter450->write($output);
           }
         }
         $output->writeListEnd();
@@ -12190,14 +12348,14 @@ class InsertEventRequestData {
         case 1:
           if ($ftype == TType::LST) {
             $this->filesAdded = array();
-            $_size444 = 0;
-            $_etype447 = 0;
-            $xfer += $input->readListBegin($_etype447, $_size444);
-            for ($_i448 = 0; $_i448 < $_size444; ++$_i448)
+            $_size451 = 0;
+            $_etype454 = 0;
+            $xfer += $input->readListBegin($_etype454, $_size451);
+            for ($_i455 = 0; $_i455 < $_size451; ++$_i455)
             {
-              $elem449 = null;
-              $xfer += $input->readString($elem449);
-              $this->filesAdded []= $elem449;
+              $elem456 = null;
+              $xfer += $input->readString($elem456);
+              $this->filesAdded []= $elem456;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -12225,9 +12383,9 @@ class InsertEventRequestData {
       {
         $output->writeListBegin(TType::STRING, count($this->filesAdded));
         {
-          foreach ($this->filesAdded as $iter450)
+          foreach ($this->filesAdded as $iter457)
           {
-            $xfer += $output->writeString($iter450);
+            $xfer += $output->writeString($iter457);
           }
         }
         $output->writeListEnd();
@@ -12427,14 +12585,14 @@ class FireEventRequest {
         case 5:
           if ($ftype == TType::LST) {
             $this->partitionVals = array();
-            $_size451 = 0;
-            $_etype454 = 0;
-            $xfer += $input->readListBegin($_etype454, $_size451);
-            for ($_i455 = 0; $_i455 < $_size451; ++$_i455)
+            $_size458 = 0;
+            $_etype461 = 0;
+            $xfer += $input->readListBegin($_etype461, $_size458);
+            for ($_i462 = 0; $_i462 < $_size458; ++$_i462)
             {
-              $elem456 = null;
-              $xfer += $input->readString($elem456);
-              $this->partitionVals []= $elem456;
+              $elem463 = null;
+              $xfer += $input->readString($elem463);
+              $this->partitionVals []= $elem463;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -12485,9 +12643,9 @@ class FireEventRequest {
       {
         $output->writeListBegin(TType::STRING, count($this->partitionVals));
         {
-          foreach ($this->partitionVals as $iter457)
+          foreach ($this->partitionVals as $iter464)
           {
-            $xfer += $output->writeString($iter457);
+            $xfer += $output->writeString($iter464);
           }
         }
         $output->writeListEnd();

Modified: hive/branches/spark/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
URL: http://svn.apache.org/viewvc/hive/branches/spark/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote?rev=1669775&r1=1669774&r2=1669775&view=diff
==============================================================================
--- hive/branches/spark/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
(original)
+++ hive/branches/spark/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
Sat Mar 28 14:03:43 2015
@@ -36,7 +36,9 @@ if len(sys.argv) <= 1 or sys.argv[1] ==
   print '  bool drop_type(string type)'
   print '   get_type_all(string name)'
   print '   get_fields(string db_name, string table_name)'
+  print '   get_fields_with_environment_context(string db_name, string table_name, EnvironmentContext
environment_context)'
   print '   get_schema(string db_name, string table_name)'
+  print '   get_schema_with_environment_context(string db_name, string table_name, EnvironmentContext
environment_context)'
   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)'
@@ -140,6 +142,7 @@ if len(sys.argv) <= 1 or sys.argv[1] ==
   print '  HeartbeatTxnRangeResponse heartbeat_txn_range(HeartbeatTxnRangeRequest txns)'
   print '  void compact(CompactionRequest rqst)'
   print '  ShowCompactResponse show_compact(ShowCompactRequest rqst)'
+  print '  void add_dynamic_partitions(AddDynamicPartitions rqst)'
   print '  NotificationEventResponse get_next_notification(NotificationEventRequest rqst)'
   print '  CurrentNotificationEventId get_current_notificationEventId()'
   print '  FireEventResponse fire_listener_event(FireEventRequest rqst)'
@@ -272,12 +275,24 @@ elif cmd == 'get_fields':
     sys.exit(1)
   pp.pprint(client.get_fields(args[0],args[1],))
 
+elif cmd == 'get_fields_with_environment_context':
+  if len(args) != 3:
+    print 'get_fields_with_environment_context requires 3 args'
+    sys.exit(1)
+  pp.pprint(client.get_fields_with_environment_context(args[0],args[1],eval(args[2]),))
+
 elif cmd == 'get_schema':
   if len(args) != 2:
     print 'get_schema requires 2 args'
     sys.exit(1)
   pp.pprint(client.get_schema(args[0],args[1],))
 
+elif cmd == 'get_schema_with_environment_context':
+  if len(args) != 3:
+    print 'get_schema_with_environment_context requires 3 args'
+    sys.exit(1)
+  pp.pprint(client.get_schema_with_environment_context(args[0],args[1],eval(args[2]),))
+
 elif cmd == 'create_table':
   if len(args) != 1:
     print 'create_table requires 1 args'
@@ -896,6 +911,12 @@ elif cmd == 'show_compact':
     sys.exit(1)
   pp.pprint(client.show_compact(eval(args[0]),))
 
+elif cmd == 'add_dynamic_partitions':
+  if len(args) != 1:
+    print 'add_dynamic_partitions requires 1 args'
+    sys.exit(1)
+  pp.pprint(client.add_dynamic_partitions(eval(args[0]),))
+
 elif cmd == 'get_next_notification':
   if len(args) != 1:
     print 'get_next_notification requires 1 args'



Mime
View raw message