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 zs...@apache.org on 2008/09/20 01:56:35 UTC
svn commit: r697291 [8/31] - in /hadoop/core/trunk: ./
src/contrib/hive/cli/src/java/org/apache/hadoop/hive/cli/
src/contrib/hive/metastore/if/
src/contrib/hive/metastore/src/gen-javabean/org/apache/hadoop/hive/metastore/api/
src/contrib/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=697291&r1=697290&r2=697291&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 Fri Sep 19 16:56:30 2008
@@ -17,7 +17,7 @@
class Iface(fb303.FacebookService.Iface):
- def create_database(self, name, location_uri):
+ def create_database(self, name, description):
pass
def get_database(self, name):
@@ -56,18 +56,9 @@
def get_table(self, dbname, tbl_name):
pass
- def set_table_parameters(self, dbname, tbl_name, params):
- pass
-
def alter_table(self, dbname, tbl_name, new_tbl):
pass
- def truncate_table(self, db_name, table_name, partition):
- pass
-
- def cat(self, db_name, table_name, partition, high):
- pass
-
def add_partition(self, new_part):
pass
@@ -83,7 +74,7 @@
def get_partitions(self, db_name, tbl_name, max_parts):
pass
- def set_partition_parameters(self, db_name, tbl_name, pname, params):
+ def get_partition_names(self, db_name, tbl_name, max_parts):
pass
def alter_partitions(self, sd, parts):
@@ -97,15 +88,15 @@
def __init__(self, iprot, oprot=None):
fb303.FacebookService.Client.__init__(self, iprot, oprot)
- def create_database(self, name, location_uri):
- self.send_create_database(name, location_uri)
+ def create_database(self, name, description):
+ self.send_create_database(name, description)
return self.recv_create_database()
- def send_create_database(self, name, location_uri):
+ def send_create_database(self, name, description):
self._oprot.writeMessageBegin('create_database', TMessageType.CALL, self._seqid)
args = create_database_args()
args.name = name
- args.location_uri = location_uri
+ args.description = description
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
@@ -488,38 +479,6 @@
raise result.o2
raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table failed: unknown result");
- def set_table_parameters(self, dbname, tbl_name, params):
- self.send_set_table_parameters(dbname, tbl_name, params)
- return self.recv_set_table_parameters()
-
- def send_set_table_parameters(self, dbname, tbl_name, params):
- self._oprot.writeMessageBegin('set_table_parameters', TMessageType.CALL, self._seqid)
- args = set_table_parameters_args()
- args.dbname = dbname
- args.tbl_name = tbl_name
- args.params = params
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_set_table_parameters(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = set_table_parameters_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success != None:
- return result.success
- if result.o1 != None:
- raise result.o1
- if result.o2 != None:
- raise result.o2
- raise TApplicationException(TApplicationException.MISSING_RESULT, "set_table_parameters failed: unknown result");
-
def alter_table(self, dbname, tbl_name, new_tbl):
self.send_alter_table(dbname, tbl_name, new_tbl)
self.recv_alter_table()
@@ -550,73 +509,6 @@
raise result.o2
return
- def truncate_table(self, db_name, table_name, partition):
- self.send_truncate_table(db_name, table_name, partition)
- self.recv_truncate_table()
-
- def send_truncate_table(self, db_name, table_name, partition):
- self._oprot.writeMessageBegin('truncate_table', TMessageType.CALL, self._seqid)
- args = truncate_table_args()
- args.db_name = db_name
- args.table_name = table_name
- args.partition = partition
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_truncate_table(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = truncate_table_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.ouch1 != None:
- raise result.ouch1
- if result.ouch2 != None:
- raise result.ouch2
- if result.ouch3 != None:
- raise result.ouch3
- return
-
- def cat(self, db_name, table_name, partition, high):
- self.send_cat(db_name, table_name, partition, high)
- return self.recv_cat()
-
- def send_cat(self, db_name, table_name, partition, high):
- self._oprot.writeMessageBegin('cat', TMessageType.CALL, self._seqid)
- args = cat_args()
- args.db_name = db_name
- args.table_name = table_name
- args.partition = partition
- args.high = high
- 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.ouch1 != None:
- raise result.ouch1
- if result.ouch2 != None:
- raise result.ouch2
- if result.ouch3 != None:
- raise result.ouch3
- raise TApplicationException(TApplicationException.MISSING_RESULT, "cat failed: unknown result");
-
def add_partition(self, new_part):
self.send_add_partition(new_part)
return self.recv_add_partition()
@@ -778,38 +670,35 @@
raise result.o2
raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions failed: unknown result");
- def set_partition_parameters(self, db_name, tbl_name, pname, params):
- self.send_set_partition_parameters(db_name, tbl_name, pname, params)
- return self.recv_set_partition_parameters()
-
- def send_set_partition_parameters(self, db_name, tbl_name, pname, params):
- self._oprot.writeMessageBegin('set_partition_parameters', TMessageType.CALL, self._seqid)
- args = set_partition_parameters_args()
+ def get_partition_names(self, db_name, tbl_name, max_parts):
+ self.send_get_partition_names(db_name, tbl_name, max_parts)
+ return self.recv_get_partition_names()
+
+ def send_get_partition_names(self, db_name, tbl_name, max_parts):
+ self._oprot.writeMessageBegin('get_partition_names', TMessageType.CALL, self._seqid)
+ args = get_partition_names_args()
args.db_name = db_name
args.tbl_name = tbl_name
- args.pname = pname
- args.params = params
+ args.max_parts = max_parts
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_set_partition_parameters(self, ):
+ def recv_get_partition_names(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = set_partition_parameters_result()
+ result = get_partition_names_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
if result.success != None:
return result.success
- if result.o1 != None:
- raise result.o1
if result.o2 != None:
raise result.o2
- raise TApplicationException(TApplicationException.MISSING_RESULT, "set_partition_parameters failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_names failed: unknown result");
def alter_partitions(self, sd, parts):
self.send_alter_partitions(sd, parts)
@@ -889,16 +778,13 @@
self._processMap["drop_table"] = Processor.process_drop_table
self._processMap["get_tables"] = Processor.process_get_tables
self._processMap["get_table"] = Processor.process_get_table
- self._processMap["set_table_parameters"] = Processor.process_set_table_parameters
self._processMap["alter_table"] = Processor.process_alter_table
- self._processMap["truncate_table"] = Processor.process_truncate_table
- self._processMap["cat"] = Processor.process_cat
self._processMap["add_partition"] = Processor.process_add_partition
self._processMap["append_partition"] = Processor.process_append_partition
self._processMap["drop_partition"] = Processor.process_drop_partition
self._processMap["get_partition"] = Processor.process_get_partition
self._processMap["get_partitions"] = Processor.process_get_partitions
- self._processMap["set_partition_parameters"] = Processor.process_set_partition_parameters
+ self._processMap["get_partition_names"] = Processor.process_get_partition_names
self._processMap["alter_partitions"] = Processor.process_alter_partitions
self._processMap["create_index"] = Processor.process_create_index
@@ -923,7 +809,7 @@
iprot.readMessageEnd()
result = create_database_result()
try:
- result.success = self._handler.create_database(args.name, args.location_uri)
+ result.success = self._handler.create_database(args.name, args.description)
except AlreadyExistsException, o1:
result.o1 = o1
except MetaException, o2:
@@ -1125,22 +1011,6 @@
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_set_table_parameters(self, seqid, iprot, oprot):
- args = set_table_parameters_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = set_table_parameters_result()
- try:
- result.success = self._handler.set_table_parameters(args.dbname, args.tbl_name, args.params)
- except NoSuchObjectException, o1:
- result.o1 = o1
- except MetaException, o2:
- result.o2 = o2
- oprot.writeMessageBegin("set_table_parameters", 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)
@@ -1157,42 +1027,6 @@
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_truncate_table(self, seqid, iprot, oprot):
- args = truncate_table_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = truncate_table_result()
- try:
- self._handler.truncate_table(args.db_name, args.table_name, args.partition)
- except MetaException, ouch1:
- result.ouch1 = ouch1
- except UnknownTableException, ouch2:
- result.ouch2 = ouch2
- except UnknownDBException, ouch3:
- result.ouch3 = ouch3
- oprot.writeMessageBegin("truncate_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.db_name, args.table_name, args.partition, args.high)
- except MetaException, ouch1:
- result.ouch1 = ouch1
- except UnknownDBException, ouch2:
- result.ouch2 = ouch2
- except UnknownTableException, ouch3:
- result.ouch3 = ouch3
- oprot.writeMessageBegin("cat", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
def process_add_partition(self, seqid, iprot, oprot):
args = add_partition_args()
args.read(iprot)
@@ -1275,18 +1109,16 @@
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_set_partition_parameters(self, seqid, iprot, oprot):
- args = set_partition_parameters_args()
+ def process_get_partition_names(self, seqid, iprot, oprot):
+ args = get_partition_names_args()
args.read(iprot)
iprot.readMessageEnd()
- result = set_partition_parameters_result()
+ result = get_partition_names_result()
try:
- result.success = self._handler.set_partition_parameters(args.db_name, args.tbl_name, args.pname, args.params)
- except NoSuchObjectException, o1:
- result.o1 = o1
+ result.success = self._handler.get_partition_names(args.db_name, args.tbl_name, args.max_parts)
except MetaException, o2:
result.o2 = o2
- oprot.writeMessageBegin("set_partition_parameters", TMessageType.REPLY, seqid)
+ oprot.writeMessageBegin("get_partition_names", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1331,17 +1163,17 @@
thrift_spec = (
None, # 0
(1, TType.STRING, 'name', None, None, ), # 1
- (2, TType.STRING, 'location_uri', None, None, ), # 2
+ (2, TType.STRING, 'description', None, None, ), # 2
)
def __init__(self, d=None):
self.name = None
- self.location_uri = None
+ self.description = None
if isinstance(d, dict):
if 'name' in d:
self.name = d['name']
- if 'location_uri' in d:
- self.location_uri = d['location_uri']
+ if 'description' in d:
+ self.description = d['description']
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:
@@ -1359,7 +1191,7 @@
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.location_uri = iprot.readString();
+ self.description = iprot.readString();
else:
iprot.skip(ftype)
else:
@@ -1376,9 +1208,9 @@
oprot.writeFieldBegin('name', TType.STRING, 1)
oprot.writeString(self.name)
oprot.writeFieldEnd()
- if self.location_uri != None:
- oprot.writeFieldBegin('location_uri', TType.STRING, 2)
- oprot.writeString(self.location_uri)
+ if self.description != None:
+ oprot.writeFieldBegin('description', TType.STRING, 2)
+ oprot.writeString(self.description)
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -3193,26 +3025,26 @@
def __ne__(self, other):
return not (self == other)
-class set_table_parameters_args:
+class alter_table_args:
thrift_spec = (
None, # 0
(1, TType.STRING, 'dbname', None, None, ), # 1
(2, TType.STRING, 'tbl_name', None, None, ), # 2
- (3, TType.MAP, 'params', (TType.STRING,None,TType.STRING,None), None, ), # 3
+ (3, TType.STRUCT, 'new_tbl', (Table, Table.thrift_spec), None, ), # 3
)
def __init__(self, d=None):
self.dbname = None
self.tbl_name = None
- self.params = None
+ self.new_tbl = None
if isinstance(d, dict):
if 'dbname' in d:
self.dbname = d['dbname']
if 'tbl_name' in d:
self.tbl_name = d['tbl_name']
- if 'params' in d:
- self.params = d['params']
+ if 'new_tbl' in d:
+ self.new_tbl = d['new_tbl']
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:
@@ -3234,14 +3066,9 @@
else:
iprot.skip(ftype)
elif fid == 3:
- if ftype == TType.MAP:
- self.params = {}
- (_ktype116, _vtype117, _size115 ) = iprot.readMapBegin()
- for _i119 in xrange(_size115):
- _key120 = iprot.readString();
- _val121 = iprot.readString();
- self.params[_key120] = _val121
- iprot.readMapEnd()
+ if ftype == TType.STRUCT:
+ self.new_tbl = Table()
+ self.new_tbl.read(iprot)
else:
iprot.skip(ftype)
else:
@@ -3253,7 +3080,7 @@
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('set_table_parameters_args')
+ oprot.writeStructBegin('alter_table_args')
if self.dbname != None:
oprot.writeFieldBegin('dbname', TType.STRING, 1)
oprot.writeString(self.dbname)
@@ -3262,13 +3089,9 @@
oprot.writeFieldBegin('tbl_name', TType.STRING, 2)
oprot.writeString(self.tbl_name)
oprot.writeFieldEnd()
- if self.params != None:
- oprot.writeFieldBegin('params', TType.MAP, 3)
- oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.params))
- for kiter122,viter123 in self.params.items():
- oprot.writeString(kiter122)
- oprot.writeString(viter123)
- oprot.writeMapEnd()
+ if self.new_tbl != None:
+ oprot.writeFieldBegin('new_tbl', TType.STRUCT, 3)
+ self.new_tbl.write(oprot)
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -3285,21 +3108,18 @@
def __ne__(self, other):
return not (self == other)
-class set_table_parameters_result:
+class alter_table_result:
thrift_spec = (
- (0, TType.BOOL, 'success', None, None, ), # 0
- (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1
+ None, # 0
+ (1, TType.STRUCT, 'o1', (InvalidOperationException, InvalidOperationException.thrift_spec), None, ), # 1
(2, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 2
)
def __init__(self, d=None):
- self.success = None
self.o1 = None
self.o2 = None
if isinstance(d, dict):
- if 'success' in d:
- self.success = d['success']
if 'o1' in d:
self.o1 = d['o1']
if 'o2' in d:
@@ -3314,14 +3134,9 @@
(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 fid == 1:
if ftype == TType.STRUCT:
- self.o1 = NoSuchObjectException()
+ self.o1 = InvalidOperationException()
self.o1.read(iprot)
else:
iprot.skip(ftype)
@@ -3340,11 +3155,7 @@
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('set_table_parameters_result')
- if self.success != None:
- oprot.writeFieldBegin('success', TType.BOOL, 0)
- oprot.writeBool(self.success)
- oprot.writeFieldEnd()
+ oprot.writeStructBegin('alter_table_result')
if self.o1 != None:
oprot.writeFieldBegin('o1', TType.STRUCT, 1)
self.o1.write(oprot)
@@ -3368,26 +3179,18 @@
def __ne__(self, other):
return not (self == other)
-class alter_table_args:
+class add_partition_args:
thrift_spec = (
None, # 0
- (1, TType.STRING, 'dbname', None, None, ), # 1
- (2, TType.STRING, 'tbl_name', None, None, ), # 2
- (3, TType.STRUCT, 'new_tbl', (Table, Table.thrift_spec), None, ), # 3
+ (1, TType.STRUCT, 'new_part', (Partition, Partition.thrift_spec), None, ), # 1
)
def __init__(self, d=None):
- self.dbname = None
- self.tbl_name = None
- self.new_tbl = None
+ self.new_part = None
if isinstance(d, dict):
- if 'dbname' in d:
- self.dbname = d['dbname']
- if 'tbl_name' in d:
- self.tbl_name = d['tbl_name']
- if 'new_tbl' in d:
- self.new_tbl = d['new_tbl']
+ if 'new_part' in d:
+ self.new_part = d['new_part']
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:
@@ -3399,19 +3202,9 @@
if ftype == TType.STOP:
break
if fid == 1:
- if ftype == TType.STRING:
- self.dbname = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.tbl_name = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == 3:
if ftype == TType.STRUCT:
- self.new_tbl = Table()
- self.new_tbl.read(iprot)
+ self.new_part = Partition()
+ self.new_part.read(iprot)
else:
iprot.skip(ftype)
else:
@@ -3423,18 +3216,10 @@
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.dbname != None:
- oprot.writeFieldBegin('dbname', TType.STRING, 1)
- oprot.writeString(self.dbname)
- oprot.writeFieldEnd()
- if self.tbl_name != None:
- oprot.writeFieldBegin('tbl_name', TType.STRING, 2)
- oprot.writeString(self.tbl_name)
- oprot.writeFieldEnd()
- if self.new_tbl != None:
- oprot.writeFieldBegin('new_tbl', TType.STRUCT, 3)
- self.new_tbl.write(oprot)
+ oprot.writeStructBegin('add_partition_args')
+ if self.new_part != None:
+ oprot.writeFieldBegin('new_part', TType.STRUCT, 1)
+ self.new_part.write(oprot)
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -3451,22 +3236,29 @@
def __ne__(self, other):
return not (self == other)
-class alter_table_result:
+class add_partition_result:
thrift_spec = (
- None, # 0
- (1, TType.STRUCT, 'o1', (InvalidOperationException, InvalidOperationException.thrift_spec), None, ), # 1
- (2, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 2
+ (0, TType.STRUCT, 'success', (Partition, Partition.thrift_spec), None, ), # 0
+ (1, TType.STRUCT, 'o1', (InvalidObjectException, InvalidObjectException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'o2', (AlreadyExistsException, AlreadyExistsException.thrift_spec), None, ), # 2
+ (3, TType.STRUCT, 'o3', (MetaException, MetaException.thrift_spec), None, ), # 3
)
def __init__(self, d=None):
+ self.success = None
self.o1 = None
self.o2 = None
+ self.o3 = None
if isinstance(d, dict):
+ if 'success' in d:
+ self.success = d['success']
if 'o1' in d:
self.o1 = d['o1']
if 'o2' in d:
self.o2 = d['o2']
+ if 'o3' in d:
+ self.o3 = d['o3']
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:
@@ -3477,18 +3269,30 @@
(fname, ftype, fid) = iprot.readFieldBegin()
if ftype == TType.STOP:
break
- if fid == 1:
+ if fid == 0:
if ftype == TType.STRUCT:
- self.o1 = InvalidOperationException()
+ self.success = Partition()
+ self.success.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 1:
+ if ftype == TType.STRUCT:
+ self.o1 = InvalidObjectException()
self.o1.read(iprot)
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRUCT:
- self.o2 = MetaException()
+ self.o2 = AlreadyExistsException()
self.o2.read(iprot)
else:
iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRUCT:
+ self.o3 = MetaException()
+ self.o3.read(iprot)
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -3498,7 +3302,11 @@
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')
+ oprot.writeStructBegin('add_partition_result')
+ if self.success != None:
+ oprot.writeFieldBegin('success', TType.STRUCT, 0)
+ self.success.write(oprot)
+ oprot.writeFieldEnd()
if self.o1 != None:
oprot.writeFieldBegin('o1', TType.STRUCT, 1)
self.o1.write(oprot)
@@ -3507,6 +3315,10 @@
oprot.writeFieldBegin('o2', TType.STRUCT, 2)
self.o2.write(oprot)
oprot.writeFieldEnd()
+ if self.o3 != None:
+ oprot.writeFieldBegin('o3', TType.STRUCT, 3)
+ self.o3.write(oprot)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -3522,26 +3334,26 @@
def __ne__(self, other):
return not (self == other)
-class truncate_table_args:
+class append_partition_args:
thrift_spec = (
None, # 0
(1, TType.STRING, 'db_name', None, None, ), # 1
- (2, TType.STRING, 'table_name', None, None, ), # 2
- (3, TType.STRING, 'partition', None, None, ), # 3
+ (2, TType.STRING, 'tbl_name', None, None, ), # 2
+ (3, TType.LIST, 'part_vals', (TType.STRING,None), None, ), # 3
)
def __init__(self, d=None):
self.db_name = None
- self.table_name = None
- self.partition = None
+ self.tbl_name = None
+ self.part_vals = None
if isinstance(d, dict):
if 'db_name' in d:
self.db_name = d['db_name']
- if 'table_name' in d:
- self.table_name = d['table_name']
- if 'partition' in d:
- self.partition = d['partition']
+ if 'tbl_name' in d:
+ self.tbl_name = d['tbl_name']
+ if 'part_vals' in d:
+ self.part_vals = d['part_vals']
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:
@@ -3559,525 +3371,16 @@
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.table_name = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == 3:
- 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('truncate_table_args')
- if self.db_name != None:
- oprot.writeFieldBegin('db_name', TType.STRING, 1)
- oprot.writeString(self.db_name)
- oprot.writeFieldEnd()
- if self.table_name != None:
- oprot.writeFieldBegin('table_name', TType.STRING, 2)
- oprot.writeString(self.table_name)
- oprot.writeFieldEnd()
- if self.partition != None:
- oprot.writeFieldBegin('partition', TType.STRING, 3)
- 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 truncate_table_result:
-
- thrift_spec = (
- None, # 0
- (1, TType.STRUCT, 'ouch1', (MetaException, MetaException.thrift_spec), None, ), # 1
- (2, TType.STRUCT, 'ouch2', (UnknownTableException, UnknownTableException.thrift_spec), None, ), # 2
- (3, TType.STRUCT, 'ouch3', (UnknownDBException, UnknownDBException.thrift_spec), None, ), # 3
- )
-
- def __init__(self, d=None):
- self.ouch1 = None
- self.ouch2 = None
- self.ouch3 = None
- if isinstance(d, dict):
- if 'ouch1' in d:
- self.ouch1 = d['ouch1']
- if 'ouch2' in d:
- self.ouch2 = d['ouch2']
- if 'ouch3' in d:
- self.ouch3 = d['ouch3']
-
- 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.ouch1 = MetaException()
- self.ouch1.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRUCT:
- self.ouch2 = UnknownTableException()
- self.ouch2.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRUCT:
- self.ouch3 = UnknownDBException()
- self.ouch3.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('truncate_table_result')
- if self.ouch1 != None:
- oprot.writeFieldBegin('ouch1', TType.STRUCT, 1)
- self.ouch1.write(oprot)
- oprot.writeFieldEnd()
- if self.ouch2 != None:
- oprot.writeFieldBegin('ouch2', TType.STRUCT, 2)
- self.ouch2.write(oprot)
- oprot.writeFieldEnd()
- if self.ouch3 != None:
- oprot.writeFieldBegin('ouch3', TType.STRUCT, 3)
- self.ouch3.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.db_name = None
- self.table_name = None
- self.partition = None
- self.high = None
- if isinstance(d, dict):
- if 'db_name' in d:
- self.db_name = d['db_name']
- if 'table_name' in d:
- self.table_name = d['table_name']
- if 'partition' in d:
- self.partition = d['partition']
- if 'high' in d:
- self.high = d['high']
-
- 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.db_name = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.table_name = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.partition = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == -1:
- if ftype == TType.I32:
- self.high = iprot.readI32();
- 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.db_name != None:
- oprot.writeFieldBegin('db_name', TType.STRING, 1)
- oprot.writeString(self.db_name)
- oprot.writeFieldEnd()
- if self.table_name != None:
- oprot.writeFieldBegin('table_name', TType.STRING, 2)
- oprot.writeString(self.table_name)
- oprot.writeFieldEnd()
- if self.partition != None:
- oprot.writeFieldBegin('partition', TType.STRING, 3)
- oprot.writeString(self.partition)
- oprot.writeFieldEnd()
- if self.high != None:
- oprot.writeFieldBegin('high', TType.I32, -1)
- oprot.writeI32(self.high)
- 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.ouch1 = None
- self.ouch2 = None
- self.ouch3 = None
- if isinstance(d, dict):
- if 'success' in d:
- self.success = d['success']
- if 'ouch1' in d:
- self.ouch1 = d['ouch1']
- if 'ouch2' in d:
- self.ouch2 = d['ouch2']
- if 'ouch3' in d:
- self.ouch3 = d['ouch3']
-
- 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 = []
- (_etype127, _size124) = iprot.readListBegin()
- for _i128 in xrange(_size124):
- _elem129 = iprot.readString();
- self.success.append(_elem129)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == -2:
- if ftype == TType.STRUCT:
- self.ouch1 = MetaException()
- self.ouch1.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == -3:
- if ftype == TType.STRUCT:
- self.ouch2 = UnknownDBException()
- self.ouch2.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == -4:
- if ftype == TType.STRUCT:
- self.ouch3 = UnknownTableException()
- self.ouch3.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 iter130 in self.success:
- oprot.writeString(iter130)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.ouch1 != None:
- oprot.writeFieldBegin('ouch1', TType.STRUCT, -2)
- self.ouch1.write(oprot)
- oprot.writeFieldEnd()
- if self.ouch2 != None:
- oprot.writeFieldBegin('ouch2', TType.STRUCT, -3)
- self.ouch2.write(oprot)
- oprot.writeFieldEnd()
- if self.ouch3 != None:
- oprot.writeFieldBegin('ouch3', TType.STRUCT, -4)
- self.ouch3.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 add_partition_args:
-
- thrift_spec = (
- None, # 0
- (1, TType.STRUCT, 'new_part', (Partition, Partition.thrift_spec), None, ), # 1
- )
-
- def __init__(self, d=None):
- self.new_part = None
- if isinstance(d, dict):
- if 'new_part' in d:
- self.new_part = d['new_part']
-
- 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.new_part = Partition()
- self.new_part.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('add_partition_args')
- if self.new_part != None:
- oprot.writeFieldBegin('new_part', TType.STRUCT, 1)
- self.new_part.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 add_partition_result:
-
- thrift_spec = (
- (0, TType.STRUCT, 'success', (Partition, Partition.thrift_spec), None, ), # 0
- (1, TType.STRUCT, 'o1', (InvalidObjectException, InvalidObjectException.thrift_spec), None, ), # 1
- (2, TType.STRUCT, 'o2', (AlreadyExistsException, AlreadyExistsException.thrift_spec), None, ), # 2
- (3, TType.STRUCT, 'o3', (MetaException, MetaException.thrift_spec), None, ), # 3
- )
-
- def __init__(self, d=None):
- self.success = None
- self.o1 = None
- self.o2 = None
- self.o3 = None
- if isinstance(d, dict):
- if 'success' in d:
- self.success = d['success']
- if 'o1' in d:
- self.o1 = d['o1']
- if 'o2' in d:
- self.o2 = d['o2']
- if 'o3' in d:
- self.o3 = d['o3']
-
- 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.STRUCT:
- self.success = Partition()
- self.success.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.o1 = InvalidObjectException()
- self.o1.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRUCT:
- self.o2 = AlreadyExistsException()
- self.o2.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRUCT:
- self.o3 = MetaException()
- self.o3.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('add_partition_result')
- if self.success != None:
- oprot.writeFieldBegin('success', TType.STRUCT, 0)
- self.success.write(oprot)
- oprot.writeFieldEnd()
- if self.o1 != None:
- oprot.writeFieldBegin('o1', TType.STRUCT, 1)
- self.o1.write(oprot)
- oprot.writeFieldEnd()
- if self.o2 != None:
- oprot.writeFieldBegin('o2', TType.STRUCT, 2)
- self.o2.write(oprot)
- oprot.writeFieldEnd()
- if self.o3 != None:
- oprot.writeFieldBegin('o3', TType.STRUCT, 3)
- self.o3.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 append_partition_args:
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'db_name', None, None, ), # 1
- (2, TType.STRING, 'tbl_name', None, None, ), # 2
- (3, TType.LIST, 'part_vals', (TType.STRING,None), None, ), # 3
- )
-
- def __init__(self, d=None):
- self.db_name = None
- self.tbl_name = None
- self.part_vals = None
- if isinstance(d, dict):
- if 'db_name' in d:
- self.db_name = d['db_name']
- if 'tbl_name' in d:
- self.tbl_name = d['tbl_name']
- if 'part_vals' in d:
- self.part_vals = d['part_vals']
-
- 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.db_name = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.tbl_name = iprot.readString();
+ self.tbl_name = iprot.readString();
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype134, _size131) = iprot.readListBegin()
- for _i135 in xrange(_size131):
- _elem136 = iprot.readString();
- self.part_vals.append(_elem136)
+ (_etype118, _size115) = iprot.readListBegin()
+ for _i119 in xrange(_size115):
+ _elem120 = iprot.readString();
+ self.part_vals.append(_elem120)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -4102,8 +3405,8 @@
if self.part_vals != None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter137 in self.part_vals:
- oprot.writeString(iter137)
+ for iter121 in self.part_vals:
+ oprot.writeString(iter121)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -4266,10 +3569,10 @@
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype141, _size138) = iprot.readListBegin()
- for _i142 in xrange(_size138):
- _elem143 = iprot.readString();
- self.part_vals.append(_elem143)
+ (_etype125, _size122) = iprot.readListBegin()
+ for _i126 in xrange(_size122):
+ _elem127 = iprot.readString();
+ self.part_vals.append(_elem127)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -4299,8 +3602,8 @@
if self.part_vals != None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter144 in self.part_vals:
- oprot.writeString(iter144)
+ for iter128 in self.part_vals:
+ oprot.writeString(iter128)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData != None:
@@ -4448,10 +3751,10 @@
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype148, _size145) = iprot.readListBegin()
- for _i149 in xrange(_size145):
- _elem150 = iprot.readString();
- self.part_vals.append(_elem150)
+ (_etype132, _size129) = iprot.readListBegin()
+ for _i133 in xrange(_size129):
+ _elem134 = iprot.readString();
+ self.part_vals.append(_elem134)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -4476,8 +3779,8 @@
if self.part_vals != None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter151 in self.part_vals:
- oprot.writeString(iter151)
+ for iter135 in self.part_vals:
+ oprot.writeString(iter135)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -4679,11 +3982,11 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype155, _size152) = iprot.readListBegin()
- for _i156 in xrange(_size152):
- _elem157 = Partition()
- _elem157.read(iprot)
- self.success.append(_elem157)
+ (_etype139, _size136) = iprot.readListBegin()
+ for _i140 in xrange(_size136):
+ _elem141 = Partition()
+ _elem141.read(iprot)
+ self.success.append(_elem141)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -4712,8 +4015,8 @@
if self.success != None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter158 in self.success:
- iter158.write(oprot)
+ for iter142 in self.success:
+ iter142.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 != None:
@@ -4739,30 +4042,26 @@
def __ne__(self, other):
return not (self == other)
-class set_partition_parameters_args:
+class get_partition_names_args:
thrift_spec = (
None, # 0
(1, TType.STRING, 'db_name', None, None, ), # 1
(2, TType.STRING, 'tbl_name', None, None, ), # 2
- (3, TType.STRING, 'pname', None, None, ), # 3
- (4, TType.MAP, 'params', (TType.STRING,None,TType.STRING,None), None, ), # 4
+ (3, TType.I16, 'max_parts', None, None, ), # 3
)
def __init__(self, d=None):
self.db_name = None
self.tbl_name = None
- self.pname = None
- self.params = None
+ self.max_parts = -1
if isinstance(d, dict):
if 'db_name' in d:
self.db_name = d['db_name']
if 'tbl_name' in d:
self.tbl_name = d['tbl_name']
- if 'pname' in d:
- self.pname = d['pname']
- if 'params' in d:
- self.params = d['params']
+ if 'max_parts' in d:
+ self.max_parts = d['max_parts']
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:
@@ -4784,19 +4083,8 @@
else:
iprot.skip(ftype)
elif fid == 3:
- if ftype == TType.STRING:
- self.pname = iprot.readString();
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.MAP:
- self.params = {}
- (_ktype160, _vtype161, _size159 ) = iprot.readMapBegin()
- for _i163 in xrange(_size159):
- _key164 = iprot.readString();
- _val165 = iprot.readString();
- self.params[_key164] = _val165
- iprot.readMapEnd()
+ if ftype == TType.I16:
+ self.max_parts = iprot.readI16();
else:
iprot.skip(ftype)
else:
@@ -4808,7 +4096,7 @@
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('set_partition_parameters_args')
+ oprot.writeStructBegin('get_partition_names_args')
if self.db_name != None:
oprot.writeFieldBegin('db_name', TType.STRING, 1)
oprot.writeString(self.db_name)
@@ -4817,17 +4105,9 @@
oprot.writeFieldBegin('tbl_name', TType.STRING, 2)
oprot.writeString(self.tbl_name)
oprot.writeFieldEnd()
- if self.pname != None:
- oprot.writeFieldBegin('pname', TType.STRING, 3)
- oprot.writeString(self.pname)
- oprot.writeFieldEnd()
- if self.params != None:
- oprot.writeFieldBegin('params', TType.MAP, 4)
- oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.params))
- for kiter166,viter167 in self.params.items():
- oprot.writeString(kiter166)
- oprot.writeString(viter167)
- oprot.writeMapEnd()
+ if self.max_parts != None:
+ oprot.writeFieldBegin('max_parts', TType.I16, 3)
+ oprot.writeI16(self.max_parts)
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -4844,23 +4124,19 @@
def __ne__(self, other):
return not (self == other)
-class set_partition_parameters_result:
+class get_partition_names_result:
thrift_spec = (
- (0, TType.BOOL, 'success', None, None, ), # 0
- (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1
- (2, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 2
+ (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
+ (1, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 1
)
def __init__(self, d=None):
self.success = None
- self.o1 = None
self.o2 = None
if isinstance(d, dict):
if 'success' in d:
self.success = d['success']
- if 'o1' in d:
- self.o1 = d['o1']
if 'o2' in d:
self.o2 = d['o2']
@@ -4874,18 +4150,17 @@
if ftype == TType.STOP:
break
if fid == 0:
- if ftype == TType.BOOL:
- self.success = iprot.readBool();
+ if ftype == TType.LIST:
+ self.success = []
+ (_etype146, _size143) = iprot.readListBegin()
+ for _i147 in xrange(_size143):
+ _elem148 = iprot.readString();
+ self.success.append(_elem148)
+ iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 1:
if ftype == TType.STRUCT:
- self.o1 = NoSuchObjectException()
- self.o1.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRUCT:
self.o2 = MetaException()
self.o2.read(iprot)
else:
@@ -4899,17 +4174,16 @@
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('set_partition_parameters_result')
+ oprot.writeStructBegin('get_partition_names_result')
if self.success != None:
- oprot.writeFieldBegin('success', TType.BOOL, 0)
- oprot.writeBool(self.success)
- oprot.writeFieldEnd()
- if self.o1 != None:
- oprot.writeFieldBegin('o1', TType.STRUCT, 1)
- self.o1.write(oprot)
+ oprot.writeFieldBegin('success', TType.LIST, 0)
+ oprot.writeListBegin(TType.STRING, len(self.success))
+ for iter149 in self.success:
+ oprot.writeString(iter149)
+ oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 != None:
- oprot.writeFieldBegin('o2', TType.STRUCT, 2)
+ oprot.writeFieldBegin('o2', TType.STRUCT, 1)
self.o2.write(oprot)
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -4962,10 +4236,10 @@
elif fid == 2:
if ftype == TType.LIST:
self.parts = []
- (_etype171, _size168) = iprot.readListBegin()
- for _i172 in xrange(_size168):
- _elem173 = iprot.readString();
- self.parts.append(_elem173)
+ (_etype153, _size150) = iprot.readListBegin()
+ for _i154 in xrange(_size150):
+ _elem155 = iprot.readString();
+ self.parts.append(_elem155)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -4986,8 +4260,8 @@
if self.parts != None:
oprot.writeFieldBegin('parts', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.parts))
- for iter174 in self.parts:
- oprot.writeString(iter174)
+ for iter156 in self.parts:
+ oprot.writeString(iter156)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
Modified: hadoop/core/trunk/src/contrib/hive/metastore/src/gen-py/hive_metastore/ThriftMetaStore.py
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hive/metastore/src/gen-py/hive_metastore/ThriftMetaStore.py?rev=697291&r1=697290&r2=697291&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hive/metastore/src/gen-py/hive_metastore/ThriftMetaStore.py (original)
+++ hadoop/core/trunk/src/contrib/hive/metastore/src/gen-py/hive_metastore/ThriftMetaStore.py Fri Sep 19 16:56:30 2008
@@ -722,11 +722,11 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype178, _size175) = iprot.readListBegin()
- for _i179 in xrange(_size175):
- _elem180 = FieldSchema()
- _elem180.read(iprot)
- self.success.append(_elem180)
+ (_etype160, _size157) = iprot.readListBegin()
+ for _i161 in xrange(_size157):
+ _elem162 = FieldSchema()
+ _elem162.read(iprot)
+ self.success.append(_elem162)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -761,8 +761,8 @@
if self.success != None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter181 in self.success:
- iter181.write(oprot)
+ for iter163 in self.success:
+ iter163.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ouch1 != None:
@@ -886,10 +886,10 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype185, _size182) = iprot.readListBegin()
- for _i186 in xrange(_size182):
- _elem187 = iprot.readString();
- self.success.append(_elem187)
+ (_etype167, _size164) = iprot.readListBegin()
+ for _i168 in xrange(_size164):
+ _elem169 = iprot.readString();
+ self.success.append(_elem169)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -924,8 +924,8 @@
if self.success != None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter188 in self.success:
- oprot.writeString(iter188)
+ for iter170 in self.success:
+ oprot.writeString(iter170)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ouch1 != None:
@@ -1037,11 +1037,11 @@
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype190, _vtype191, _size189 ) = iprot.readMapBegin()
- for _i193 in xrange(_size189):
- _key194 = iprot.readString();
- _val195 = iprot.readString();
- self.success[_key194] = _val195
+ (_ktype172, _vtype173, _size171 ) = iprot.readMapBegin()
+ for _i175 in xrange(_size171):
+ _key176 = iprot.readString();
+ _val177 = iprot.readString();
+ self.success[_key176] = _val177
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -1076,9 +1076,9 @@
if self.success != None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success))
- for kiter196,viter197 in self.success.items():
- oprot.writeString(kiter196)
- oprot.writeString(viter197)
+ for kiter178,viter179 in self.success.items():
+ oprot.writeString(kiter178)
+ oprot.writeString(viter179)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.ouch1 != None:
@@ -1145,11 +1145,11 @@
elif fid == -3:
if ftype == TType.MAP:
self.schema = {}
- (_ktype199, _vtype200, _size198 ) = iprot.readMapBegin()
- for _i202 in xrange(_size198):
- _key203 = iprot.readString();
- _val204 = iprot.readString();
- self.schema[_key203] = _val204
+ (_ktype181, _vtype182, _size180 ) = iprot.readMapBegin()
+ for _i184 in xrange(_size180):
+ _key185 = iprot.readString();
+ _val186 = iprot.readString();
+ self.schema[_key185] = _val186
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -1174,9 +1174,9 @@
if self.schema != None:
oprot.writeFieldBegin('schema', TType.MAP, -3)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.schema))
- for kiter205,viter206 in self.schema.items():
- oprot.writeString(kiter205)
- oprot.writeString(viter206)
+ for kiter187,viter188 in self.schema.items():
+ oprot.writeString(kiter187)
+ oprot.writeString(viter188)
oprot.writeMapEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -1310,11 +1310,11 @@
elif fid == -3:
if ftype == TType.MAP:
self.schema = {}
- (_ktype208, _vtype209, _size207 ) = iprot.readMapBegin()
- for _i211 in xrange(_size207):
- _key212 = iprot.readString();
- _val213 = iprot.readString();
- self.schema[_key212] = _val213
+ (_ktype190, _vtype191, _size189 ) = iprot.readMapBegin()
+ for _i193 in xrange(_size189):
+ _key194 = iprot.readString();
+ _val195 = iprot.readString();
+ self.schema[_key194] = _val195
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -1339,9 +1339,9 @@
if self.schema != None:
oprot.writeFieldBegin('schema', TType.MAP, -3)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.schema))
- for kiter214,viter215 in self.schema.items():
- oprot.writeString(kiter214)
- oprot.writeString(viter215)
+ for kiter196,viter197 in self.schema.items():
+ oprot.writeString(kiter196)
+ oprot.writeString(viter197)
oprot.writeMapEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -1959,10 +1959,10 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype219, _size216) = iprot.readListBegin()
- for _i220 in xrange(_size216):
- _elem221 = iprot.readString();
- self.success.append(_elem221)
+ (_etype201, _size198) = iprot.readListBegin()
+ for _i202 in xrange(_size198):
+ _elem203 = iprot.readString();
+ self.success.append(_elem203)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -1997,8 +1997,8 @@
if self.success != None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter222 in self.success:
- oprot.writeString(iter222)
+ for iter204 in self.success:
+ oprot.writeString(iter204)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ouch1 != None:
@@ -2094,10 +2094,10 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype226, _size223) = iprot.readListBegin()
- for _i227 in xrange(_size223):
- _elem228 = iprot.readString();
- self.success.append(_elem228)
+ (_etype208, _size205) = iprot.readListBegin()
+ for _i209 in xrange(_size205):
+ _elem210 = iprot.readString();
+ self.success.append(_elem210)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -2120,8 +2120,8 @@
if self.success != None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter229 in self.success:
- oprot.writeString(iter229)
+ for iter211 in self.success:
+ oprot.writeString(iter211)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ouch != None:
@@ -2261,10 +2261,10 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype233, _size230) = iprot.readListBegin()
- for _i234 in xrange(_size230):
- _elem235 = iprot.readString();
- self.success.append(_elem235)
+ (_etype215, _size212) = iprot.readListBegin()
+ for _i216 in xrange(_size212):
+ _elem217 = iprot.readString();
+ self.success.append(_elem217)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -2299,8 +2299,8 @@
if self.success != None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter236 in self.success:
- oprot.writeString(iter236)
+ for iter218 in self.success:
+ oprot.writeString(iter218)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ouch1 != None:
Modified: hadoop/core/trunk/src/contrib/hive/metastore/src/gen-py/hive_metastore/constants.py
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hive/metastore/src/gen-py/hive_metastore/constants.py?rev=697291&r1=697290&r2=697291&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hive/metastore/src/gen-py/hive_metastore/constants.py (original)
+++ hadoop/core/trunk/src/contrib/hive/metastore/src/gen-py/hive_metastore/constants.py Fri Sep 19 16:56:30 2008
@@ -7,8 +7,6 @@
from thrift.Thrift import *
from ttypes import *
-META_SERDE = 'com.facebook.serde.simple_meta.MetadataTypedColumnsetSerDe'
-
META_TABLE_COLUMNS = 'columns'
BUCKET_FIELD_NAME = 'bucket_field_name'
@@ -25,58 +23,9 @@
META_TABLE_SERDE = 'serde'
-SERIALIZATION_FORMAT = 'serialization.format'
-
-SERIALIZATION_CLASS = 'serialization.class'
-
-SERIALIZATION_LIB = 'serialization.lib'
-
META_TABLE_PARTITION_COLUMNS = 'partition_columns'
FILE_INPUT_FORMAT = 'file.inputformat'
FILE_OUTPUT_FORMAT = 'file.outputformat'
-KEY_COMMENTS = 'key_comments'
-
-VERSION_0_1 = '0.1'
-
-TINYINT_TYPE_NAME = 'tinyint'
-
-INT_TYPE_NAME = 'int'
-
-BIGINT_TYPE_NAME = 'bigint'
-
-FLOAT_TYPE_NAME = 'float'
-
-DOUBLE_TYPE_NAME = 'double'
-
-STRING_TYPE_NAME = 'string'
-
-DATE_TYPE_NAME = 'date'
-
-DATETIME_TYPE_NAME = 'datetime'
-
-TIMESTAMP_TYPE_NAME = 'timestamp'
-
-LIST_TYPE_NAME = 'list'
-
-MAP_TYPE_NAME = 'map'
-
-PrimitiveTypes = set([
- 'tinyint',
- 'int',
- 'bigint',
- 'float',
- 'double',
- 'string',
- 'date',
- 'datetime',
- 'timestamp',
-])
-
-CollectionTypes = set([
- 'list',
- 'map',
-])
-