svn commit: r1574266 [16/23] - in /hive/trunk: common/src/java/org/apache/hadoop/hive/conf/ itests/hive-unit/src/test/java/org/apache/hadoop/hive/metastore/ metastore/ metastore/if/ metastore/scripts/upgrade/derby/ metastore/scripts/upgrade/mysql/ meta...

[ha...@apache.org]

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=1574266&r1=1574265&r2=1574266&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 Wed Mar  5 00:20:53 2014
@@ -115,6 +115,18 @@ if len(sys.argv) <= 1 or sys.argv[1] == 
   print '  string get_delegation_token(string token_owner, string renewer_kerberos_principal_name)'
   print '  i64 renew_delegation_token(string token_str_form)'
   print '  void cancel_delegation_token(string token_str_form)'
+  print '  GetOpenTxnsResponse get_open_txns()'
+  print '  GetOpenTxnsInfoResponse get_open_txns_info()'
+  print '  OpenTxnsResponse open_txns(OpenTxnRequest rqst)'
+  print '  void abort_txn(AbortTxnRequest rqst)'
+  print '  void commit_txn(CommitTxnRequest rqst)'
+  print '  LockResponse lock(LockRequest rqst)'
+  print '  LockResponse check_lock(CheckLockRequest rqst)'
+  print '  void unlock(UnlockRequest rqst)'
+  print '  ShowLocksResponse show_locks(ShowLocksRequest rqst)'
+  print '  void heartbeat(HeartbeatRequest ids)'
+  print '  void compact(CompactionRequest rqst)'
+  print '  ShowCompactResponse show_compact(ShowCompactRequest rqst)'
   print ''
   sys.exit(0)
 
@@ -718,6 +730,78 @@ elif cmd == 'cancel_delegation_token':
     sys.exit(1)
   pp.pprint(client.cancel_delegation_token(args[0],))
 
+elif cmd == 'get_open_txns':
+  if len(args) != 0:
+    print 'get_open_txns requires 0 args'
+    sys.exit(1)
+  pp.pprint(client.get_open_txns())
+
+elif cmd == 'get_open_txns_info':
+  if len(args) != 0:
+    print 'get_open_txns_info requires 0 args'
+    sys.exit(1)
+  pp.pprint(client.get_open_txns_info())
+
+elif cmd == 'open_txns':
+  if len(args) != 1:
+    print 'open_txns requires 1 args'
+    sys.exit(1)
+  pp.pprint(client.open_txns(eval(args[0]),))
+
+elif cmd == 'abort_txn':
+  if len(args) != 1:
+    print 'abort_txn requires 1 args'
+    sys.exit(1)
+  pp.pprint(client.abort_txn(eval(args[0]),))
+
+elif cmd == 'commit_txn':
+  if len(args) != 1:
+    print 'commit_txn requires 1 args'
+    sys.exit(1)
+  pp.pprint(client.commit_txn(eval(args[0]),))
+
+elif cmd == 'lock':
+  if len(args) != 1:
+    print 'lock requires 1 args'
+    sys.exit(1)
+  pp.pprint(client.lock(eval(args[0]),))
+
+elif cmd == 'check_lock':
+  if len(args) != 1:
+    print 'check_lock requires 1 args'
+    sys.exit(1)
+  pp.pprint(client.check_lock(eval(args[0]),))
+
+elif cmd == 'unlock':
+  if len(args) != 1:
+    print 'unlock requires 1 args'
+    sys.exit(1)
+  pp.pprint(client.unlock(eval(args[0]),))
+
+elif cmd == 'show_locks':
+  if len(args) != 1:
+    print 'show_locks requires 1 args'
+    sys.exit(1)
+  pp.pprint(client.show_locks(eval(args[0]),))
+
+elif cmd == 'heartbeat':
+  if len(args) != 1:
+    print 'heartbeat requires 1 args'
+    sys.exit(1)
+  pp.pprint(client.heartbeat(eval(args[0]),))
+
+elif cmd == 'compact':
+  if len(args) != 1:
+    print 'compact requires 1 args'
+    sys.exit(1)
+  pp.pprint(client.compact(eval(args[0]),))
+
+elif cmd == 'show_compact':
+  if len(args) != 1:
+    print 'show_compact requires 1 args'
+    sys.exit(1)
+  pp.pprint(client.show_compact(eval(args[0]),))
+
 else:
   print 'Unrecognized method %s' % cmd
   sys.exit(1)