You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by sz...@apache.org on 2015/01/12 23:08:34 UTC
svn commit: r1651213 [2/9] - in /hive/branches/spark: ./ hbase-handler/
hcatalog/src/test/e2e/templeton/tests/
itests/util/src/main/java/org/apache/hadoop/hive/ql/security/ metastore/if/
metastore/scripts/upgrade/derby/ metastore/scripts/upgrade/mssql/...
Modified: hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
URL: http://svn.apache.org/viewvc/hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java?rev=1651213&r1=1651212&r2=1651213&view=diff
==============================================================================
--- hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java (original)
+++ hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java Mon Jan 12 22:08:32 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/branches/spark/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
URL: http://svn.apache.org/viewvc/hive/branches/spark/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php?rev=1651213&r1=1651212&r2=1651213&view=diff
==============================================================================
--- hive/branches/spark/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php (original)
+++ hive/branches/spark/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php Mon Jan 12 22:08:32 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/branches/spark/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
URL: http://svn.apache.org/viewvc/hive/branches/spark/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote?rev=1651213&r1=1651212&r2=1651213&view=diff
==============================================================================
--- hive/branches/spark/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote (original)
+++ hive/branches/spark/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote Mon Jan 12 22:08:32 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/branches/spark/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
URL: http://svn.apache.org/viewvc/hive/branches/spark/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py?rev=1651213&r1=1651212&r2=1651213&view=diff
==============================================================================
--- hive/branches/spark/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py (original)
+++ hive/branches/spark/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py Mon Jan 12 22:08:32 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/branches/spark/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb
URL: http://svn.apache.org/viewvc/hive/branches/spark/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb?rev=1651213&r1=1651212&r2=1651213&view=diff
==============================================================================
--- hive/branches/spark/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb (original)
+++ hive/branches/spark/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb Mon Jan 12 22:08:32 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/branches/spark/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
URL: http://svn.apache.org/viewvc/hive/branches/spark/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java?rev=1651213&r1=1651212&r2=1651213&view=diff
==============================================================================
--- hive/branches/spark/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java (original)
+++ hive/branches/spark/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java Mon Jan 12 22:08:32 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/branches/spark/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
URL: http://svn.apache.org/viewvc/hive/branches/spark/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java?rev=1651213&r1=1651212&r2=1651213&view=diff
==============================================================================
--- hive/branches/spark/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java (original)
+++ hive/branches/spark/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java Mon Jan 12 22:08:32 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();
}
/**