Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java (original) +++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java Fri Jan 9 22:09:50 2015 @@ -272,9 +272,9 @@ public class ThriftHiveMetastore { public ShowCompactResponse show_compact(ShowCompactRequest rqst) throws org.apache.thrift.TException; - public NotificationEventResponse getNextNotification(NotificationEventRequest rqst) throws org.apache.thrift.TException; + public NotificationEventResponse get_next_notification(NotificationEventRequest rqst) throws org.apache.thrift.TException; - public CurrentNotificationEventId getCurrentNotificationEventId() throws org.apache.thrift.TException; + public CurrentNotificationEventId get_current_notificationEventId() throws org.apache.thrift.TException; } @@ -514,9 +514,9 @@ public class ThriftHiveMetastore { public void show_compact(ShowCompactRequest rqst, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.show_compact_call> resultHandler) throws org.apache.thrift.TException; - public void getNextNotification(NotificationEventRequest rqst, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getNextNotification_call> resultHandler) throws org.apache.thrift.TException; + public void get_next_notification(NotificationEventRequest rqst, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_next_notification_call> resultHandler) throws org.apache.thrift.TException; - public void getCurrentNotificationEventId(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getCurrentNotificationEventId_call> resultHandler) throws org.apache.thrift.TException; + public void get_current_notificationEventId(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_current_notificationEventId_call> resultHandler) throws org.apache.thrift.TException; } @@ -4008,49 +4008,49 @@ public class ThriftHiveMetastore { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "show_compact failed: unknown result"); } - public NotificationEventResponse getNextNotification(NotificationEventRequest rqst) throws org.apache.thrift.TException + public NotificationEventResponse get_next_notification(NotificationEventRequest rqst) throws org.apache.thrift.TException { - send_getNextNotification(rqst); - return recv_getNextNotification(); + send_get_next_notification(rqst); + return recv_get_next_notification(); } - public void send_getNextNotification(NotificationEventRequest rqst) throws org.apache.thrift.TException + public void send_get_next_notification(NotificationEventRequest rqst) throws org.apache.thrift.TException { - getNextNotification_args args = new getNextNotification_args(); + get_next_notification_args args = new get_next_notification_args(); args.setRqst(rqst); - sendBase("getNextNotification", args); + sendBase("get_next_notification", args); } - public NotificationEventResponse recv_getNextNotification() throws org.apache.thrift.TException + public NotificationEventResponse recv_get_next_notification() throws org.apache.thrift.TException { - getNextNotification_result result = new getNextNotification_result(); - receiveBase(result, "getNextNotification"); + get_next_notification_result result = new get_next_notification_result(); + receiveBase(result, "get_next_notification"); if (result.isSetSuccess()) { return result.success; } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getNextNotification failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_next_notification failed: unknown result"); } - public CurrentNotificationEventId getCurrentNotificationEventId() throws org.apache.thrift.TException + public CurrentNotificationEventId get_current_notificationEventId() throws org.apache.thrift.TException { - send_getCurrentNotificationEventId(); - return recv_getCurrentNotificationEventId(); + send_get_current_notificationEventId(); + return recv_get_current_notificationEventId(); } - public void send_getCurrentNotificationEventId() throws org.apache.thrift.TException + public void send_get_current_notificationEventId() throws org.apache.thrift.TException { - getCurrentNotificationEventId_args args = new getCurrentNotificationEventId_args(); - sendBase("getCurrentNotificationEventId", args); + get_current_notificationEventId_args args = new get_current_notificationEventId_args(); + sendBase("get_current_notificationEventId", args); } - public CurrentNotificationEventId recv_getCurrentNotificationEventId() throws org.apache.thrift.TException + public CurrentNotificationEventId recv_get_current_notificationEventId() throws org.apache.thrift.TException { - getCurrentNotificationEventId_result result = new getCurrentNotificationEventId_result(); - receiveBase(result, "getCurrentNotificationEventId"); + get_current_notificationEventId_result result = new get_current_notificationEventId_result(); + receiveBase(result, "get_current_notificationEventId"); if (result.isSetSuccess()) { return result.success; } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getCurrentNotificationEventId failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_current_notificationEventId failed: unknown result"); } } @@ -8256,23 +8256,23 @@ public class ThriftHiveMetastore { } } - public void getNextNotification(NotificationEventRequest rqst, org.apache.thrift.async.AsyncMethodCallback<getNextNotification_call> resultHandler) throws org.apache.thrift.TException { + public void get_next_notification(NotificationEventRequest rqst, org.apache.thrift.async.AsyncMethodCallback<get_next_notification_call> resultHandler) throws org.apache.thrift.TException { checkReady(); - getNextNotification_call method_call = new getNextNotification_call(rqst, resultHandler, this, ___protocolFactory, ___transport); + get_next_notification_call method_call = new get_next_notification_call(rqst, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } - public static class getNextNotification_call extends org.apache.thrift.async.TAsyncMethodCall { + public static class get_next_notification_call extends org.apache.thrift.async.TAsyncMethodCall { private NotificationEventRequest rqst; - public getNextNotification_call(NotificationEventRequest rqst, org.apache.thrift.async.AsyncMethodCallback<getNextNotification_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public get_next_notification_call(NotificationEventRequest rqst, org.apache.thrift.async.AsyncMethodCallback<get_next_notification_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.rqst = rqst; } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getNextNotification", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getNextNotification_args args = new getNextNotification_args(); + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_next_notification", org.apache.thrift.protocol.TMessageType.CALL, 0)); + get_next_notification_args args = new get_next_notification_args(); args.setRqst(rqst); args.write(prot); prot.writeMessageEnd(); @@ -8284,25 +8284,25 @@ public class ThriftHiveMetastore { } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_getNextNotification(); + return (new Client(prot)).recv_get_next_notification(); } } - public void getCurrentNotificationEventId(org.apache.thrift.async.AsyncMethodCallback<getCurrentNotificationEventId_call> resultHandler) throws org.apache.thrift.TException { + public void get_current_notificationEventId(org.apache.thrift.async.AsyncMethodCallback<get_current_notificationEventId_call> resultHandler) throws org.apache.thrift.TException { checkReady(); - getCurrentNotificationEventId_call method_call = new getCurrentNotificationEventId_call(resultHandler, this, ___protocolFactory, ___transport); + get_current_notificationEventId_call method_call = new get_current_notificationEventId_call(resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } - public static class getCurrentNotificationEventId_call extends org.apache.thrift.async.TAsyncMethodCall { - public getCurrentNotificationEventId_call(org.apache.thrift.async.AsyncMethodCallback<getCurrentNotificationEventId_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public static class get_current_notificationEventId_call extends org.apache.thrift.async.TAsyncMethodCall { + public get_current_notificationEventId_call(org.apache.thrift.async.AsyncMethodCallback<get_current_notificationEventId_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getCurrentNotificationEventId", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getCurrentNotificationEventId_args args = new getCurrentNotificationEventId_args(); + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_current_notificationEventId", org.apache.thrift.protocol.TMessageType.CALL, 0)); + get_current_notificationEventId_args args = new get_current_notificationEventId_args(); args.write(prot); prot.writeMessageEnd(); } @@ -8313,7 +8313,7 @@ public class ThriftHiveMetastore { } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_getCurrentNotificationEventId(); + return (new Client(prot)).recv_get_current_notificationEventId(); } } @@ -8447,8 +8447,8 @@ public class ThriftHiveMetastore { processMap.put("heartbeat_txn_range", new heartbeat_txn_range()); processMap.put("compact", new compact()); processMap.put("show_compact", new show_compact()); - processMap.put("getNextNotification", new getNextNotification()); - processMap.put("getCurrentNotificationEventId", new getCurrentNotificationEventId()); + processMap.put("get_next_notification", new get_next_notification()); + processMap.put("get_current_notificationEventId", new get_current_notificationEventId()); return processMap; } @@ -11507,42 +11507,42 @@ public class ThriftHiveMetastore { } } - public static class getNextNotification<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getNextNotification_args> { - public getNextNotification() { - super("getNextNotification"); + public static class get_next_notification<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_next_notification_args> { + public get_next_notification() { + super("get_next_notification"); } - public getNextNotification_args getEmptyArgsInstance() { - return new getNextNotification_args(); + public get_next_notification_args getEmptyArgsInstance() { + return new get_next_notification_args(); } protected boolean isOneway() { return false; } - public getNextNotification_result getResult(I iface, getNextNotification_args args) throws org.apache.thrift.TException { - getNextNotification_result result = new getNextNotification_result(); - result.success = iface.getNextNotification(args.rqst); + public get_next_notification_result getResult(I iface, get_next_notification_args args) throws org.apache.thrift.TException { + get_next_notification_result result = new get_next_notification_result(); + result.success = iface.get_next_notification(args.rqst); return result; } } - public static class getCurrentNotificationEventId<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getCurrentNotificationEventId_args> { - public getCurrentNotificationEventId() { - super("getCurrentNotificationEventId"); + public static class get_current_notificationEventId<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_current_notificationEventId_args> { + public get_current_notificationEventId() { + super("get_current_notificationEventId"); } - public getCurrentNotificationEventId_args getEmptyArgsInstance() { - return new getCurrentNotificationEventId_args(); + public get_current_notificationEventId_args getEmptyArgsInstance() { + return new get_current_notificationEventId_args(); } protected boolean isOneway() { return false; } - public getCurrentNotificationEventId_result getResult(I iface, getCurrentNotificationEventId_args args) throws org.apache.thrift.TException { - getCurrentNotificationEventId_result result = new getCurrentNotificationEventId_result(); - result.success = iface.getCurrentNotificationEventId(); + public get_current_notificationEventId_result getResult(I iface, get_current_notificationEventId_args args) throws org.apache.thrift.TException { + get_current_notificationEventId_result result = new get_current_notificationEventId_result(); + result.success = iface.get_current_notificationEventId(); return result; } } @@ -136197,15 +136197,15 @@ public class ThriftHiveMetastore { } - public static class getNextNotification_args implements org.apache.thrift.TBase<getNextNotification_args, getNextNotification_args._Fields>, java.io.Serializable, Cloneable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getNextNotification_args"); + public static class get_next_notification_args implements org.apache.thrift.TBase<get_next_notification_args, get_next_notification_args._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("get_next_notification_args"); private static final org.apache.thrift.protocol.TField RQST_FIELD_DESC = new org.apache.thrift.protocol.TField("rqst", org.apache.thrift.protocol.TType.STRUCT, (short)1); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getNextNotification_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getNextNotification_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new get_next_notification_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new get_next_notification_argsTupleSchemeFactory()); } private NotificationEventRequest rqst; // required @@ -136275,13 +136275,13 @@ public class ThriftHiveMetastore { tmpMap.put(_Fields.RQST, new org.apache.thrift.meta_data.FieldMetaData("rqst", org.apache.thrift.TFieldRequirementType.DEFAULT, new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, NotificationEventRequest.class))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getNextNotification_args.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_next_notification_args.class, metaDataMap); } - public getNextNotification_args() { + public get_next_notification_args() { } - public getNextNotification_args( + public get_next_notification_args( NotificationEventRequest rqst) { this(); @@ -136291,14 +136291,14 @@ public class ThriftHiveMetastore { /** * Performs a deep copy on <i>other</i>. */ - public getNextNotification_args(getNextNotification_args other) { + public get_next_notification_args(get_next_notification_args other) { if (other.isSetRqst()) { this.rqst = new NotificationEventRequest(other.rqst); } } - public getNextNotification_args deepCopy() { - return new getNextNotification_args(this); + public get_next_notification_args deepCopy() { + return new get_next_notification_args(this); } @Override @@ -136368,12 +136368,12 @@ public class ThriftHiveMetastore { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof getNextNotification_args) - return this.equals((getNextNotification_args)that); + if (that instanceof get_next_notification_args) + return this.equals((get_next_notification_args)that); return false; } - public boolean equals(getNextNotification_args that) { + public boolean equals(get_next_notification_args that) { if (that == null) return false; @@ -136401,13 +136401,13 @@ public class ThriftHiveMetastore { return builder.toHashCode(); } - public int compareTo(getNextNotification_args other) { + public int compareTo(get_next_notification_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - getNextNotification_args typedOther = (getNextNotification_args)other; + get_next_notification_args typedOther = (get_next_notification_args)other; lastComparison = Boolean.valueOf(isSetRqst()).compareTo(typedOther.isSetRqst()); if (lastComparison != 0) { @@ -136436,7 +136436,7 @@ public class ThriftHiveMetastore { @Override public String toString() { - StringBuilder sb = new StringBuilder("getNextNotification_args("); + StringBuilder sb = new StringBuilder("get_next_notification_args("); boolean first = true; sb.append("rqst:"); @@ -136474,15 +136474,15 @@ public class ThriftHiveMetastore { } } - private static class getNextNotification_argsStandardSchemeFactory implements SchemeFactory { - public getNextNotification_argsStandardScheme getScheme() { - return new getNextNotification_argsStandardScheme(); + private static class get_next_notification_argsStandardSchemeFactory implements SchemeFactory { + public get_next_notification_argsStandardScheme getScheme() { + return new get_next_notification_argsStandardScheme(); } } - private static class getNextNotification_argsStandardScheme extends StandardScheme<getNextNotification_args> { + private static class get_next_notification_argsStandardScheme extends StandardScheme<get_next_notification_args> { - public void read(org.apache.thrift.protocol.TProtocol iprot, getNextNotification_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, get_next_notification_args struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -136510,7 +136510,7 @@ public class ThriftHiveMetastore { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getNextNotification_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, get_next_notification_args struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -136525,16 +136525,16 @@ public class ThriftHiveMetastore { } - private static class getNextNotification_argsTupleSchemeFactory implements SchemeFactory { - public getNextNotification_argsTupleScheme getScheme() { - return new getNextNotification_argsTupleScheme(); + private static class get_next_notification_argsTupleSchemeFactory implements SchemeFactory { + public get_next_notification_argsTupleScheme getScheme() { + return new get_next_notification_argsTupleScheme(); } } - private static class getNextNotification_argsTupleScheme extends TupleScheme<getNextNotification_args> { + private static class get_next_notification_argsTupleScheme extends TupleScheme<get_next_notification_args> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getNextNotification_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, get_next_notification_args struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetRqst()) { @@ -136547,7 +136547,7 @@ public class ThriftHiveMetastore { } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getNextNotification_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, get_next_notification_args struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { @@ -136560,15 +136560,15 @@ public class ThriftHiveMetastore { } - public static class getNextNotification_result implements org.apache.thrift.TBase<getNextNotification_result, getNextNotification_result._Fields>, java.io.Serializable, Cloneable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getNextNotification_result"); + public static class get_next_notification_result implements org.apache.thrift.TBase<get_next_notification_result, get_next_notification_result._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("get_next_notification_result"); private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getNextNotification_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getNextNotification_resultTupleSchemeFactory()); + schemes.put(StandardScheme.class, new get_next_notification_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new get_next_notification_resultTupleSchemeFactory()); } private NotificationEventResponse success; // required @@ -136638,13 +136638,13 @@ public class ThriftHiveMetastore { tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, NotificationEventResponse.class))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getNextNotification_result.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_next_notification_result.class, metaDataMap); } - public getNextNotification_result() { + public get_next_notification_result() { } - public getNextNotification_result( + public get_next_notification_result( NotificationEventResponse success) { this(); @@ -136654,14 +136654,14 @@ public class ThriftHiveMetastore { /** * Performs a deep copy on <i>other</i>. */ - public getNextNotification_result(getNextNotification_result other) { + public get_next_notification_result(get_next_notification_result other) { if (other.isSetSuccess()) { this.success = new NotificationEventResponse(other.success); } } - public getNextNotification_result deepCopy() { - return new getNextNotification_result(this); + public get_next_notification_result deepCopy() { + return new get_next_notification_result(this); } @Override @@ -136731,12 +136731,12 @@ public class ThriftHiveMetastore { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof getNextNotification_result) - return this.equals((getNextNotification_result)that); + if (that instanceof get_next_notification_result) + return this.equals((get_next_notification_result)that); return false; } - public boolean equals(getNextNotification_result that) { + public boolean equals(get_next_notification_result that) { if (that == null) return false; @@ -136764,13 +136764,13 @@ public class ThriftHiveMetastore { return builder.toHashCode(); } - public int compareTo(getNextNotification_result other) { + public int compareTo(get_next_notification_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - getNextNotification_result typedOther = (getNextNotification_result)other; + get_next_notification_result typedOther = (get_next_notification_result)other; lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); if (lastComparison != 0) { @@ -136799,7 +136799,7 @@ public class ThriftHiveMetastore { @Override public String toString() { - StringBuilder sb = new StringBuilder("getNextNotification_result("); + StringBuilder sb = new StringBuilder("get_next_notification_result("); boolean first = true; sb.append("success:"); @@ -136837,15 +136837,15 @@ public class ThriftHiveMetastore { } } - private static class getNextNotification_resultStandardSchemeFactory implements SchemeFactory { - public getNextNotification_resultStandardScheme getScheme() { - return new getNextNotification_resultStandardScheme(); + private static class get_next_notification_resultStandardSchemeFactory implements SchemeFactory { + public get_next_notification_resultStandardScheme getScheme() { + return new get_next_notification_resultStandardScheme(); } } - private static class getNextNotification_resultStandardScheme extends StandardScheme<getNextNotification_result> { + private static class get_next_notification_resultStandardScheme extends StandardScheme<get_next_notification_result> { - public void read(org.apache.thrift.protocol.TProtocol iprot, getNextNotification_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, get_next_notification_result struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -136873,7 +136873,7 @@ public class ThriftHiveMetastore { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getNextNotification_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, get_next_notification_result struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -136888,16 +136888,16 @@ public class ThriftHiveMetastore { } - private static class getNextNotification_resultTupleSchemeFactory implements SchemeFactory { - public getNextNotification_resultTupleScheme getScheme() { - return new getNextNotification_resultTupleScheme(); + private static class get_next_notification_resultTupleSchemeFactory implements SchemeFactory { + public get_next_notification_resultTupleScheme getScheme() { + return new get_next_notification_resultTupleScheme(); } } - private static class getNextNotification_resultTupleScheme extends TupleScheme<getNextNotification_result> { + private static class get_next_notification_resultTupleScheme extends TupleScheme<get_next_notification_result> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getNextNotification_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, get_next_notification_result struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -136910,7 +136910,7 @@ public class ThriftHiveMetastore { } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getNextNotification_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, get_next_notification_result struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { @@ -136923,14 +136923,14 @@ public class ThriftHiveMetastore { } - public static class getCurrentNotificationEventId_args implements org.apache.thrift.TBase<getCurrentNotificationEventId_args, getCurrentNotificationEventId_args._Fields>, java.io.Serializable, Cloneable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getCurrentNotificationEventId_args"); + public static class get_current_notificationEventId_args implements org.apache.thrift.TBase<get_current_notificationEventId_args, get_current_notificationEventId_args._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("get_current_notificationEventId_args"); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getCurrentNotificationEventId_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getCurrentNotificationEventId_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new get_current_notificationEventId_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new get_current_notificationEventId_argsTupleSchemeFactory()); } @@ -136993,20 +136993,20 @@ public class ThriftHiveMetastore { static { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getCurrentNotificationEventId_args.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_current_notificationEventId_args.class, metaDataMap); } - public getCurrentNotificationEventId_args() { + public get_current_notificationEventId_args() { } /** * Performs a deep copy on <i>other</i>. */ - public getCurrentNotificationEventId_args(getCurrentNotificationEventId_args other) { + public get_current_notificationEventId_args(get_current_notificationEventId_args other) { } - public getCurrentNotificationEventId_args deepCopy() { - return new getCurrentNotificationEventId_args(this); + public get_current_notificationEventId_args deepCopy() { + return new get_current_notificationEventId_args(this); } @Override @@ -137039,12 +137039,12 @@ public class ThriftHiveMetastore { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof getCurrentNotificationEventId_args) - return this.equals((getCurrentNotificationEventId_args)that); + if (that instanceof get_current_notificationEventId_args) + return this.equals((get_current_notificationEventId_args)that); return false; } - public boolean equals(getCurrentNotificationEventId_args that) { + public boolean equals(get_current_notificationEventId_args that) { if (that == null) return false; @@ -137058,13 +137058,13 @@ public class ThriftHiveMetastore { return builder.toHashCode(); } - public int compareTo(getCurrentNotificationEventId_args other) { + public int compareTo(get_current_notificationEventId_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - getCurrentNotificationEventId_args typedOther = (getCurrentNotificationEventId_args)other; + get_current_notificationEventId_args typedOther = (get_current_notificationEventId_args)other; return 0; } @@ -137083,7 +137083,7 @@ public class ThriftHiveMetastore { @Override public String toString() { - StringBuilder sb = new StringBuilder("getCurrentNotificationEventId_args("); + StringBuilder sb = new StringBuilder("get_current_notificationEventId_args("); boolean first = true; sb.append(")"); @@ -137111,15 +137111,15 @@ public class ThriftHiveMetastore { } } - private static class getCurrentNotificationEventId_argsStandardSchemeFactory implements SchemeFactory { - public getCurrentNotificationEventId_argsStandardScheme getScheme() { - return new getCurrentNotificationEventId_argsStandardScheme(); + private static class get_current_notificationEventId_argsStandardSchemeFactory implements SchemeFactory { + public get_current_notificationEventId_argsStandardScheme getScheme() { + return new get_current_notificationEventId_argsStandardScheme(); } } - private static class getCurrentNotificationEventId_argsStandardScheme extends StandardScheme<getCurrentNotificationEventId_args> { + private static class get_current_notificationEventId_argsStandardScheme extends StandardScheme<get_current_notificationEventId_args> { - public void read(org.apache.thrift.protocol.TProtocol iprot, getCurrentNotificationEventId_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, get_current_notificationEventId_args struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -137138,7 +137138,7 @@ public class ThriftHiveMetastore { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getCurrentNotificationEventId_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, get_current_notificationEventId_args struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -137148,36 +137148,36 @@ public class ThriftHiveMetastore { } - private static class getCurrentNotificationEventId_argsTupleSchemeFactory implements SchemeFactory { - public getCurrentNotificationEventId_argsTupleScheme getScheme() { - return new getCurrentNotificationEventId_argsTupleScheme(); + private static class get_current_notificationEventId_argsTupleSchemeFactory implements SchemeFactory { + public get_current_notificationEventId_argsTupleScheme getScheme() { + return new get_current_notificationEventId_argsTupleScheme(); } } - private static class getCurrentNotificationEventId_argsTupleScheme extends TupleScheme<getCurrentNotificationEventId_args> { + private static class get_current_notificationEventId_argsTupleScheme extends TupleScheme<get_current_notificationEventId_args> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getCurrentNotificationEventId_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, get_current_notificationEventId_args struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getCurrentNotificationEventId_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, get_current_notificationEventId_args struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; } } } - public static class getCurrentNotificationEventId_result implements org.apache.thrift.TBase<getCurrentNotificationEventId_result, getCurrentNotificationEventId_result._Fields>, java.io.Serializable, Cloneable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getCurrentNotificationEventId_result"); + public static class get_current_notificationEventId_result implements org.apache.thrift.TBase<get_current_notificationEventId_result, get_current_notificationEventId_result._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("get_current_notificationEventId_result"); private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getCurrentNotificationEventId_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getCurrentNotificationEventId_resultTupleSchemeFactory()); + schemes.put(StandardScheme.class, new get_current_notificationEventId_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new get_current_notificationEventId_resultTupleSchemeFactory()); } private CurrentNotificationEventId success; // required @@ -137247,13 +137247,13 @@ public class ThriftHiveMetastore { tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, CurrentNotificationEventId.class))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getCurrentNotificationEventId_result.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_current_notificationEventId_result.class, metaDataMap); } - public getCurrentNotificationEventId_result() { + public get_current_notificationEventId_result() { } - public getCurrentNotificationEventId_result( + public get_current_notificationEventId_result( CurrentNotificationEventId success) { this(); @@ -137263,14 +137263,14 @@ public class ThriftHiveMetastore { /** * Performs a deep copy on <i>other</i>. */ - public getCurrentNotificationEventId_result(getCurrentNotificationEventId_result other) { + public get_current_notificationEventId_result(get_current_notificationEventId_result other) { if (other.isSetSuccess()) { this.success = new CurrentNotificationEventId(other.success); } } - public getCurrentNotificationEventId_result deepCopy() { - return new getCurrentNotificationEventId_result(this); + public get_current_notificationEventId_result deepCopy() { + return new get_current_notificationEventId_result(this); } @Override @@ -137340,12 +137340,12 @@ public class ThriftHiveMetastore { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof getCurrentNotificationEventId_result) - return this.equals((getCurrentNotificationEventId_result)that); + if (that instanceof get_current_notificationEventId_result) + return this.equals((get_current_notificationEventId_result)that); return false; } - public boolean equals(getCurrentNotificationEventId_result that) { + public boolean equals(get_current_notificationEventId_result that) { if (that == null) return false; @@ -137373,13 +137373,13 @@ public class ThriftHiveMetastore { return builder.toHashCode(); } - public int compareTo(getCurrentNotificationEventId_result other) { + public int compareTo(get_current_notificationEventId_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - getCurrentNotificationEventId_result typedOther = (getCurrentNotificationEventId_result)other; + get_current_notificationEventId_result typedOther = (get_current_notificationEventId_result)other; lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); if (lastComparison != 0) { @@ -137408,7 +137408,7 @@ public class ThriftHiveMetastore { @Override public String toString() { - StringBuilder sb = new StringBuilder("getCurrentNotificationEventId_result("); + StringBuilder sb = new StringBuilder("get_current_notificationEventId_result("); boolean first = true; sb.append("success:"); @@ -137446,15 +137446,15 @@ public class ThriftHiveMetastore { } } - private static class getCurrentNotificationEventId_resultStandardSchemeFactory implements SchemeFactory { - public getCurrentNotificationEventId_resultStandardScheme getScheme() { - return new getCurrentNotificationEventId_resultStandardScheme(); + private static class get_current_notificationEventId_resultStandardSchemeFactory implements SchemeFactory { + public get_current_notificationEventId_resultStandardScheme getScheme() { + return new get_current_notificationEventId_resultStandardScheme(); } } - private static class getCurrentNotificationEventId_resultStandardScheme extends StandardScheme<getCurrentNotificationEventId_result> { + private static class get_current_notificationEventId_resultStandardScheme extends StandardScheme<get_current_notificationEventId_result> { - public void read(org.apache.thrift.protocol.TProtocol iprot, getCurrentNotificationEventId_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, get_current_notificationEventId_result struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -137482,7 +137482,7 @@ public class ThriftHiveMetastore { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getCurrentNotificationEventId_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, get_current_notificationEventId_result struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -137497,16 +137497,16 @@ public class ThriftHiveMetastore { } - private static class getCurrentNotificationEventId_resultTupleSchemeFactory implements SchemeFactory { - public getCurrentNotificationEventId_resultTupleScheme getScheme() { - return new getCurrentNotificationEventId_resultTupleScheme(); + private static class get_current_notificationEventId_resultTupleSchemeFactory implements SchemeFactory { + public get_current_notificationEventId_resultTupleScheme getScheme() { + return new get_current_notificationEventId_resultTupleScheme(); } } - private static class getCurrentNotificationEventId_resultTupleScheme extends TupleScheme<getCurrentNotificationEventId_result> { + private static class get_current_notificationEventId_resultTupleScheme extends TupleScheme<get_current_notificationEventId_result> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getCurrentNotificationEventId_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, get_current_notificationEventId_result struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -137519,7 +137519,7 @@ public class ThriftHiveMetastore { } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getCurrentNotificationEventId_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, get_current_notificationEventId_result struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) {
Modified: hive/trunk/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php (original) +++ hive/trunk/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php Fri Jan 9 22:09:50 2015 @@ -133,8 +133,8 @@ interface ThriftHiveMetastoreIf extends public function heartbeat_txn_range(\metastore\HeartbeatTxnRangeRequest $txns); public function compact(\metastore\CompactionRequest $rqst); public function show_compact(\metastore\ShowCompactRequest $rqst); - public function getNextNotification(\metastore\NotificationEventRequest $rqst); - public function getCurrentNotificationEventId(); + public function get_next_notification(\metastore\NotificationEventRequest $rqst); + public function get_current_notificationEventId(); } class ThriftHiveMetastoreClient extends \FacebookServiceClient implements \metastore\ThriftHiveMetastoreIf { @@ -6886,34 +6886,34 @@ class ThriftHiveMetastoreClient extends throw new \Exception("show_compact failed: unknown result"); } - public function getNextNotification(\metastore\NotificationEventRequest $rqst) + public function get_next_notification(\metastore\NotificationEventRequest $rqst) { - $this->send_getNextNotification($rqst); - return $this->recv_getNextNotification(); + $this->send_get_next_notification($rqst); + return $this->recv_get_next_notification(); } - public function send_getNextNotification(\metastore\NotificationEventRequest $rqst) + public function send_get_next_notification(\metastore\NotificationEventRequest $rqst) { - $args = new \metastore\ThriftHiveMetastore_getNextNotification_args(); + $args = new \metastore\ThriftHiveMetastore_get_next_notification_args(); $args->rqst = $rqst; $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'getNextNotification', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'get_next_notification', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('getNextNotification', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('get_next_notification', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_getNextNotification() + public function recv_get_next_notification() { $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_getNextNotification_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_get_next_notification_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -6927,43 +6927,43 @@ class ThriftHiveMetastoreClient extends $this->input_->readMessageEnd(); throw $x; } - $result = new \metastore\ThriftHiveMetastore_getNextNotification_result(); + $result = new \metastore\ThriftHiveMetastore_get_next_notification_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } if ($result->success !== null) { return $result->success; } - throw new \Exception("getNextNotification failed: unknown result"); + throw new \Exception("get_next_notification failed: unknown result"); } - public function getCurrentNotificationEventId() + public function get_current_notificationEventId() { - $this->send_getCurrentNotificationEventId(); - return $this->recv_getCurrentNotificationEventId(); + $this->send_get_current_notificationEventId(); + return $this->recv_get_current_notificationEventId(); } - public function send_getCurrentNotificationEventId() + public function send_get_current_notificationEventId() { - $args = new \metastore\ThriftHiveMetastore_getCurrentNotificationEventId_args(); + $args = new \metastore\ThriftHiveMetastore_get_current_notificationEventId_args(); $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'getCurrentNotificationEventId', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'get_current_notificationEventId', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('getCurrentNotificationEventId', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('get_current_notificationEventId', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_getCurrentNotificationEventId() + public function recv_get_current_notificationEventId() { $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_getCurrentNotificationEventId_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_get_current_notificationEventId_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -6977,14 +6977,14 @@ class ThriftHiveMetastoreClient extends $this->input_->readMessageEnd(); throw $x; } - $result = new \metastore\ThriftHiveMetastore_getCurrentNotificationEventId_result(); + $result = new \metastore\ThriftHiveMetastore_get_current_notificationEventId_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } if ($result->success !== null) { return $result->success; } - throw new \Exception("getCurrentNotificationEventId failed: unknown result"); + throw new \Exception("get_current_notificationEventId failed: unknown result"); } } @@ -33334,7 +33334,7 @@ class ThriftHiveMetastore_show_compact_r } -class ThriftHiveMetastore_getNextNotification_args { +class ThriftHiveMetastore_get_next_notification_args { static $_TSPEC; public $rqst = null; @@ -33357,7 +33357,7 @@ class ThriftHiveMetastore_getNextNotific } public function getName() { - return 'ThriftHiveMetastore_getNextNotification_args'; + return 'ThriftHiveMetastore_get_next_notification_args'; } public function read($input) @@ -33395,7 +33395,7 @@ class ThriftHiveMetastore_getNextNotific public function write($output) { $xfer = 0; - $xfer += $output->writeStructBegin('ThriftHiveMetastore_getNextNotification_args'); + $xfer += $output->writeStructBegin('ThriftHiveMetastore_get_next_notification_args'); if ($this->rqst !== null) { if (!is_object($this->rqst)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); @@ -33411,7 +33411,7 @@ class ThriftHiveMetastore_getNextNotific } -class ThriftHiveMetastore_getNextNotification_result { +class ThriftHiveMetastore_get_next_notification_result { static $_TSPEC; public $success = null; @@ -33434,7 +33434,7 @@ class ThriftHiveMetastore_getNextNotific } public function getName() { - return 'ThriftHiveMetastore_getNextNotification_result'; + return 'ThriftHiveMetastore_get_next_notification_result'; } public function read($input) @@ -33472,7 +33472,7 @@ class ThriftHiveMetastore_getNextNotific public function write($output) { $xfer = 0; - $xfer += $output->writeStructBegin('ThriftHiveMetastore_getNextNotification_result'); + $xfer += $output->writeStructBegin('ThriftHiveMetastore_get_next_notification_result'); if ($this->success !== null) { if (!is_object($this->success)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); @@ -33488,7 +33488,7 @@ class ThriftHiveMetastore_getNextNotific } -class ThriftHiveMetastore_getCurrentNotificationEventId_args { +class ThriftHiveMetastore_get_current_notificationEventId_args { static $_TSPEC; @@ -33500,7 +33500,7 @@ class ThriftHiveMetastore_getCurrentNoti } public function getName() { - return 'ThriftHiveMetastore_getCurrentNotificationEventId_args'; + return 'ThriftHiveMetastore_get_current_notificationEventId_args'; } public function read($input) @@ -33530,7 +33530,7 @@ class ThriftHiveMetastore_getCurrentNoti public function write($output) { $xfer = 0; - $xfer += $output->writeStructBegin('ThriftHiveMetastore_getCurrentNotificationEventId_args'); + $xfer += $output->writeStructBegin('ThriftHiveMetastore_get_current_notificationEventId_args'); $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -33538,7 +33538,7 @@ class ThriftHiveMetastore_getCurrentNoti } -class ThriftHiveMetastore_getCurrentNotificationEventId_result { +class ThriftHiveMetastore_get_current_notificationEventId_result { static $_TSPEC; public $success = null; @@ -33561,7 +33561,7 @@ class ThriftHiveMetastore_getCurrentNoti } public function getName() { - return 'ThriftHiveMetastore_getCurrentNotificationEventId_result'; + return 'ThriftHiveMetastore_get_current_notificationEventId_result'; } public function read($input) @@ -33599,7 +33599,7 @@ class ThriftHiveMetastore_getCurrentNoti public function write($output) { $xfer = 0; - $xfer += $output->writeStructBegin('ThriftHiveMetastore_getCurrentNotificationEventId_result'); + $xfer += $output->writeStructBegin('ThriftHiveMetastore_get_current_notificationEventId_result'); if ($this->success !== null) { if (!is_object($this->success)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote (original) +++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote Fri Jan 9 22:09:50 2015 @@ -140,8 +140,8 @@ if len(sys.argv) <= 1 or sys.argv[1] == print ' HeartbeatTxnRangeResponse heartbeat_txn_range(HeartbeatTxnRangeRequest txns)' print ' void compact(CompactionRequest rqst)' print ' ShowCompactResponse show_compact(ShowCompactRequest rqst)' - print ' NotificationEventResponse getNextNotification(NotificationEventRequest rqst)' - print ' CurrentNotificationEventId getCurrentNotificationEventId()' + print ' NotificationEventResponse get_next_notification(NotificationEventRequest rqst)' + print ' CurrentNotificationEventId get_current_notificationEventId()' print '' sys.exit(0) @@ -895,17 +895,17 @@ elif cmd == 'show_compact': sys.exit(1) pp.pprint(client.show_compact(eval(args[0]),)) -elif cmd == 'getNextNotification': +elif cmd == 'get_next_notification': if len(args) != 1: - print 'getNextNotification requires 1 args' + print 'get_next_notification requires 1 args' sys.exit(1) - pp.pprint(client.getNextNotification(eval(args[0]),)) + pp.pprint(client.get_next_notification(eval(args[0]),)) -elif cmd == 'getCurrentNotificationEventId': +elif cmd == 'get_current_notificationEventId': if len(args) != 0: - print 'getCurrentNotificationEventId requires 0 args' + print 'get_current_notificationEventId requires 0 args' sys.exit(1) - pp.pprint(client.getCurrentNotificationEventId()) + pp.pprint(client.get_current_notificationEventId()) else: print 'Unrecognized method %s' % cmd Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py (original) +++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py Fri Jan 9 22:09:50 2015 @@ -976,14 +976,14 @@ class Iface(fb303.FacebookService.Iface) """ pass - def getNextNotification(self, rqst): + def get_next_notification(self, rqst): """ Parameters: - rqst """ pass - def getCurrentNotificationEventId(self, ): + def get_current_notificationEventId(self, ): pass @@ -5206,60 +5206,60 @@ class Client(fb303.FacebookService.Clien return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "show_compact failed: unknown result"); - def getNextNotification(self, rqst): + def get_next_notification(self, rqst): """ Parameters: - rqst """ - self.send_getNextNotification(rqst) - return self.recv_getNextNotification() + self.send_get_next_notification(rqst) + return self.recv_get_next_notification() - def send_getNextNotification(self, rqst): - self._oprot.writeMessageBegin('getNextNotification', TMessageType.CALL, self._seqid) - args = getNextNotification_args() + def send_get_next_notification(self, rqst): + self._oprot.writeMessageBegin('get_next_notification', TMessageType.CALL, self._seqid) + args = get_next_notification_args() args.rqst = rqst args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getNextNotification(self, ): + def recv_get_next_notification(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getNextNotification_result() + result = get_next_notification_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getNextNotification failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_next_notification failed: unknown result"); - def getCurrentNotificationEventId(self, ): - self.send_getCurrentNotificationEventId() - return self.recv_getCurrentNotificationEventId() + def get_current_notificationEventId(self, ): + self.send_get_current_notificationEventId() + return self.recv_get_current_notificationEventId() - def send_getCurrentNotificationEventId(self, ): - self._oprot.writeMessageBegin('getCurrentNotificationEventId', TMessageType.CALL, self._seqid) - args = getCurrentNotificationEventId_args() + def send_get_current_notificationEventId(self, ): + self._oprot.writeMessageBegin('get_current_notificationEventId', TMessageType.CALL, self._seqid) + args = get_current_notificationEventId_args() args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getCurrentNotificationEventId(self, ): + def recv_get_current_notificationEventId(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getCurrentNotificationEventId_result() + result = get_current_notificationEventId_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getCurrentNotificationEventId failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_current_notificationEventId failed: unknown result"); class Processor(fb303.FacebookService.Processor, Iface, TProcessor): @@ -5382,8 +5382,8 @@ class Processor(fb303.FacebookService.Pr self._processMap["heartbeat_txn_range"] = Processor.process_heartbeat_txn_range self._processMap["compact"] = Processor.process_compact self._processMap["show_compact"] = Processor.process_show_compact - self._processMap["getNextNotification"] = Processor.process_getNextNotification - self._processMap["getCurrentNotificationEventId"] = Processor.process_getCurrentNotificationEventId + self._processMap["get_next_notification"] = Processor.process_get_next_notification + self._processMap["get_current_notificationEventId"] = Processor.process_get_current_notificationEventId def process(self, iprot, oprot): (name, type, seqid) = iprot.readMessageBegin() @@ -7269,24 +7269,24 @@ class Processor(fb303.FacebookService.Pr oprot.writeMessageEnd() oprot.trans.flush() - def process_getNextNotification(self, seqid, iprot, oprot): - args = getNextNotification_args() + def process_get_next_notification(self, seqid, iprot, oprot): + args = get_next_notification_args() args.read(iprot) iprot.readMessageEnd() - result = getNextNotification_result() - result.success = self._handler.getNextNotification(args.rqst) - oprot.writeMessageBegin("getNextNotification", TMessageType.REPLY, seqid) + result = get_next_notification_result() + result.success = self._handler.get_next_notification(args.rqst) + oprot.writeMessageBegin("get_next_notification", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_getCurrentNotificationEventId(self, seqid, iprot, oprot): - args = getCurrentNotificationEventId_args() + def process_get_current_notificationEventId(self, seqid, iprot, oprot): + args = get_current_notificationEventId_args() args.read(iprot) iprot.readMessageEnd() - result = getCurrentNotificationEventId_result() - result.success = self._handler.getCurrentNotificationEventId() - oprot.writeMessageBegin("getCurrentNotificationEventId", TMessageType.REPLY, seqid) + result = get_current_notificationEventId_result() + result.success = self._handler.get_current_notificationEventId() + oprot.writeMessageBegin("get_current_notificationEventId", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -26270,7 +26270,7 @@ class show_compact_result: def __ne__(self, other): return not (self == other) -class getNextNotification_args: +class get_next_notification_args: """ Attributes: - rqst @@ -26308,7 +26308,7 @@ class getNextNotification_args: 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('getNextNotification_args') + oprot.writeStructBegin('get_next_notification_args') if self.rqst is not None: oprot.writeFieldBegin('rqst', TType.STRUCT, 1) self.rqst.write(oprot) @@ -26331,7 +26331,7 @@ class getNextNotification_args: def __ne__(self, other): return not (self == other) -class getNextNotification_result: +class get_next_notification_result: """ Attributes: - success @@ -26368,7 +26368,7 @@ class getNextNotification_result: 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('getNextNotification_result') + oprot.writeStructBegin('get_next_notification_result') if self.success is not None: oprot.writeFieldBegin('success', TType.STRUCT, 0) self.success.write(oprot) @@ -26391,7 +26391,7 @@ class getNextNotification_result: def __ne__(self, other): return not (self == other) -class getCurrentNotificationEventId_args: +class get_current_notificationEventId_args: thrift_spec = ( ) @@ -26414,7 +26414,7 @@ class getCurrentNotificationEventId_args 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('getCurrentNotificationEventId_args') + oprot.writeStructBegin('get_current_notificationEventId_args') oprot.writeFieldStop() oprot.writeStructEnd() @@ -26433,7 +26433,7 @@ class getCurrentNotificationEventId_args def __ne__(self, other): return not (self == other) -class getCurrentNotificationEventId_result: +class get_current_notificationEventId_result: """ Attributes: - success @@ -26470,7 +26470,7 @@ class getCurrentNotificationEventId_resu 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('getCurrentNotificationEventId_result') + oprot.writeStructBegin('get_current_notificationEventId_result') if self.success is not None: oprot.writeFieldBegin('success', TType.STRUCT, 0) self.success.write(oprot) Modified: hive/trunk/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb (original) +++ hive/trunk/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb Fri Jan 9 22:09:50 2015 @@ -1977,34 +1977,34 @@ module ThriftHiveMetastore raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'show_compact failed: unknown result') end - def getNextNotification(rqst) - send_getNextNotification(rqst) - return recv_getNextNotification() + def get_next_notification(rqst) + send_get_next_notification(rqst) + return recv_get_next_notification() end - def send_getNextNotification(rqst) - send_message('getNextNotification', GetNextNotification_args, :rqst => rqst) + def send_get_next_notification(rqst) + send_message('get_next_notification', Get_next_notification_args, :rqst => rqst) end - def recv_getNextNotification() - result = receive_message(GetNextNotification_result) + def recv_get_next_notification() + result = receive_message(Get_next_notification_result) return result.success unless result.success.nil? - raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getNextNotification failed: unknown result') + raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_next_notification failed: unknown result') end - def getCurrentNotificationEventId() - send_getCurrentNotificationEventId() - return recv_getCurrentNotificationEventId() + def get_current_notificationEventId() + send_get_current_notificationEventId() + return recv_get_current_notificationEventId() end - def send_getCurrentNotificationEventId() - send_message('getCurrentNotificationEventId', GetCurrentNotificationEventId_args) + def send_get_current_notificationEventId() + send_message('get_current_notificationEventId', Get_current_notificationEventId_args) end - def recv_getCurrentNotificationEventId() - result = receive_message(GetCurrentNotificationEventId_result) + def recv_get_current_notificationEventId() + result = receive_message(Get_current_notificationEventId_result) return result.success unless result.success.nil? - raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getCurrentNotificationEventId failed: unknown result') + raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_current_notificationEventId failed: unknown result') end end @@ -3523,18 +3523,18 @@ module ThriftHiveMetastore write_result(result, oprot, 'show_compact', seqid) end - def process_getNextNotification(seqid, iprot, oprot) - args = read_args(iprot, GetNextNotification_args) - result = GetNextNotification_result.new() - result.success = @handler.getNextNotification(args.rqst) - write_result(result, oprot, 'getNextNotification', seqid) + def process_get_next_notification(seqid, iprot, oprot) + args = read_args(iprot, Get_next_notification_args) + result = Get_next_notification_result.new() + result.success = @handler.get_next_notification(args.rqst) + write_result(result, oprot, 'get_next_notification', seqid) end - def process_getCurrentNotificationEventId(seqid, iprot, oprot) - args = read_args(iprot, GetCurrentNotificationEventId_args) - result = GetCurrentNotificationEventId_result.new() - result.success = @handler.getCurrentNotificationEventId() - write_result(result, oprot, 'getCurrentNotificationEventId', seqid) + def process_get_current_notificationEventId(seqid, iprot, oprot) + args = read_args(iprot, Get_current_notificationEventId_args) + result = Get_current_notificationEventId_result.new() + result.success = @handler.get_current_notificationEventId() + write_result(result, oprot, 'get_current_notificationEventId', seqid) end end @@ -8025,7 +8025,7 @@ module ThriftHiveMetastore ::Thrift::Struct.generate_accessors self end - class GetNextNotification_args + class Get_next_notification_args include ::Thrift::Struct, ::Thrift::Struct_Union RQST = 1 @@ -8041,7 +8041,7 @@ module ThriftHiveMetastore ::Thrift::Struct.generate_accessors self end - class GetNextNotification_result + class Get_next_notification_result include ::Thrift::Struct, ::Thrift::Struct_Union SUCCESS = 0 @@ -8057,7 +8057,7 @@ module ThriftHiveMetastore ::Thrift::Struct.generate_accessors self end - class GetCurrentNotificationEventId_args + class Get_current_notificationEventId_args include ::Thrift::Struct, ::Thrift::Struct_Union FIELDS = { @@ -8072,7 +8072,7 @@ module ThriftHiveMetastore ::Thrift::Struct.generate_accessors self end - class GetCurrentNotificationEventId_result + class Get_current_notificationEventId_result include ::Thrift::Struct, ::Thrift::Struct_Union SUCCESS = 0 Modified: hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java (original) +++ hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java Fri Jan 9 22:09:50 2015 @@ -5586,14 +5586,14 @@ public class HiveMetaStore extends Thrif } @Override - public NotificationEventResponse getNextNotification(NotificationEventRequest rqst) + public NotificationEventResponse get_next_notification(NotificationEventRequest rqst) throws TException { RawStore ms = getMS(); return ms.getNextNotification(rqst); } @Override - public CurrentNotificationEventId getCurrentNotificationEventId() throws TException { + public CurrentNotificationEventId get_current_notificationEventId() throws TException { RawStore ms = getMS(); return ms.getCurrentNotificationEventId(); } Modified: hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java (original) +++ hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java Fri Jan 9 22:09:50 2015 @@ -1847,7 +1847,7 @@ public class HiveMetaStoreClient impleme NotificationFilter filter) throws TException { NotificationEventRequest rqst = new NotificationEventRequest(lastEventId); rqst.setMaxEvents(maxEvents); - NotificationEventResponse rsp = client.getNextNotification(rqst); + NotificationEventResponse rsp = client.get_next_notification(rqst); LOG.debug("Got back " + rsp.getEventsSize() + " events"); if (filter == null) { return rsp; @@ -1864,7 +1864,7 @@ public class HiveMetaStoreClient impleme @Override public CurrentNotificationEventId getCurrentNotificationEventId() throws TException { - return client.getCurrentNotificationEventId(); + return client.get_current_notificationEventId(); } /**
