You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by dh...@apache.org on 2008/09/16 00:55:43 UTC
svn commit: r695679 [2/6] - in /hadoop/core/trunk: ./ src/contrib/hive/
src/contrib/hive/conf/ src/contrib/hive/metastore/if/
src/contrib/hive/metastore/src/gen-py/hive_metastore/
src/contrib/hive/metastore/src/java/org/apache/hadoop/hive/metastore/
Modified: hadoop/core/trunk/src/contrib/hive/metastore/src/gen-py/hive_metastore/ThriftHiveMetaStore.py
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hive/metastore/src/gen-py/hive_metastore/ThriftHiveMetaStore.py?rev=695679&r1=695678&r2=695679&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hive/metastore/src/gen-py/hive_metastore/ThriftHiveMetaStore.py (original)
+++ hadoop/core/trunk/src/contrib/hive/metastore/src/gen-py/hive_metastore/ThriftHiveMetaStore.py Mon Sep 15 15:55:43 2008
@@ -1,3113 +0,0 @@
-#
-# Autogenerated by Thrift
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-
-from thrift.Thrift import *
-import fb303.FacebookService
-from ttypes import *
-from thrift.Thrift import TProcessor
-from thrift.transport import TTransport
-from thrift.protocol import TBinaryProtocol
-try:
- from thrift.protocol import fastbinary
-except:
- fastbinary = None
-
-
-class Iface(fb303.FacebookService.Iface):
- def get_tables(self, pattern):
- pass
-
- def get_schema(self, table_name):
- pass
-
- def get_fields(self, table_name):
- pass
-
- def get_partition_cols(self, table_name):
- pass
-
- def save_table(self, table_name, schema, overwrite):
- pass
-
- def cat(self, table_name, high, partition):
- pass
-
- def drop(self, table_name, delete_data):
- pass
-
- def rename(self, current_table_name, new_table_name, move_data):
- pass
-
- def schema_exists(self, table_name):
- pass
-
- def exists(self, table_name):
- pass
-
- def alter_table(self, table_name, columns):
- pass
-
- def create_table(self, table_name, columns, partition_cols):
- pass
-
- def get_partitions(self, table_name):
- pass
-
- def write_log(self, table_name, logName, new_entry):
- pass
-
- def read_log(self, table_name, logName):
- pass
-
- def get_log_names(self, table_name):
- pass
-
-
-class Client(fb303.FacebookService.Client, Iface):
- def __init__(self, iprot, oprot=None):
- fb303.FacebookService.Client.__init__(self, iprot, oprot)
-
- def get_tables(self, pattern):
- self.send_get_tables(pattern)
- return self.recv_get_tables()
-
- def send_get_tables(self, pattern):
- self._oprot.writeMessageBegin('get_tables', TMessageType.CALL, self._seqid)
- args = get_tables_args()
- args.pattern = pattern
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_get_tables(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = get_tables_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success != None:
- return result.success
- if result.ouch != None:
- raise result.ouch
- if result.ouch2 != None:
- raise result.ouch2
- raise TApplicationException(TApplicationException.MISSING_RESULT, "get_tables failed: unknown result");
-
- def get_schema(self, table_name):
- self.send_get_schema(table_name)
- return self.recv_get_schema()
-
- def send_get_schema(self, table_name):
- self._oprot.writeMessageBegin('get_schema', TMessageType.CALL, self._seqid)
- args = get_schema_args()
- args.table_name = table_name
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_get_schema(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = get_schema_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success != None:
- return result.success
- if result.ouch != None:
- raise result.ouch
- if result.ouch2 != None:
- raise result.ouch2
- raise TApplicationException(TApplicationException.MISSING_RESULT, "get_schema failed: unknown result");
-
- def get_fields(self, table_name):
- self.send_get_fields(table_name)
- return self.recv_get_fields()
-
- def send_get_fields(self, table_name):
- self._oprot.writeMessageBegin('get_fields', TMessageType.CALL, self._seqid)
- args = get_fields_args()
- args.table_name = table_name
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_get_fields(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = get_fields_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success != None:
- return result.success
- if result.ouch != None:
- raise result.ouch
- if result.out2 != None:
- raise result.out2
- raise TApplicationException(TApplicationException.MISSING_RESULT, "get_fields failed: unknown result");
-
- def get_partition_cols(self, table_name):
- self.send_get_partition_cols(table_name)
- return self.recv_get_partition_cols()
-
- def send_get_partition_cols(self, table_name):
- self._oprot.writeMessageBegin('get_partition_cols', TMessageType.CALL, self._seqid)
- args = get_partition_cols_args()
- args.table_name = table_name
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_get_partition_cols(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = get_partition_cols_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success != None:
- return result.success
- if result.ouch != None:
- raise result.ouch
- if result.out2 != None:
- raise result.out2
- raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_cols failed: unknown result");
-
- def save_table(self, table_name, schema, overwrite):
- self.send_save_table(table_name, schema, overwrite)
- self.recv_save_table()
-
- def send_save_table(self, table_name, schema, overwrite):
- self._oprot.writeMessageBegin('save_table', TMessageType.CALL, self._seqid)
- args = save_table_args()
- args.table_name = table_name
- args.schema = schema
- args.overwrite = overwrite
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_save_table(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = save_table_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.ouch != None:
- raise result.ouch
- return
-
- def cat(self, table_name, high, partition):
- self.send_cat(table_name, high, partition)
- return self.recv_cat()
-
- def send_cat(self, table_name, high, partition):
- self._oprot.writeMessageBegin('cat', TMessageType.CALL, self._seqid)
- args = cat_args()
- args.table_name = table_name
- args.high = high
- args.partition = partition
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_cat(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = cat_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success != None:
- return result.success
- if result.ouch != None:
- raise result.ouch
- if result.ouch2 != None:
- raise result.ouch2
- raise TApplicationException(TApplicationException.MISSING_RESULT, "cat failed: unknown result");
-
- def drop(self, table_name, delete_data):
- self.send_drop(table_name, delete_data)
- self.recv_drop()
-
- def send_drop(self, table_name, delete_data):
- self._oprot.writeMessageBegin('drop', TMessageType.CALL, self._seqid)
- args = drop_args()
- args.table_name = table_name
- args.delete_data = delete_data
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_drop(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = drop_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.ouch != None:
- raise result.ouch
- if result.ouch2 != None:
- raise result.ouch2
- return
-
- def rename(self, current_table_name, new_table_name, move_data):
- self.send_rename(current_table_name, new_table_name, move_data)
- self.recv_rename()
-
- def send_rename(self, current_table_name, new_table_name, move_data):
- self._oprot.writeMessageBegin('rename', TMessageType.CALL, self._seqid)
- args = rename_args()
- args.current_table_name = current_table_name
- args.new_table_name = new_table_name
- args.move_data = move_data
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_rename(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = rename_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.ouch != None:
- raise result.ouch
- if result.ouch2 != None:
- raise result.ouch2
- return
-
- def schema_exists(self, table_name):
- self.send_schema_exists(table_name)
- return self.recv_schema_exists()
-
- def send_schema_exists(self, table_name):
- self._oprot.writeMessageBegin('schema_exists', TMessageType.CALL, self._seqid)
- args = schema_exists_args()
- args.table_name = table_name
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_schema_exists(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = schema_exists_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success != None:
- return result.success
- if result.ouch != None:
- raise result.ouch
- raise TApplicationException(TApplicationException.MISSING_RESULT, "schema_exists failed: unknown result");
-
- def exists(self, table_name):
- self.send_exists(table_name)
- return self.recv_exists()
-
- def send_exists(self, table_name):
- self._oprot.writeMessageBegin('exists', TMessageType.CALL, self._seqid)
- args = exists_args()
- args.table_name = table_name
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_exists(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = exists_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success != None:
- return result.success
- if result.ouch != None:
- raise result.ouch
- raise TApplicationException(TApplicationException.MISSING_RESULT, "exists failed: unknown result");
-
- def alter_table(self, table_name, columns):
- self.send_alter_table(table_name, columns)
- self.recv_alter_table()
-
- def send_alter_table(self, table_name, columns):
- self._oprot.writeMessageBegin('alter_table', TMessageType.CALL, self._seqid)
- args = alter_table_args()
- args.table_name = table_name
- args.columns = columns
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_alter_table(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = alter_table_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.ouch != None:
- raise result.ouch
- if result.ouch2 != None:
- raise result.ouch2
- return
-
- def create_table(self, table_name, columns, partition_cols):
- self.send_create_table(table_name, columns, partition_cols)
- self.recv_create_table()
-
- def send_create_table(self, table_name, columns, partition_cols):
- self._oprot.writeMessageBegin('create_table', TMessageType.CALL, self._seqid)
- args = create_table_args()
- args.table_name = table_name
- args.columns = columns
- args.partition_cols = partition_cols
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_create_table(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = create_table_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.ouch != None:
- raise result.ouch
- return
-
- def get_partitions(self, table_name):
- self.send_get_partitions(table_name)
- return self.recv_get_partitions()
-
- def send_get_partitions(self, table_name):
- self._oprot.writeMessageBegin('get_partitions', TMessageType.CALL, self._seqid)
- args = get_partitions_args()
- args.table_name = table_name
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_get_partitions(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = get_partitions_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success != None:
- return result.success
- if result.ouch != None:
- raise result.ouch
- if result.ouch2 != None:
- raise result.ouch2
- raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions failed: unknown result");
-
- def write_log(self, table_name, logName, new_entry):
- self.send_write_log(table_name, logName, new_entry)
- self.recv_write_log()
-
- def send_write_log(self, table_name, logName, new_entry):
- self._oprot.writeMessageBegin('write_log', TMessageType.CALL, self._seqid)
- args = write_log_args()
- args.table_name = table_name
- args.logName = logName
- args.new_entry = new_entry
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_write_log(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = write_log_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.ouch != None:
- raise result.ouch
- if result.ouch2 != None:
- raise result.ouch2
- return
-
- def read_log(self, table_name, logName):
- self.send_read_log(table_name, logName)
- return self.recv_read_log()
-
- def send_read_log(self, table_name, logName):
- self._oprot.writeMessageBegin('read_log', TMessageType.CALL, self._seqid)
- args = read_log_args()
- args.table_name = table_name
- args.logName = logName
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_read_log(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = read_log_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success != None:
- return result.success
- if result.ouch != None:
- raise result.ouch
- if result.ouch2 != None:
- raise result.ouch2
- raise TApplicationException(TApplicationException.MISSING_RESULT, "read_log failed: unknown result");
-
- def get_log_names(self, table_name):
- self.send_get_log_names(table_name)
- return self.recv_get_log_names()
-
- def send_get_log_names(self, table_name):
- self._oprot.writeMessageBegin('get_log_names', TMessageType.CALL, self._seqid)
- args = get_log_names_args()
- args.table_name = table_name
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_get_log_names(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = get_log_names_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success != None:
- return result.success
- if result.ouch != None:
- raise result.ouch
- if result.ouch2 != None:
- raise result.ouch2
- raise TApplicationException(TApplicationException.MISSING_RESULT, "get_log_names failed: unknown result");
-
-
-class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
- def __init__(self, handler):
- fb303.FacebookService.Processor.__init__(self, handler)
- self._processMap["get_tables"] = Processor.process_get_tables
- self._processMap["get_schema"] = Processor.process_get_schema
- self._processMap["get_fields"] = Processor.process_get_fields
- self._processMap["get_partition_cols"] = Processor.process_get_partition_cols
- self._processMap["save_table"] = Processor.process_save_table
- self._processMap["cat"] = Processor.process_cat
- self._processMap["drop"] = Processor.process_drop
- self._processMap["rename"] = Processor.process_rename
- self._processMap["schema_exists"] = Processor.process_schema_exists
- self._processMap["exists"] = Processor.process_exists
- self._processMap["alter_table"] = Processor.process_alter_table
- self._processMap["create_table"] = Processor.process_create_table
- self._processMap["get_partitions"] = Processor.process_get_partitions
- self._processMap["write_log"] = Processor.process_write_log
- self._processMap["read_log"] = Processor.process_read_log
- self._processMap["get_log_names"] = Processor.process_get_log_names
-
- def process(self, iprot, oprot):
- (name, type, seqid) = iprot.readMessageBegin()
- if name not in self._processMap:
- iprot.skip(TType.STRUCT)
- iprot.readMessageEnd()
- x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
- oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
- x.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
- return
- else:
- self._processMap[name](self, seqid, iprot, oprot)
- return True
-
- def process_get_tables(self, seqid, iprot, oprot):
- args = get_tables_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = get_tables_result()
- try:
- result.success = self._handler.get_tables(args.pattern)
- except MetaException, ouch:
- result.ouch = ouch
- except UnknownTableException, ouch2:
- result.ouch2 = ouch2
- oprot.writeMessageBegin("get_tables", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_get_schema(self, seqid, iprot, oprot):
- args = get_schema_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = get_schema_result()
- try:
- result.success = self._handler.get_schema(args.table_name)
- except MetaException, ouch:
- result.ouch = ouch
- except UnknownTableException, ouch2:
- result.ouch2 = ouch2
- oprot.writeMessageBegin("get_schema", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_get_fields(self, seqid, iprot, oprot):
- args = get_fields_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = get_fields_result()
- try:
- result.success = self._handler.get_fields(args.table_name)
- except MetaException, ouch:
- result.ouch = ouch
- except UnknownTableException, out2:
- result.out2 = out2
- oprot.writeMessageBegin("get_fields", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_get_partition_cols(self, seqid, iprot, oprot):
- args = get_partition_cols_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = get_partition_cols_result()
- try:
- result.success = self._handler.get_partition_cols(args.table_name)
- except MetaException, ouch:
- result.ouch = ouch
- except UnknownTableException, out2:
- result.out2 = out2
- oprot.writeMessageBegin("get_partition_cols", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_save_table(self, seqid, iprot, oprot):
- args = save_table_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = save_table_result()
- try:
- self._handler.save_table(args.table_name, args.schema, args.overwrite)
- except MetaException, ouch:
- result.ouch = ouch
- oprot.writeMessageBegin("save_table", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_cat(self, seqid, iprot, oprot):
- args = cat_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = cat_result()
- try:
- result.success = self._handler.cat(args.table_name, args.high, args.partition)
- except MetaException, ouch:
- result.ouch = ouch
- except UnknownTableException, ouch2:
- result.ouch2 = ouch2
- oprot.writeMessageBegin("cat", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_drop(self, seqid, iprot, oprot):
- args = drop_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = drop_result()
- try:
- self._handler.drop(args.table_name, args.delete_data)
- except MetaException, ouch:
- result.ouch = ouch
- except UnknownTableException, ouch2:
- result.ouch2 = ouch2
- oprot.writeMessageBegin("drop", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_rename(self, seqid, iprot, oprot):
- args = rename_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = rename_result()
- try:
- self._handler.rename(args.current_table_name, args.new_table_name, args.move_data)
- except MetaException, ouch:
- result.ouch = ouch
- except UnknownTableException, ouch2:
- result.ouch2 = ouch2
- oprot.writeMessageBegin("rename", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_schema_exists(self, seqid, iprot, oprot):
- args = schema_exists_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = schema_exists_result()
- try:
- result.success = self._handler.schema_exists(args.table_name)
- except MetaException, ouch:
- result.ouch = ouch
- oprot.writeMessageBegin("schema_exists", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_exists(self, seqid, iprot, oprot):
- args = exists_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = exists_result()
- try:
- result.success = self._handler.exists(args.table_name)
- except MetaException, ouch:
- result.ouch = ouch
- oprot.writeMessageBegin("exists", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_alter_table(self, seqid, iprot, oprot):
- args = alter_table_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = alter_table_result()
- try:
- self._handler.alter_table(args.table_name, args.columns)
- except MetaException, ouch:
- result.ouch = ouch
- except UnknownTableException, ouch2:
- result.ouch2 = ouch2
- oprot.writeMessageBegin("alter_table", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_create_table(self, seqid, iprot, oprot):
- args = create_table_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = create_table_result()
- try:
- self._handler.create_table(args.table_name, args.columns, args.partition_cols)
- except MetaException, ouch:
- result.ouch = ouch
- oprot.writeMessageBegin("create_table", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_get_partitions(self, seqid, iprot, oprot):
- args = get_partitions_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = get_partitions_result()
- try:
- result.success = self._handler.get_partitions(args.table_name)
- except MetaException, ouch:
- result.ouch = ouch
- except UnknownTableException, ouch2:
- result.ouch2 = ouch2
- oprot.writeMessageBegin("get_partitions", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_write_log(self, seqid, iprot, oprot):
- args = write_log_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = write_log_result()
- try:
- self._handler.write_log(args.table_name, args.logName, args.new_entry)
- except MetaException, ouch:
- result.ouch = ouch
- except UnknownTableException, ouch2:
- result.ouch2 = ouch2
- oprot.writeMessageBegin("write_log", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_read_log(self, seqid, iprot, oprot):
- args = read_log_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = read_log_result()
- try:
- result.success = self._handler.read_log(args.table_name, args.logName)
- except MetaException, ouch:
- result.ouch = ouch
- except UnknownTableException, ouch2:
- result.ouch2 = ouch2
- oprot.writeMessageBegin("read_log", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_get_log_names(self, seqid, iprot, oprot):
- args = get_log_names_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = get_log_names_result()
- try:
- result.success = self._handler.get_log_names(args.table_name)
- except MetaException, ouch:
- result.ouch = ouch
- except UnknownTableException, ouch2:
- result.ouch2 = ouch2
- oprot.writeMessageBegin("get_log_names", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
-
-# HELPER FUNCTIONS AND STRUCTURES
-
-class get_tables_args:
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'pattern', None, None, ), # 1
- )
-
- def __init__(self, d=None):
- self.pattern = None
- if isinstance(d, dict):
- if 'pattern' in d:
- self.pattern = d['pattern']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.pattern = iprot.readString();
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_tables_args')
- if self.pattern != None:
- oprot.writeFieldBegin('pattern', TType.STRING, 1)
- oprot.writeString(self.pattern)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class get_tables_result:
-
- thrift_spec = None
- def __init__(self, d=None):
- self.success = None
- self.ouch = None
- self.ouch2 = None
- if isinstance(d, dict):
- if 'success' in d:
- self.success = d['success']
- if 'ouch' in d:
- self.ouch = d['ouch']
- if 'ouch2' in d:
- self.ouch2 = d['ouch2']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.LIST:
- self.success = []
- (_etype3, _size0) = iprot.readListBegin()
- for _i4 in xrange(_size0):
- _elem5 = iprot.readString();
- self.success.append(_elem5)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.ouch = MetaException()
- self.ouch.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == -1:
- if ftype == TType.STRUCT:
- self.ouch2 = UnknownTableException()
- self.ouch2.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_tables_result')
- if self.success != None:
- oprot.writeFieldBegin('success', TType.LIST, 0)
- oprot.writeListBegin(TType.STRING, len(self.success))
- for iter6 in self.success:
- oprot.writeString(iter6)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.ouch != None:
- oprot.writeFieldBegin('ouch', TType.STRUCT, 1)
- self.ouch.write(oprot)
- oprot.writeFieldEnd()
- if self.ouch2 != None:
- oprot.writeFieldBegin('ouch2', TType.STRUCT, -1)
- self.ouch2.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class get_schema_args:
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'table_name', None, None, ), # 1
- )
-
- def __init__(self, d=None):
- self.table_name = None
- if isinstance(d, dict):
- if 'table_name' in d:
- self.table_name = d['table_name']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.table_name = iprot.readString();
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_schema_args')
- if self.table_name != None:
- oprot.writeFieldBegin('table_name', TType.STRING, 1)
- oprot.writeString(self.table_name)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class get_schema_result:
-
- thrift_spec = None
- def __init__(self, d=None):
- self.success = None
- self.ouch = None
- self.ouch2 = None
- if isinstance(d, dict):
- if 'success' in d:
- self.success = d['success']
- if 'ouch' in d:
- self.ouch = d['ouch']
- if 'ouch2' in d:
- self.ouch2 = d['ouch2']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.MAP:
- self.success = {}
- (_ktype8, _vtype9, _size7 ) = iprot.readMapBegin()
- for _i11 in xrange(_size7):
- _key12 = iprot.readString();
- _val13 = iprot.readString();
- self.success[_key12] = _val13
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.ouch = MetaException()
- self.ouch.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == -1:
- if ftype == TType.STRUCT:
- self.ouch2 = UnknownTableException()
- self.ouch2.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_schema_result')
- if self.success != None:
- oprot.writeFieldBegin('success', TType.MAP, 0)
- oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success))
- for kiter14,viter15 in self.success.items():
- oprot.writeString(kiter14)
- oprot.writeString(viter15)
- oprot.writeMapEnd()
- oprot.writeFieldEnd()
- if self.ouch != None:
- oprot.writeFieldBegin('ouch', TType.STRUCT, 1)
- self.ouch.write(oprot)
- oprot.writeFieldEnd()
- if self.ouch2 != None:
- oprot.writeFieldBegin('ouch2', TType.STRUCT, -1)
- self.ouch2.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class get_fields_args:
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'table_name', None, None, ), # 1
- )
-
- def __init__(self, d=None):
- self.table_name = None
- if isinstance(d, dict):
- if 'table_name' in d:
- self.table_name = d['table_name']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.table_name = iprot.readString();
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_fields_args')
- if self.table_name != None:
- oprot.writeFieldBegin('table_name', TType.STRING, 1)
- oprot.writeString(self.table_name)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class get_fields_result:
-
- thrift_spec = None
- def __init__(self, d=None):
- self.success = None
- self.ouch = None
- self.out2 = None
- if isinstance(d, dict):
- if 'success' in d:
- self.success = d['success']
- if 'ouch' in d:
- self.ouch = d['ouch']
- if 'out2' in d:
- self.out2 = d['out2']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.LIST:
- self.success = []
- (_etype19, _size16) = iprot.readListBegin()
- for _i20 in xrange(_size16):
- _elem21 = FieldSchema()
- _elem21.read(iprot)
- self.success.append(_elem21)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.ouch = MetaException()
- self.ouch.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == -1:
- if ftype == TType.STRUCT:
- self.out2 = UnknownTableException()
- self.out2.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_fields_result')
- if self.success != None:
- oprot.writeFieldBegin('success', TType.LIST, 0)
- oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter22 in self.success:
- iter22.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.ouch != None:
- oprot.writeFieldBegin('ouch', TType.STRUCT, 1)
- self.ouch.write(oprot)
- oprot.writeFieldEnd()
- if self.out2 != None:
- oprot.writeFieldBegin('out2', TType.STRUCT, -1)
- self.out2.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class get_partition_cols_args:
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'table_name', None, None, ), # 1
- )
-
- def __init__(self, d=None):
- self.table_name = None
- if isinstance(d, dict):
- if 'table_name' in d:
- self.table_name = d['table_name']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.table_name = iprot.readString();
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_partition_cols_args')
- if self.table_name != None:
- oprot.writeFieldBegin('table_name', TType.STRING, 1)
- oprot.writeString(self.table_name)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class get_partition_cols_result:
-
- thrift_spec = None
- def __init__(self, d=None):
- self.success = None
- self.ouch = None
- self.out2 = None
- if isinstance(d, dict):
- if 'success' in d:
- self.success = d['success']
- if 'ouch' in d:
- self.ouch = d['ouch']
- if 'out2' in d:
- self.out2 = d['out2']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.LIST:
- self.success = []
- (_etype26, _size23) = iprot.readListBegin()
- for _i27 in xrange(_size23):
- _elem28 = iprot.readString();
- self.success.append(_elem28)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.ouch = MetaException()
- self.ouch.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == -1:
- if ftype == TType.STRUCT:
- self.out2 = UnknownTableException()
- self.out2.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_partition_cols_result')
- if self.success != None:
- oprot.writeFieldBegin('success', TType.LIST, 0)
- oprot.writeListBegin(TType.STRING, len(self.success))
- for iter29 in self.success:
- oprot.writeString(iter29)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.ouch != None:
- oprot.writeFieldBegin('ouch', TType.STRUCT, 1)
- self.ouch.write(oprot)
- oprot.writeFieldEnd()
- if self.out2 != None:
- oprot.writeFieldBegin('out2', TType.STRUCT, -1)
- self.out2.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class save_table_args:
-
- thrift_spec = None
- def __init__(self, d=None):
- self.table_name = None
- self.schema = None
- self.overwrite = None
- if isinstance(d, dict):
- if 'table_name' in d:
- self.table_name = d['table_name']
- if 'schema' in d:
- self.schema = d['schema']
- if 'overwrite' in d:
- self.overwrite = d['overwrite']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.table_name = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == -1:
- if ftype == TType.MAP:
- self.schema = {}
- (_ktype31, _vtype32, _size30 ) = iprot.readMapBegin()
- for _i34 in xrange(_size30):
- _key35 = iprot.readString();
- _val36 = iprot.readString();
- self.schema[_key35] = _val36
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- elif fid == -2:
- if ftype == TType.BOOL:
- self.overwrite = iprot.readBool();
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('save_table_args')
- if self.table_name != None:
- oprot.writeFieldBegin('table_name', TType.STRING, 1)
- oprot.writeString(self.table_name)
- oprot.writeFieldEnd()
- if self.schema != None:
- oprot.writeFieldBegin('schema', TType.MAP, -1)
- oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.schema))
- for kiter37,viter38 in self.schema.items():
- oprot.writeString(kiter37)
- oprot.writeString(viter38)
- oprot.writeMapEnd()
- oprot.writeFieldEnd()
- if self.overwrite != None:
- oprot.writeFieldBegin('overwrite', TType.BOOL, -2)
- oprot.writeBool(self.overwrite)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class save_table_result:
-
- thrift_spec = (
- None, # 0
- (1, TType.STRUCT, 'ouch', (MetaException, MetaException.thrift_spec), None, ), # 1
- )
-
- def __init__(self, d=None):
- self.ouch = None
- if isinstance(d, dict):
- if 'ouch' in d:
- self.ouch = d['ouch']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRUCT:
- self.ouch = MetaException()
- self.ouch.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('save_table_result')
- if self.ouch != None:
- oprot.writeFieldBegin('ouch', TType.STRUCT, 1)
- self.ouch.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class cat_args:
-
- thrift_spec = None
- def __init__(self, d=None):
- self.table_name = None
- self.high = None
- self.partition = None
- if isinstance(d, dict):
- if 'table_name' in d:
- self.table_name = d['table_name']
- if 'high' in d:
- self.high = d['high']
- if 'partition' in d:
- self.partition = d['partition']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.table_name = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == -1:
- if ftype == TType.I32:
- self.high = iprot.readI32();
- else:
- iprot.skip(ftype)
- elif fid == -2:
- if ftype == TType.STRING:
- self.partition = iprot.readString();
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('cat_args')
- if self.table_name != None:
- oprot.writeFieldBegin('table_name', TType.STRING, 1)
- oprot.writeString(self.table_name)
- oprot.writeFieldEnd()
- if self.high != None:
- oprot.writeFieldBegin('high', TType.I32, -1)
- oprot.writeI32(self.high)
- oprot.writeFieldEnd()
- if self.partition != None:
- oprot.writeFieldBegin('partition', TType.STRING, -2)
- oprot.writeString(self.partition)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class cat_result:
-
- thrift_spec = None
- def __init__(self, d=None):
- self.success = None
- self.ouch = None
- self.ouch2 = None
- if isinstance(d, dict):
- if 'success' in d:
- self.success = d['success']
- if 'ouch' in d:
- self.ouch = d['ouch']
- if 'ouch2' in d:
- self.ouch2 = d['ouch2']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.LIST:
- self.success = []
- (_etype42, _size39) = iprot.readListBegin()
- for _i43 in xrange(_size39):
- _elem44 = iprot.readString();
- self.success.append(_elem44)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.ouch = MetaException()
- self.ouch.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == -3:
- if ftype == TType.STRUCT:
- self.ouch2 = UnknownTableException()
- self.ouch2.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('cat_result')
- if self.success != None:
- oprot.writeFieldBegin('success', TType.LIST, 0)
- oprot.writeListBegin(TType.STRING, len(self.success))
- for iter45 in self.success:
- oprot.writeString(iter45)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.ouch != None:
- oprot.writeFieldBegin('ouch', TType.STRUCT, 1)
- self.ouch.write(oprot)
- oprot.writeFieldEnd()
- if self.ouch2 != None:
- oprot.writeFieldBegin('ouch2', TType.STRUCT, -3)
- self.ouch2.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class drop_args:
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'table_name', None, None, ), # 1
- (2, TType.BOOL, 'delete_data', None, None, ), # 2
- )
-
- def __init__(self, d=None):
- self.table_name = None
- self.delete_data = None
- if isinstance(d, dict):
- if 'table_name' in d:
- self.table_name = d['table_name']
- if 'delete_data' in d:
- self.delete_data = d['delete_data']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.table_name = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.BOOL:
- self.delete_data = iprot.readBool();
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('drop_args')
- if self.table_name != None:
- oprot.writeFieldBegin('table_name', TType.STRING, 1)
- oprot.writeString(self.table_name)
- oprot.writeFieldEnd()
- if self.delete_data != None:
- oprot.writeFieldBegin('delete_data', TType.BOOL, 2)
- oprot.writeBool(self.delete_data)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class drop_result:
-
- thrift_spec = None
- def __init__(self, d=None):
- self.ouch = None
- self.ouch2 = None
- if isinstance(d, dict):
- if 'ouch' in d:
- self.ouch = d['ouch']
- if 'ouch2' in d:
- self.ouch2 = d['ouch2']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRUCT:
- self.ouch = MetaException()
- self.ouch.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == -1:
- if ftype == TType.STRUCT:
- self.ouch2 = UnknownTableException()
- self.ouch2.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('drop_result')
- if self.ouch != None:
- oprot.writeFieldBegin('ouch', TType.STRUCT, 1)
- self.ouch.write(oprot)
- oprot.writeFieldEnd()
- if self.ouch2 != None:
- oprot.writeFieldBegin('ouch2', TType.STRUCT, -1)
- self.ouch2.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class rename_args:
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'current_table_name', None, None, ), # 1
- (2, TType.STRING, 'new_table_name', None, None, ), # 2
- (3, TType.BOOL, 'move_data', None, None, ), # 3
- )
-
- def __init__(self, d=None):
- self.current_table_name = None
- self.new_table_name = None
- self.move_data = None
- if isinstance(d, dict):
- if 'current_table_name' in d:
- self.current_table_name = d['current_table_name']
- if 'new_table_name' in d:
- self.new_table_name = d['new_table_name']
- if 'move_data' in d:
- self.move_data = d['move_data']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.current_table_name = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.new_table_name = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.BOOL:
- self.move_data = iprot.readBool();
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('rename_args')
- if self.current_table_name != None:
- oprot.writeFieldBegin('current_table_name', TType.STRING, 1)
- oprot.writeString(self.current_table_name)
- oprot.writeFieldEnd()
- if self.new_table_name != None:
- oprot.writeFieldBegin('new_table_name', TType.STRING, 2)
- oprot.writeString(self.new_table_name)
- oprot.writeFieldEnd()
- if self.move_data != None:
- oprot.writeFieldBegin('move_data', TType.BOOL, 3)
- oprot.writeBool(self.move_data)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class rename_result:
-
- thrift_spec = None
- def __init__(self, d=None):
- self.ouch = None
- self.ouch2 = None
- if isinstance(d, dict):
- if 'ouch' in d:
- self.ouch = d['ouch']
- if 'ouch2' in d:
- self.ouch2 = d['ouch2']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRUCT:
- self.ouch = MetaException()
- self.ouch.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == -1:
- if ftype == TType.STRUCT:
- self.ouch2 = UnknownTableException()
- self.ouch2.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('rename_result')
- if self.ouch != None:
- oprot.writeFieldBegin('ouch', TType.STRUCT, 1)
- self.ouch.write(oprot)
- oprot.writeFieldEnd()
- if self.ouch2 != None:
- oprot.writeFieldBegin('ouch2', TType.STRUCT, -1)
- self.ouch2.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class schema_exists_args:
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'table_name', None, None, ), # 1
- )
-
- def __init__(self, d=None):
- self.table_name = None
- if isinstance(d, dict):
- if 'table_name' in d:
- self.table_name = d['table_name']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.table_name = iprot.readString();
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('schema_exists_args')
- if self.table_name != None:
- oprot.writeFieldBegin('table_name', TType.STRING, 1)
- oprot.writeString(self.table_name)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class schema_exists_result:
-
- thrift_spec = (
- (0, TType.BOOL, 'success', None, None, ), # 0
- (1, TType.STRUCT, 'ouch', (MetaException, MetaException.thrift_spec), None, ), # 1
- )
-
- def __init__(self, d=None):
- self.success = None
- self.ouch = None
- if isinstance(d, dict):
- if 'success' in d:
- self.success = d['success']
- if 'ouch' in d:
- self.ouch = d['ouch']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.BOOL:
- self.success = iprot.readBool();
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.ouch = MetaException()
- self.ouch.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('schema_exists_result')
- if self.success != None:
- oprot.writeFieldBegin('success', TType.BOOL, 0)
- oprot.writeBool(self.success)
- oprot.writeFieldEnd()
- if self.ouch != None:
- oprot.writeFieldBegin('ouch', TType.STRUCT, 1)
- self.ouch.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class exists_args:
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'table_name', None, None, ), # 1
- )
-
- def __init__(self, d=None):
- self.table_name = None
- if isinstance(d, dict):
- if 'table_name' in d:
- self.table_name = d['table_name']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.table_name = iprot.readString();
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('exists_args')
- if self.table_name != None:
- oprot.writeFieldBegin('table_name', TType.STRING, 1)
- oprot.writeString(self.table_name)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class exists_result:
-
- thrift_spec = (
- (0, TType.BOOL, 'success', None, None, ), # 0
- (1, TType.STRUCT, 'ouch', (MetaException, MetaException.thrift_spec), None, ), # 1
- )
-
- def __init__(self, d=None):
- self.success = None
- self.ouch = None
- if isinstance(d, dict):
- if 'success' in d:
- self.success = d['success']
- if 'ouch' in d:
- self.ouch = d['ouch']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.BOOL:
- self.success = iprot.readBool();
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.ouch = MetaException()
- self.ouch.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('exists_result')
- if self.success != None:
- oprot.writeFieldBegin('success', TType.BOOL, 0)
- oprot.writeBool(self.success)
- oprot.writeFieldEnd()
- if self.ouch != None:
- oprot.writeFieldBegin('ouch', TType.STRUCT, 1)
- self.ouch.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class alter_table_args:
-
- thrift_spec = None
- def __init__(self, d=None):
- self.table_name = None
- self.columns = None
- if isinstance(d, dict):
- if 'table_name' in d:
- self.table_name = d['table_name']
- if 'columns' in d:
- self.columns = d['columns']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == -1:
- if ftype == TType.STRING:
- self.table_name = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == -2:
- if ftype == TType.LIST:
- self.columns = []
- (_etype49, _size46) = iprot.readListBegin()
- for _i50 in xrange(_size46):
- _elem51 = iprot.readString();
- self.columns.append(_elem51)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('alter_table_args')
- if self.table_name != None:
- oprot.writeFieldBegin('table_name', TType.STRING, -1)
- oprot.writeString(self.table_name)
- oprot.writeFieldEnd()
- if self.columns != None:
- oprot.writeFieldBegin('columns', TType.LIST, -2)
- oprot.writeListBegin(TType.STRING, len(self.columns))
- for iter52 in self.columns:
- oprot.writeString(iter52)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class alter_table_result:
-
- thrift_spec = None
- def __init__(self, d=None):
- self.ouch = None
- self.ouch2 = None
- if isinstance(d, dict):
- if 'ouch' in d:
- self.ouch = d['ouch']
- if 'ouch2' in d:
- self.ouch2 = d['ouch2']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == -3:
- if ftype == TType.STRUCT:
- self.ouch = MetaException()
- self.ouch.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == -4:
- if ftype == TType.STRUCT:
- self.ouch2 = UnknownTableException()
- self.ouch2.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('alter_table_result')
- if self.ouch != None:
- oprot.writeFieldBegin('ouch', TType.STRUCT, -3)
- self.ouch.write(oprot)
- oprot.writeFieldEnd()
- if self.ouch2 != None:
- oprot.writeFieldBegin('ouch2', TType.STRUCT, -4)
- self.ouch2.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class create_table_args:
-
- thrift_spec = None
- def __init__(self, d=None):
- self.table_name = None
- self.columns = None
- self.partition_cols = None
- if isinstance(d, dict):
- if 'table_name' in d:
- self.table_name = d['table_name']
- if 'columns' in d:
- self.columns = d['columns']
- if 'partition_cols' in d:
- self.partition_cols = d['partition_cols']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == -1:
- if ftype == TType.STRING:
- self.table_name = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == -2:
- if ftype == TType.LIST:
- self.columns = []
- (_etype56, _size53) = iprot.readListBegin()
- for _i57 in xrange(_size53):
- _elem58 = iprot.readString();
- self.columns.append(_elem58)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == -3:
- if ftype == TType.LIST:
- self.partition_cols = []
- (_etype62, _size59) = iprot.readListBegin()
- for _i63 in xrange(_size59):
- _elem64 = iprot.readString();
- self.partition_cols.append(_elem64)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('create_table_args')
- if self.table_name != None:
- oprot.writeFieldBegin('table_name', TType.STRING, -1)
- oprot.writeString(self.table_name)
- oprot.writeFieldEnd()
- if self.columns != None:
- oprot.writeFieldBegin('columns', TType.LIST, -2)
- oprot.writeListBegin(TType.STRING, len(self.columns))
- for iter65 in self.columns:
- oprot.writeString(iter65)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.partition_cols != None:
- oprot.writeFieldBegin('partition_cols', TType.LIST, -3)
- oprot.writeListBegin(TType.STRING, len(self.partition_cols))
- for iter66 in self.partition_cols:
- oprot.writeString(iter66)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class create_table_result:
-
- thrift_spec = None
- def __init__(self, d=None):
- self.ouch = None
- if isinstance(d, dict):
- if 'ouch' in d:
- self.ouch = d['ouch']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == -4:
- if ftype == TType.STRUCT:
- self.ouch = MetaException()
- self.ouch.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('create_table_result')
- if self.ouch != None:
- oprot.writeFieldBegin('ouch', TType.STRUCT, -4)
- self.ouch.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class get_partitions_args:
-
- thrift_spec = None
- def __init__(self, d=None):
- self.table_name = None
- if isinstance(d, dict):
- if 'table_name' in d:
- self.table_name = d['table_name']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == -1:
- if ftype == TType.STRING:
- self.table_name = iprot.readString();
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_partitions_args')
- if self.table_name != None:
- oprot.writeFieldBegin('table_name', TType.STRING, -1)
- oprot.writeString(self.table_name)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class get_partitions_result:
-
- thrift_spec = None
- def __init__(self, d=None):
- self.success = None
- self.ouch = None
- self.ouch2 = None
- if isinstance(d, dict):
- if 'success' in d:
- self.success = d['success']
- if 'ouch' in d:
- self.ouch = d['ouch']
- if 'ouch2' in d:
- self.ouch2 = d['ouch2']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.LIST:
- self.success = []
- (_etype70, _size67) = iprot.readListBegin()
- for _i71 in xrange(_size67):
- _elem72 = iprot.readString();
- self.success.append(_elem72)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == -2:
- if ftype == TType.STRUCT:
- self.ouch = MetaException()
- self.ouch.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == -3:
- if ftype == TType.STRUCT:
- self.ouch2 = UnknownTableException()
- self.ouch2.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_partitions_result')
- if self.success != None:
- oprot.writeFieldBegin('success', TType.LIST, 0)
- oprot.writeListBegin(TType.STRING, len(self.success))
- for iter73 in self.success:
- oprot.writeString(iter73)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.ouch != None:
- oprot.writeFieldBegin('ouch', TType.STRUCT, -2)
- self.ouch.write(oprot)
- oprot.writeFieldEnd()
- if self.ouch2 != None:
- oprot.writeFieldBegin('ouch2', TType.STRUCT, -3)
- self.ouch2.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def __str__(self):
- return str(self.__dict__)
-
- def __repr__(self):
- return repr(self.__dict__)
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class write_log_args:
-
- thrift_spec = None
- def __init__(self, d=None):
- self.table_name = None
- self.logName = None
- self.new_entry = None
- if isinstance(d, dict):
- if 'table_name' in d:
- self.table_name = d['table_name']
- if 'logName' in d:
- self.logName = d['logName']
- if 'new_entry' in d:
- self.new_entry = d['new_entry']
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == -1:
- if ftype == TType.STRING:
- self.table_name = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == -2:
- if ftype == TType.STRING:
- self.logName = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == -3:
- if ftype == TType.MAP:
- self.new_entry = {}
- (_ktype75, _vtype76, _size74 ) = iprot.readMapBegin()
- for _i78 in xrange(_size74):
- _key79 = iprot.readString();
- _val80 = iprot.readString();
- self.new_entry[_key79] = _val80
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
[... 404 lines stripped ...]