SENTRY-1236: Bump thrift version to 0.9.3 (Sravya Tirukkovalur, Reviewed by: Lenni Kuff and Hao Hao)
Change-Id: I204c83de02c8709f2ea72dd846a5b72e4987f5ad Project: http://git-wip-us.apache.org/repos/asf/sentry/repo Commit: http://git-wip-us.apache.org/repos/asf/sentry/commit/e67bde0d Tree: http://git-wip-us.apache.org/repos/asf/sentry/tree/e67bde0d Diff: http://git-wip-us.apache.org/repos/asf/sentry/diff/e67bde0d Branch: refs/heads/master Commit: e67bde0daed57eeaf778510f72b8082f99588c7d Parents: 42744cc Author: Sravya Tirukkovalur <[email protected]> Authored: Wed Jun 1 15:01:53 2016 -0700 Committer: Sravya Tirukkovalur <[email protected]> Committed: Wed Jun 1 15:01:53 2016 -0700 ---------------------------------------------------------------------- pom.xml | 4 +- .../hdfs/service/thrift/SentryHDFSService.java | 449 +++-- .../service/thrift/TAuthzUpdateResponse.java | 78 +- .../hdfs/service/thrift/TPathChanges.java | 118 +- .../sentry/hdfs/service/thrift/TPathEntry.java | 94 +- .../sentry/hdfs/service/thrift/TPathsDump.java | 64 +- .../hdfs/service/thrift/TPathsUpdate.java | 76 +- .../hdfs/service/thrift/TPermissionsUpdate.java | 112 +- .../hdfs/service/thrift/TPrivilegeChanges.java | 114 +- .../hdfs/service/thrift/TRoleChanges.java | 82 +- .../thrift/SentryGenericPolicyService.java | 1104 +++++++++--- .../TAlterSentryRoleAddGroupsRequest.java | 79 +- .../TAlterSentryRoleAddGroupsResponse.java | 24 +- .../TAlterSentryRoleDeleteGroupsRequest.java | 79 +- .../TAlterSentryRoleDeleteGroupsResponse.java | 24 +- .../TAlterSentryRoleGrantPrivilegeRequest.java | 58 +- .../TAlterSentryRoleGrantPrivilegeResponse.java | 24 +- .../TAlterSentryRoleRevokePrivilegeRequest.java | 58 +- ...TAlterSentryRoleRevokePrivilegeResponse.java | 24 +- .../generic/service/thrift/TAuthorizable.java | 32 +- .../thrift/TCreateSentryRoleRequest.java | 50 +- .../thrift/TCreateSentryRoleResponse.java | 24 +- .../service/thrift/TDropPrivilegesRequest.java | 50 +- .../service/thrift/TDropPrivilegesResponse.java | 24 +- .../service/thrift/TDropSentryRoleRequest.java | 50 +- .../service/thrift/TDropSentryRoleResponse.java | 24 +- .../TListSentryPrivilegesByAuthRequest.java | 118 +- .../TListSentryPrivilegesByAuthResponse.java | 64 +- ...TListSentryPrivilegesForProviderRequest.java | 111 +- ...ListSentryPrivilegesForProviderResponse.java | 53 +- .../thrift/TListSentryPrivilegesRequest.java | 90 +- .../thrift/TListSentryPrivilegesResponse.java | 56 +- .../service/thrift/TListSentryRolesRequest.java | 52 +- .../thrift/TListSentryRolesResponse.java | 56 +- .../thrift/TRenamePrivilegesRequest.java | 110 +- .../thrift/TRenamePrivilegesResponse.java | 24 +- .../service/thrift/TSentryActiveRoleSet.java | 55 +- .../service/thrift/TSentryGrantOption.java | 2 +- .../service/thrift/TSentryPrivilege.java | 102 +- .../service/thrift/TSentryPrivilegeMap.java | 72 +- .../db/generic/service/thrift/TSentryRole.java | 53 +- .../db/service/thrift/SentryPolicyService.java | 1644 ++++++++++++++---- .../TAlterSentryRoleAddGroupsRequest.java | 72 +- .../TAlterSentryRoleAddGroupsResponse.java | 24 +- .../thrift/TAlterSentryRoleAddUsersRequest.java | 71 +- .../TAlterSentryRoleAddUsersResponse.java | 24 +- .../TAlterSentryRoleDeleteGroupsRequest.java | 72 +- .../TAlterSentryRoleDeleteGroupsResponse.java | 24 +- .../TAlterSentryRoleDeleteUsersRequest.java | 71 +- .../TAlterSentryRoleDeleteUsersResponse.java | 24 +- .../TAlterSentryRoleGrantPrivilegeRequest.java | 82 +- .../TAlterSentryRoleGrantPrivilegeResponse.java | 64 +- .../TAlterSentryRoleRevokePrivilegeRequest.java | 82 +- ...TAlterSentryRoleRevokePrivilegeResponse.java | 24 +- .../thrift/TCreateSentryRoleRequest.java | 42 +- .../thrift/TCreateSentryRoleResponse.java | 24 +- .../service/thrift/TDropPrivilegesRequest.java | 42 +- .../service/thrift/TDropPrivilegesResponse.java | 24 +- .../service/thrift/TDropSentryRoleRequest.java | 42 +- .../service/thrift/TDropSentryRoleResponse.java | 24 +- .../TListSentryPrivilegesByAuthRequest.java | 103 +- .../TListSentryPrivilegesByAuthResponse.java | 68 +- ...TListSentryPrivilegesForProviderRequest.java | 102 +- ...ListSentryPrivilegesForProviderResponse.java | 53 +- .../thrift/TListSentryPrivilegesRequest.java | 52 +- .../thrift/TListSentryPrivilegesResponse.java | 56 +- .../thrift/TListSentryRolesForUserRequest.java | 42 +- .../service/thrift/TListSentryRolesRequest.java | 44 +- .../thrift/TListSentryRolesResponse.java | 56 +- .../thrift/TRenamePrivilegesRequest.java | 50 +- .../thrift/TRenamePrivilegesResponse.java | 24 +- .../db/service/thrift/TSentryActiveRoleSet.java | 55 +- .../db/service/thrift/TSentryAuthorizable.java | 58 +- .../thrift/TSentryConfigValueRequest.java | 44 +- .../thrift/TSentryConfigValueResponse.java | 34 +- .../thrift/TSentryExportMappingDataRequest.java | 132 +- .../TSentryExportMappingDataResponse.java | 32 +- .../db/service/thrift/TSentryGrantOption.java | 2 +- .../db/service/thrift/TSentryGroup.java | 24 +- .../thrift/TSentryImportMappingDataRequest.java | 52 +- .../TSentryImportMappingDataResponse.java | 24 +- .../db/service/thrift/TSentryMappingData.java | 282 ++- .../db/service/thrift/TSentryPrivilege.java | 96 +- .../db/service/thrift/TSentryPrivilegeMap.java | 72 +- .../provider/db/service/thrift/TSentryRole.java | 62 +- .../service/thrift/TSentryResponseStatus.java | 44 +- .../thrift/sentry_common_serviceConstants.java | 7 +- 87 files changed, 5070 insertions(+), 3013 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sentry/blob/e67bde0d/pom.xml ---------------------------------------------------------------------- diff --git a/pom.xml b/pom.xml index 5ce7247..2ea4735 100644 --- a/pom.xml +++ b/pom.xml @@ -77,8 +77,8 @@ limitations under the License. <jettyVersion>8.1.19.v20160209</jettyVersion> <joda-time.version>2.5</joda-time.version> <junit.version>4.10</junit.version> - <libfb303.version>0.9.2</libfb303.version> - <libthrift.version>0.9.2</libthrift.version> + <libfb303.version>0.9.3</libfb303.version> + <libthrift.version>0.9.3</libthrift.version> <log4j.version>1.2.16</log4j.version> <maven.antrun.plugin.version>1.7</maven.antrun.plugin.version> <maven.eclipse.plugin.version>2.9</maven.eclipse.plugin.version> http://git-wip-us.apache.org/repos/asf/sentry/blob/e67bde0d/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/SentryHDFSService.java ---------------------------------------------------------------------- diff --git a/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/SentryHDFSService.java b/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/SentryHDFSService.java index 254f72b..5cbd26c 100644 --- a/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/SentryHDFSService.java +++ b/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/SentryHDFSService.java @@ -1,12 +1,11 @@ /** - * Autogenerated by Thrift Compiler (0.9.0) + * Autogenerated by Thrift Compiler (0.9.3) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated */ package org.apache.sentry.hdfs.service.thrift; -import org.apache.commons.lang.builder.HashCodeBuilder; import org.apache.thrift.scheme.IScheme; import org.apache.thrift.scheme.SchemeFactory; import org.apache.thrift.scheme.StandardScheme; @@ -16,6 +15,8 @@ import org.apache.thrift.protocol.TTupleProtocol; import org.apache.thrift.protocol.TProtocolException; import org.apache.thrift.EncodingUtils; import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; import java.util.List; import java.util.ArrayList; import java.util.Map; @@ -28,9 +29,12 @@ import java.util.Collections; import java.util.BitSet; import java.nio.ByteBuffer; import java.util.Arrays; +import javax.annotation.Generated; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-05-05") public class SentryHDFSService { public interface Iface { @@ -47,13 +51,13 @@ public class SentryHDFSService { public interface AsyncIface { - public void handle_hms_notification(TPathsUpdate pathsUpdate, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.handle_hms_notification_call> resultHandler) throws org.apache.thrift.TException; + public void handle_hms_notification(TPathsUpdate pathsUpdate, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void check_hms_seq_num(long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.check_hms_seq_num_call> resultHandler) throws org.apache.thrift.TException; + public void check_hms_seq_num(long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void get_all_authz_updates_from(long permSeqNum, long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_all_authz_updates_from_call> resultHandler) throws org.apache.thrift.TException; + public void get_all_authz_updates_from(long permSeqNum, long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void get_all_related_paths(String path, boolean exactMatch, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_all_related_paths_call> resultHandler) throws org.apache.thrift.TException; + public void get_all_related_paths(String path, boolean exactMatch, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; } @@ -186,7 +190,7 @@ public class SentryHDFSService { super(protocolFactory, clientManager, transport); } - public void handle_hms_notification(TPathsUpdate pathsUpdate, org.apache.thrift.async.AsyncMethodCallback<handle_hms_notification_call> resultHandler) throws org.apache.thrift.TException { + public void handle_hms_notification(TPathsUpdate pathsUpdate, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); handle_hms_notification_call method_call = new handle_hms_notification_call(pathsUpdate, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -195,7 +199,7 @@ public class SentryHDFSService { public static class handle_hms_notification_call extends org.apache.thrift.async.TAsyncMethodCall { private TPathsUpdate pathsUpdate; - public handle_hms_notification_call(TPathsUpdate pathsUpdate, org.apache.thrift.async.AsyncMethodCallback<handle_hms_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 { + public handle_hms_notification_call(TPathsUpdate pathsUpdate, org.apache.thrift.async.AsyncMethodCallback 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.pathsUpdate = pathsUpdate; } @@ -218,7 +222,7 @@ public class SentryHDFSService { } } - public void check_hms_seq_num(long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback<check_hms_seq_num_call> resultHandler) throws org.apache.thrift.TException { + public void check_hms_seq_num(long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); check_hms_seq_num_call method_call = new check_hms_seq_num_call(pathSeqNum, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -227,7 +231,7 @@ public class SentryHDFSService { public static class check_hms_seq_num_call extends org.apache.thrift.async.TAsyncMethodCall { private long pathSeqNum; - public check_hms_seq_num_call(long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback<check_hms_seq_num_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 check_hms_seq_num_call(long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback 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.pathSeqNum = pathSeqNum; } @@ -250,7 +254,7 @@ public class SentryHDFSService { } } - public void get_all_authz_updates_from(long permSeqNum, long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback<get_all_authz_updates_from_call> resultHandler) throws org.apache.thrift.TException { + public void get_all_authz_updates_from(long permSeqNum, long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); get_all_authz_updates_from_call method_call = new get_all_authz_updates_from_call(permSeqNum, pathSeqNum, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -260,7 +264,7 @@ public class SentryHDFSService { public static class get_all_authz_updates_from_call extends org.apache.thrift.async.TAsyncMethodCall { private long permSeqNum; private long pathSeqNum; - public get_all_authz_updates_from_call(long permSeqNum, long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback<get_all_authz_updates_from_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_all_authz_updates_from_call(long permSeqNum, long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback 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.permSeqNum = permSeqNum; this.pathSeqNum = pathSeqNum; @@ -285,7 +289,7 @@ public class SentryHDFSService { } } - public void get_all_related_paths(String path, boolean exactMatch, org.apache.thrift.async.AsyncMethodCallback<get_all_related_paths_call> resultHandler) throws org.apache.thrift.TException { + public void get_all_related_paths(String path, boolean exactMatch, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); get_all_related_paths_call method_call = new get_all_related_paths_call(path, exactMatch, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -295,7 +299,7 @@ public class SentryHDFSService { public static class get_all_related_paths_call extends org.apache.thrift.async.TAsyncMethodCall { private String path; private boolean exactMatch; - public get_all_related_paths_call(String path, boolean exactMatch, org.apache.thrift.async.AsyncMethodCallback<get_all_related_paths_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_all_related_paths_call(String path, boolean exactMatch, org.apache.thrift.async.AsyncMethodCallback 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.path = path; this.exactMatch = exactMatch; @@ -423,7 +427,231 @@ public class SentryHDFSService { } - public static class handle_hms_notification_args implements org.apache.thrift.TBase<handle_hms_notification_args, handle_hms_notification_args._Fields>, java.io.Serializable, Cloneable { + public static class AsyncProcessor<I extends AsyncIface> extends org.apache.thrift.TBaseAsyncProcessor<I> { + private static final Logger LOGGER = LoggerFactory.getLogger(AsyncProcessor.class.getName()); + public AsyncProcessor(I iface) { + super(iface, getProcessMap(new HashMap<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>>())); + } + + protected AsyncProcessor(I iface, Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) { + super(iface, getProcessMap(processMap)); + } + + private static <I extends AsyncIface> Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase,?>> getProcessMap(Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) { + processMap.put("handle_hms_notification", new handle_hms_notification()); + processMap.put("check_hms_seq_num", new check_hms_seq_num()); + processMap.put("get_all_authz_updates_from", new get_all_authz_updates_from()); + processMap.put("get_all_related_paths", new get_all_related_paths()); + return processMap; + } + + public static class handle_hms_notification<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, handle_hms_notification_args, Void> { + public handle_hms_notification() { + super("handle_hms_notification"); + } + + public handle_hms_notification_args getEmptyArgsInstance() { + return new handle_hms_notification_args(); + } + + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + handle_hms_notification_result result = new handle_hms_notification_result(); + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + handle_hms_notification_result result = new handle_hms_notification_result(); + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, handle_hms_notification_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.handle_hms_notification(args.pathsUpdate,resultHandler); + } + } + + public static class check_hms_seq_num<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, check_hms_seq_num_args, Long> { + public check_hms_seq_num() { + super("check_hms_seq_num"); + } + + public check_hms_seq_num_args getEmptyArgsInstance() { + return new check_hms_seq_num_args(); + } + + public AsyncMethodCallback<Long> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Long>() { + public void onComplete(Long o) { + check_hms_seq_num_result result = new check_hms_seq_num_result(); + result.success = o; + result.setSuccessIsSet(true); + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + check_hms_seq_num_result result = new check_hms_seq_num_result(); + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, check_hms_seq_num_args args, org.apache.thrift.async.AsyncMethodCallback<Long> resultHandler) throws TException { + iface.check_hms_seq_num(args.pathSeqNum,resultHandler); + } + } + + public static class get_all_authz_updates_from<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_all_authz_updates_from_args, TAuthzUpdateResponse> { + public get_all_authz_updates_from() { + super("get_all_authz_updates_from"); + } + + public get_all_authz_updates_from_args getEmptyArgsInstance() { + return new get_all_authz_updates_from_args(); + } + + public AsyncMethodCallback<TAuthzUpdateResponse> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<TAuthzUpdateResponse>() { + public void onComplete(TAuthzUpdateResponse o) { + get_all_authz_updates_from_result result = new get_all_authz_updates_from_result(); + result.success = o; + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + get_all_authz_updates_from_result result = new get_all_authz_updates_from_result(); + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, get_all_authz_updates_from_args args, org.apache.thrift.async.AsyncMethodCallback<TAuthzUpdateResponse> resultHandler) throws TException { + iface.get_all_authz_updates_from(args.permSeqNum, args.pathSeqNum,resultHandler); + } + } + + public static class get_all_related_paths<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_all_related_paths_args, Map<String,List<String>>> { + public get_all_related_paths() { + super("get_all_related_paths"); + } + + public get_all_related_paths_args getEmptyArgsInstance() { + return new get_all_related_paths_args(); + } + + public AsyncMethodCallback<Map<String,List<String>>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Map<String,List<String>>>() { + public void onComplete(Map<String,List<String>> o) { + get_all_related_paths_result result = new get_all_related_paths_result(); + result.success = o; + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + get_all_related_paths_result result = new get_all_related_paths_result(); + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, get_all_related_paths_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,List<String>>> resultHandler) throws TException { + iface.get_all_related_paths(args.path, args.exactMatch,resultHandler); + } + } + + } + + public static class handle_hms_notification_args implements org.apache.thrift.TBase<handle_hms_notification_args, handle_hms_notification_args._Fields>, java.io.Serializable, Cloneable, Comparable<handle_hms_notification_args> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("handle_hms_notification_args"); private static final org.apache.thrift.protocol.TField PATHS_UPDATE_FIELD_DESC = new org.apache.thrift.protocol.TField("pathsUpdate", org.apache.thrift.protocol.TType.STRUCT, (short)1); @@ -617,30 +845,30 @@ public class SentryHDFSService { @Override public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); + List<Object> list = new ArrayList<Object>(); boolean present_pathsUpdate = true && (isSetPathsUpdate()); - builder.append(present_pathsUpdate); + list.add(present_pathsUpdate); if (present_pathsUpdate) - builder.append(pathsUpdate); + list.add(pathsUpdate); - return builder.toHashCode(); + return list.hashCode(); } + @Override public int compareTo(handle_hms_notification_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - handle_hms_notification_args typedOther = (handle_hms_notification_args)other; - lastComparison = Boolean.valueOf(isSetPathsUpdate()).compareTo(typedOther.isSetPathsUpdate()); + lastComparison = Boolean.valueOf(isSetPathsUpdate()).compareTo(other.isSetPathsUpdate()); if (lastComparison != 0) { return lastComparison; } if (isSetPathsUpdate()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.pathsUpdate, typedOther.pathsUpdate); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.pathsUpdate, other.pathsUpdate); if (lastComparison != 0) { return lastComparison; } @@ -786,7 +1014,7 @@ public class SentryHDFSService { } - public static class handle_hms_notification_result implements org.apache.thrift.TBase<handle_hms_notification_result, handle_hms_notification_result._Fields>, java.io.Serializable, Cloneable { + public static class handle_hms_notification_result implements org.apache.thrift.TBase<handle_hms_notification_result, handle_hms_notification_result._Fields>, java.io.Serializable, Cloneable, Comparable<handle_hms_notification_result> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("handle_hms_notification_result"); @@ -916,18 +1144,18 @@ public class SentryHDFSService { @Override public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); + List<Object> list = new ArrayList<Object>(); - return builder.toHashCode(); + return list.hashCode(); } + @Override public int compareTo(handle_hms_notification_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - handle_hms_notification_result typedOther = (handle_hms_notification_result)other; return 0; } @@ -1032,7 +1260,7 @@ public class SentryHDFSService { } - public static class check_hms_seq_num_args implements org.apache.thrift.TBase<check_hms_seq_num_args, check_hms_seq_num_args._Fields>, java.io.Serializable, Cloneable { + public static class check_hms_seq_num_args implements org.apache.thrift.TBase<check_hms_seq_num_args, check_hms_seq_num_args._Fields>, java.io.Serializable, Cloneable, Comparable<check_hms_seq_num_args> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("check_hms_seq_num_args"); private static final org.apache.thrift.protocol.TField PATH_SEQ_NUM_FIELD_DESC = new org.apache.thrift.protocol.TField("pathSeqNum", org.apache.thrift.protocol.TType.I64, (short)1); @@ -1182,7 +1410,7 @@ public class SentryHDFSService { public Object getFieldValue(_Fields field) { switch (field) { case PATH_SEQ_NUM: - return Long.valueOf(getPathSeqNum()); + return getPathSeqNum(); } throw new IllegalStateException(); @@ -1228,30 +1456,30 @@ public class SentryHDFSService { @Override public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); + List<Object> list = new ArrayList<Object>(); boolean present_pathSeqNum = true; - builder.append(present_pathSeqNum); + list.add(present_pathSeqNum); if (present_pathSeqNum) - builder.append(pathSeqNum); + list.add(pathSeqNum); - return builder.toHashCode(); + return list.hashCode(); } + @Override public int compareTo(check_hms_seq_num_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - check_hms_seq_num_args typedOther = (check_hms_seq_num_args)other; - lastComparison = Boolean.valueOf(isSetPathSeqNum()).compareTo(typedOther.isSetPathSeqNum()); + lastComparison = Boolean.valueOf(isSetPathSeqNum()).compareTo(other.isSetPathSeqNum()); if (lastComparison != 0) { return lastComparison; } if (isSetPathSeqNum()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.pathSeqNum, typedOther.pathSeqNum); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.pathSeqNum, other.pathSeqNum); if (lastComparison != 0) { return lastComparison; } @@ -1388,7 +1616,7 @@ public class SentryHDFSService { } - public static class check_hms_seq_num_result implements org.apache.thrift.TBase<check_hms_seq_num_result, check_hms_seq_num_result._Fields>, java.io.Serializable, Cloneable { + public static class check_hms_seq_num_result implements org.apache.thrift.TBase<check_hms_seq_num_result, check_hms_seq_num_result._Fields>, java.io.Serializable, Cloneable, Comparable<check_hms_seq_num_result> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("check_hms_seq_num_result"); private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.I64, (short)0); @@ -1538,7 +1766,7 @@ public class SentryHDFSService { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Long.valueOf(getSuccess()); + return getSuccess(); } throw new IllegalStateException(); @@ -1584,30 +1812,30 @@ public class SentryHDFSService { @Override public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); + List<Object> list = new ArrayList<Object>(); boolean present_success = true; - builder.append(present_success); + list.add(present_success); if (present_success) - builder.append(success); + list.add(success); - return builder.toHashCode(); + return list.hashCode(); } + @Override public int compareTo(check_hms_seq_num_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - check_hms_seq_num_result typedOther = (check_hms_seq_num_result)other; - lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); + lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess()); if (lastComparison != 0) { return lastComparison; } if (isSetSuccess()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success); if (lastComparison != 0) { return lastComparison; } @@ -1746,7 +1974,7 @@ public class SentryHDFSService { } - public static class get_all_authz_updates_from_args implements org.apache.thrift.TBase<get_all_authz_updates_from_args, get_all_authz_updates_from_args._Fields>, java.io.Serializable, Cloneable { + public static class get_all_authz_updates_from_args implements org.apache.thrift.TBase<get_all_authz_updates_from_args, get_all_authz_updates_from_args._Fields>, java.io.Serializable, Cloneable, Comparable<get_all_authz_updates_from_args> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("get_all_authz_updates_from_args"); private static final org.apache.thrift.protocol.TField PERM_SEQ_NUM_FIELD_DESC = new org.apache.thrift.protocol.TField("permSeqNum", org.apache.thrift.protocol.TType.I64, (short)1); @@ -1940,10 +2168,10 @@ public class SentryHDFSService { public Object getFieldValue(_Fields field) { switch (field) { case PERM_SEQ_NUM: - return Long.valueOf(getPermSeqNum()); + return getPermSeqNum(); case PATH_SEQ_NUM: - return Long.valueOf(getPathSeqNum()); + return getPathSeqNum(); } throw new IllegalStateException(); @@ -2000,45 +2228,45 @@ public class SentryHDFSService { @Override public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); + List<Object> list = new ArrayList<Object>(); boolean present_permSeqNum = true; - builder.append(present_permSeqNum); + list.add(present_permSeqNum); if (present_permSeqNum) - builder.append(permSeqNum); + list.add(permSeqNum); boolean present_pathSeqNum = true; - builder.append(present_pathSeqNum); + list.add(present_pathSeqNum); if (present_pathSeqNum) - builder.append(pathSeqNum); + list.add(pathSeqNum); - return builder.toHashCode(); + return list.hashCode(); } + @Override public int compareTo(get_all_authz_updates_from_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - get_all_authz_updates_from_args typedOther = (get_all_authz_updates_from_args)other; - lastComparison = Boolean.valueOf(isSetPermSeqNum()).compareTo(typedOther.isSetPermSeqNum()); + lastComparison = Boolean.valueOf(isSetPermSeqNum()).compareTo(other.isSetPermSeqNum()); if (lastComparison != 0) { return lastComparison; } if (isSetPermSeqNum()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.permSeqNum, typedOther.permSeqNum); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.permSeqNum, other.permSeqNum); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetPathSeqNum()).compareTo(typedOther.isSetPathSeqNum()); + lastComparison = Boolean.valueOf(isSetPathSeqNum()).compareTo(other.isSetPathSeqNum()); if (lastComparison != 0) { return lastComparison; } if (isSetPathSeqNum()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.pathSeqNum, typedOther.pathSeqNum); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.pathSeqNum, other.pathSeqNum); if (lastComparison != 0) { return lastComparison; } @@ -2200,7 +2428,7 @@ public class SentryHDFSService { } - public static class get_all_authz_updates_from_result implements org.apache.thrift.TBase<get_all_authz_updates_from_result, get_all_authz_updates_from_result._Fields>, java.io.Serializable, Cloneable { + public static class get_all_authz_updates_from_result implements org.apache.thrift.TBase<get_all_authz_updates_from_result, get_all_authz_updates_from_result._Fields>, java.io.Serializable, Cloneable, Comparable<get_all_authz_updates_from_result> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("get_all_authz_updates_from_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); @@ -2394,30 +2622,30 @@ public class SentryHDFSService { @Override public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); + List<Object> list = new ArrayList<Object>(); boolean present_success = true && (isSetSuccess()); - builder.append(present_success); + list.add(present_success); if (present_success) - builder.append(success); + list.add(success); - return builder.toHashCode(); + return list.hashCode(); } + @Override public int compareTo(get_all_authz_updates_from_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - get_all_authz_updates_from_result typedOther = (get_all_authz_updates_from_result)other; - lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); + lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess()); if (lastComparison != 0) { return lastComparison; } if (isSetSuccess()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success); if (lastComparison != 0) { return lastComparison; } @@ -2563,7 +2791,7 @@ public class SentryHDFSService { } - public static class get_all_related_paths_args implements org.apache.thrift.TBase<get_all_related_paths_args, get_all_related_paths_args._Fields>, java.io.Serializable, Cloneable { + public static class get_all_related_paths_args implements org.apache.thrift.TBase<get_all_related_paths_args, get_all_related_paths_args._Fields>, java.io.Serializable, Cloneable, Comparable<get_all_related_paths_args> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("get_all_related_paths_args"); private static final org.apache.thrift.protocol.TField PATH_FIELD_DESC = new org.apache.thrift.protocol.TField("path", org.apache.thrift.protocol.TType.STRING, (short)1); @@ -2760,7 +2988,7 @@ public class SentryHDFSService { return getPath(); case EXACT_MATCH: - return Boolean.valueOf(isExactMatch()); + return isExactMatch(); } throw new IllegalStateException(); @@ -2817,45 +3045,45 @@ public class SentryHDFSService { @Override public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); + List<Object> list = new ArrayList<Object>(); boolean present_path = true && (isSetPath()); - builder.append(present_path); + list.add(present_path); if (present_path) - builder.append(path); + list.add(path); boolean present_exactMatch = true; - builder.append(present_exactMatch); + list.add(present_exactMatch); if (present_exactMatch) - builder.append(exactMatch); + list.add(exactMatch); - return builder.toHashCode(); + return list.hashCode(); } + @Override public int compareTo(get_all_related_paths_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - get_all_related_paths_args typedOther = (get_all_related_paths_args)other; - lastComparison = Boolean.valueOf(isSetPath()).compareTo(typedOther.isSetPath()); + lastComparison = Boolean.valueOf(isSetPath()).compareTo(other.isSetPath()); if (lastComparison != 0) { return lastComparison; } if (isSetPath()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.path, typedOther.path); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.path, other.path); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetExactMatch()).compareTo(typedOther.isSetExactMatch()); + lastComparison = Boolean.valueOf(isSetExactMatch()).compareTo(other.isSetExactMatch()); if (lastComparison != 0) { return lastComparison; } if (isSetExactMatch()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.exactMatch, typedOther.exactMatch); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.exactMatch, other.exactMatch); if (lastComparison != 0) { return lastComparison; } @@ -3023,7 +3251,7 @@ public class SentryHDFSService { } - public static class get_all_related_paths_result implements org.apache.thrift.TBase<get_all_related_paths_result, get_all_related_paths_result._Fields>, java.io.Serializable, Cloneable { + public static class get_all_related_paths_result implements org.apache.thrift.TBase<get_all_related_paths_result, get_all_related_paths_result._Fields>, java.io.Serializable, Cloneable, Comparable<get_all_related_paths_result> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("get_all_related_paths_result"); private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.MAP, (short)0); @@ -3122,7 +3350,7 @@ public class SentryHDFSService { */ public get_all_related_paths_result(get_all_related_paths_result other) { if (other.isSetSuccess()) { - Map<String,List<String>> __this__success = new HashMap<String,List<String>>(); + Map<String,List<String>> __this__success = new HashMap<String,List<String>>(other.success.size()); for (Map.Entry<String, List<String>> other_element : other.success.entrySet()) { String other_element_key = other_element.getKey(); @@ -3130,10 +3358,7 @@ public class SentryHDFSService { String __this__success_copy_key = other_element_key; - List<String> __this__success_copy_value = new ArrayList<String>(); - for (String other_element_value_element : other_element_value) { - __this__success_copy_value.add(other_element_value_element); - } + List<String> __this__success_copy_value = new ArrayList<String>(other_element_value); __this__success.put(__this__success_copy_key, __this__success_copy_value); } @@ -3246,30 +3471,30 @@ public class SentryHDFSService { @Override public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); + List<Object> list = new ArrayList<Object>(); boolean present_success = true && (isSetSuccess()); - builder.append(present_success); + list.add(present_success); if (present_success) - builder.append(success); + list.add(success); - return builder.toHashCode(); + return list.hashCode(); } + @Override public int compareTo(get_all_related_paths_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - get_all_related_paths_result typedOther = (get_all_related_paths_result)other; - lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); + lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess()); if (lastComparison != 0) { return lastComparison; } if (isSetSuccess()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success); if (lastComparison != 0) { return lastComparison; } @@ -3349,23 +3574,23 @@ public class SentryHDFSService { { org.apache.thrift.protocol.TMap _map138 = iprot.readMapBegin(); struct.success = new HashMap<String,List<String>>(2*_map138.size); - for (int _i139 = 0; _i139 < _map138.size; ++_i139) + String _key139; + List<String> _val140; + for (int _i141 = 0; _i141 < _map138.size; ++_i141) { - String _key140; // required - List<String> _val141; // required - _key140 = iprot.readString(); + _key139 = iprot.readString(); { org.apache.thrift.protocol.TList _list142 = iprot.readListBegin(); - _val141 = new ArrayList<String>(_list142.size); - for (int _i143 = 0; _i143 < _list142.size; ++_i143) + _val140 = new ArrayList<String>(_list142.size); + String _elem143; + for (int _i144 = 0; _i144 < _list142.size; ++_i144) { - String _elem144; // required - _elem144 = iprot.readString(); - _val141.add(_elem144); + _elem143 = iprot.readString(); + _val140.add(_elem143); } iprot.readListEnd(); } - struct.success.put(_key140, _val141); + struct.success.put(_key139, _val140); } iprot.readMapEnd(); } @@ -3455,22 +3680,22 @@ public class SentryHDFSService { { org.apache.thrift.protocol.TMap _map149 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.LIST, iprot.readI32()); struct.success = new HashMap<String,List<String>>(2*_map149.size); - for (int _i150 = 0; _i150 < _map149.size; ++_i150) + String _key150; + List<String> _val151; + for (int _i152 = 0; _i152 < _map149.size; ++_i152) { - String _key151; // required - List<String> _val152; // required - _key151 = iprot.readString(); + _key150 = iprot.readString(); { org.apache.thrift.protocol.TList _list153 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - _val152 = new ArrayList<String>(_list153.size); - for (int _i154 = 0; _i154 < _list153.size; ++_i154) + _val151 = new ArrayList<String>(_list153.size); + String _elem154; + for (int _i155 = 0; _i155 < _list153.size; ++_i155) { - String _elem155; // required - _elem155 = iprot.readString(); - _val152.add(_elem155); + _elem154 = iprot.readString(); + _val151.add(_elem154); } } - struct.success.put(_key151, _val152); + struct.success.put(_key150, _val151); } } struct.setSuccessIsSet(true); http://git-wip-us.apache.org/repos/asf/sentry/blob/e67bde0d/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/TAuthzUpdateResponse.java ---------------------------------------------------------------------- diff --git a/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/TAuthzUpdateResponse.java b/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/TAuthzUpdateResponse.java index ec1d2af..c21072f 100644 --- a/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/TAuthzUpdateResponse.java +++ b/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/TAuthzUpdateResponse.java @@ -1,12 +1,11 @@ /** - * Autogenerated by Thrift Compiler (0.9.0) + * Autogenerated by Thrift Compiler (0.9.3) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated */ package org.apache.sentry.hdfs.service.thrift; -import org.apache.commons.lang.builder.HashCodeBuilder; import org.apache.thrift.scheme.IScheme; import org.apache.thrift.scheme.SchemeFactory; import org.apache.thrift.scheme.StandardScheme; @@ -16,6 +15,8 @@ import org.apache.thrift.protocol.TTupleProtocol; import org.apache.thrift.protocol.TProtocolException; import org.apache.thrift.EncodingUtils; import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; import java.util.List; import java.util.ArrayList; import java.util.Map; @@ -28,10 +29,13 @@ import java.util.Collections; import java.util.BitSet; import java.nio.ByteBuffer; import java.util.Arrays; +import javax.annotation.Generated; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class TAuthzUpdateResponse implements org.apache.thrift.TBase<TAuthzUpdateResponse, TAuthzUpdateResponse._Fields>, java.io.Serializable, Cloneable { +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-05-05") +public class TAuthzUpdateResponse implements org.apache.thrift.TBase<TAuthzUpdateResponse, TAuthzUpdateResponse._Fields>, java.io.Serializable, Cloneable, Comparable<TAuthzUpdateResponse> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TAuthzUpdateResponse"); private static final org.apache.thrift.protocol.TField AUTHZ_PATH_UPDATE_FIELD_DESC = new org.apache.thrift.protocol.TField("authzPathUpdate", org.apache.thrift.protocol.TType.LIST, (short)1); @@ -108,7 +112,7 @@ public class TAuthzUpdateResponse implements org.apache.thrift.TBase<TAuthzUpdat } // isset id assignments - private _Fields optionals[] = {_Fields.AUTHZ_PATH_UPDATE,_Fields.AUTHZ_PERM_UPDATE}; + private static final _Fields optionals[] = {_Fields.AUTHZ_PATH_UPDATE,_Fields.AUTHZ_PERM_UPDATE}; public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); @@ -130,14 +134,14 @@ public class TAuthzUpdateResponse implements org.apache.thrift.TBase<TAuthzUpdat */ public TAuthzUpdateResponse(TAuthzUpdateResponse other) { if (other.isSetAuthzPathUpdate()) { - List<TPathsUpdate> __this__authzPathUpdate = new ArrayList<TPathsUpdate>(); + List<TPathsUpdate> __this__authzPathUpdate = new ArrayList<TPathsUpdate>(other.authzPathUpdate.size()); for (TPathsUpdate other_element : other.authzPathUpdate) { __this__authzPathUpdate.add(new TPathsUpdate(other_element)); } this.authzPathUpdate = __this__authzPathUpdate; } if (other.isSetAuthzPermUpdate()) { - List<TPermissionsUpdate> __this__authzPermUpdate = new ArrayList<TPermissionsUpdate>(); + List<TPermissionsUpdate> __this__authzPermUpdate = new ArrayList<TPermissionsUpdate>(other.authzPermUpdate.size()); for (TPermissionsUpdate other_element : other.authzPermUpdate) { __this__authzPermUpdate.add(new TPermissionsUpdate(other_element)); } @@ -315,45 +319,45 @@ public class TAuthzUpdateResponse implements org.apache.thrift.TBase<TAuthzUpdat @Override public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); + List<Object> list = new ArrayList<Object>(); boolean present_authzPathUpdate = true && (isSetAuthzPathUpdate()); - builder.append(present_authzPathUpdate); + list.add(present_authzPathUpdate); if (present_authzPathUpdate) - builder.append(authzPathUpdate); + list.add(authzPathUpdate); boolean present_authzPermUpdate = true && (isSetAuthzPermUpdate()); - builder.append(present_authzPermUpdate); + list.add(present_authzPermUpdate); if (present_authzPermUpdate) - builder.append(authzPermUpdate); + list.add(authzPermUpdate); - return builder.toHashCode(); + return list.hashCode(); } + @Override public int compareTo(TAuthzUpdateResponse other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - TAuthzUpdateResponse typedOther = (TAuthzUpdateResponse)other; - lastComparison = Boolean.valueOf(isSetAuthzPathUpdate()).compareTo(typedOther.isSetAuthzPathUpdate()); + lastComparison = Boolean.valueOf(isSetAuthzPathUpdate()).compareTo(other.isSetAuthzPathUpdate()); if (lastComparison != 0) { return lastComparison; } if (isSetAuthzPathUpdate()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.authzPathUpdate, typedOther.authzPathUpdate); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.authzPathUpdate, other.authzPathUpdate); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetAuthzPermUpdate()).compareTo(typedOther.isSetAuthzPermUpdate()); + lastComparison = Boolean.valueOf(isSetAuthzPermUpdate()).compareTo(other.isSetAuthzPermUpdate()); if (lastComparison != 0) { return lastComparison; } if (isSetAuthzPermUpdate()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.authzPermUpdate, typedOther.authzPermUpdate); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.authzPermUpdate, other.authzPermUpdate); if (lastComparison != 0) { return lastComparison; } @@ -445,12 +449,12 @@ public class TAuthzUpdateResponse implements org.apache.thrift.TBase<TAuthzUpdat { org.apache.thrift.protocol.TList _list122 = iprot.readListBegin(); struct.authzPathUpdate = new ArrayList<TPathsUpdate>(_list122.size); - for (int _i123 = 0; _i123 < _list122.size; ++_i123) + TPathsUpdate _elem123; + for (int _i124 = 0; _i124 < _list122.size; ++_i124) { - TPathsUpdate _elem124; // required - _elem124 = new TPathsUpdate(); - _elem124.read(iprot); - struct.authzPathUpdate.add(_elem124); + _elem123 = new TPathsUpdate(); + _elem123.read(iprot); + struct.authzPathUpdate.add(_elem123); } iprot.readListEnd(); } @@ -464,12 +468,12 @@ public class TAuthzUpdateResponse implements org.apache.thrift.TBase<TAuthzUpdat { org.apache.thrift.protocol.TList _list125 = iprot.readListBegin(); struct.authzPermUpdate = new ArrayList<TPermissionsUpdate>(_list125.size); - for (int _i126 = 0; _i126 < _list125.size; ++_i126) + TPermissionsUpdate _elem126; + for (int _i127 = 0; _i127 < _list125.size; ++_i127) { - TPermissionsUpdate _elem127; // required - _elem127 = new TPermissionsUpdate(); - _elem127.read(iprot); - struct.authzPermUpdate.add(_elem127); + _elem126 = new TPermissionsUpdate(); + _elem126.read(iprot); + struct.authzPermUpdate.add(_elem126); } iprot.readListEnd(); } @@ -572,12 +576,12 @@ public class TAuthzUpdateResponse implements org.apache.thrift.TBase<TAuthzUpdat { org.apache.thrift.protocol.TList _list132 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); struct.authzPathUpdate = new ArrayList<TPathsUpdate>(_list132.size); - for (int _i133 = 0; _i133 < _list132.size; ++_i133) + TPathsUpdate _elem133; + for (int _i134 = 0; _i134 < _list132.size; ++_i134) { - TPathsUpdate _elem134; // required - _elem134 = new TPathsUpdate(); - _elem134.read(iprot); - struct.authzPathUpdate.add(_elem134); + _elem133 = new TPathsUpdate(); + _elem133.read(iprot); + struct.authzPathUpdate.add(_elem133); } } struct.setAuthzPathUpdateIsSet(true); @@ -586,12 +590,12 @@ public class TAuthzUpdateResponse implements org.apache.thrift.TBase<TAuthzUpdat { org.apache.thrift.protocol.TList _list135 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); struct.authzPermUpdate = new ArrayList<TPermissionsUpdate>(_list135.size); - for (int _i136 = 0; _i136 < _list135.size; ++_i136) + TPermissionsUpdate _elem136; + for (int _i137 = 0; _i137 < _list135.size; ++_i137) { - TPermissionsUpdate _elem137; // required - _elem137 = new TPermissionsUpdate(); - _elem137.read(iprot); - struct.authzPermUpdate.add(_elem137); + _elem136 = new TPermissionsUpdate(); + _elem136.read(iprot); + struct.authzPermUpdate.add(_elem136); } } struct.setAuthzPermUpdateIsSet(true); http://git-wip-us.apache.org/repos/asf/sentry/blob/e67bde0d/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/TPathChanges.java ---------------------------------------------------------------------- diff --git a/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/TPathChanges.java b/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/TPathChanges.java index 85254d7..4ba4f27 100644 --- a/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/TPathChanges.java +++ b/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/TPathChanges.java @@ -1,12 +1,11 @@ /** - * Autogenerated by Thrift Compiler (0.9.0) + * Autogenerated by Thrift Compiler (0.9.3) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated */ package org.apache.sentry.hdfs.service.thrift; -import org.apache.commons.lang.builder.HashCodeBuilder; import org.apache.thrift.scheme.IScheme; import org.apache.thrift.scheme.SchemeFactory; import org.apache.thrift.scheme.StandardScheme; @@ -16,6 +15,8 @@ import org.apache.thrift.protocol.TTupleProtocol; import org.apache.thrift.protocol.TProtocolException; import org.apache.thrift.EncodingUtils; import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; import java.util.List; import java.util.ArrayList; import java.util.Map; @@ -28,10 +29,13 @@ import java.util.Collections; import java.util.BitSet; import java.nio.ByteBuffer; import java.util.Arrays; +import javax.annotation.Generated; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class TPathChanges implements org.apache.thrift.TBase<TPathChanges, TPathChanges._Fields>, java.io.Serializable, Cloneable { +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-05-05") +public class TPathChanges implements org.apache.thrift.TBase<TPathChanges, TPathChanges._Fields>, java.io.Serializable, Cloneable, Comparable<TPathChanges> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TPathChanges"); private static final org.apache.thrift.protocol.TField AUTHZ_OBJ_FIELD_DESC = new org.apache.thrift.protocol.TField("authzObj", org.apache.thrift.protocol.TType.STRING, (short)1); @@ -152,23 +156,17 @@ public class TPathChanges implements org.apache.thrift.TBase<TPathChanges, TPath this.authzObj = other.authzObj; } if (other.isSetAddPaths()) { - List<List<String>> __this__addPaths = new ArrayList<List<String>>(); + List<List<String>> __this__addPaths = new ArrayList<List<String>>(other.addPaths.size()); for (List<String> other_element : other.addPaths) { - List<String> __this__addPaths_copy = new ArrayList<String>(); - for (String other_element_element : other_element) { - __this__addPaths_copy.add(other_element_element); - } + List<String> __this__addPaths_copy = new ArrayList<String>(other_element); __this__addPaths.add(__this__addPaths_copy); } this.addPaths = __this__addPaths; } if (other.isSetDelPaths()) { - List<List<String>> __this__delPaths = new ArrayList<List<String>>(); + List<List<String>> __this__delPaths = new ArrayList<List<String>>(other.delPaths.size()); for (List<String> other_element : other.delPaths) { - List<String> __this__delPaths_copy = new ArrayList<String>(); - for (String other_element_element : other_element) { - __this__delPaths_copy.add(other_element_element); - } + List<String> __this__delPaths_copy = new ArrayList<String>(other_element); __this__delPaths.add(__this__delPaths_copy); } this.delPaths = __this__delPaths; @@ -391,60 +389,60 @@ public class TPathChanges implements org.apache.thrift.TBase<TPathChanges, TPath @Override public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); + List<Object> list = new ArrayList<Object>(); boolean present_authzObj = true && (isSetAuthzObj()); - builder.append(present_authzObj); + list.add(present_authzObj); if (present_authzObj) - builder.append(authzObj); + list.add(authzObj); boolean present_addPaths = true && (isSetAddPaths()); - builder.append(present_addPaths); + list.add(present_addPaths); if (present_addPaths) - builder.append(addPaths); + list.add(addPaths); boolean present_delPaths = true && (isSetDelPaths()); - builder.append(present_delPaths); + list.add(present_delPaths); if (present_delPaths) - builder.append(delPaths); + list.add(delPaths); - return builder.toHashCode(); + return list.hashCode(); } + @Override public int compareTo(TPathChanges other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - TPathChanges typedOther = (TPathChanges)other; - lastComparison = Boolean.valueOf(isSetAuthzObj()).compareTo(typedOther.isSetAuthzObj()); + lastComparison = Boolean.valueOf(isSetAuthzObj()).compareTo(other.isSetAuthzObj()); if (lastComparison != 0) { return lastComparison; } if (isSetAuthzObj()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.authzObj, typedOther.authzObj); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.authzObj, other.authzObj); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetAddPaths()).compareTo(typedOther.isSetAddPaths()); + lastComparison = Boolean.valueOf(isSetAddPaths()).compareTo(other.isSetAddPaths()); if (lastComparison != 0) { return lastComparison; } if (isSetAddPaths()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.addPaths, typedOther.addPaths); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.addPaths, other.addPaths); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetDelPaths()).compareTo(typedOther.isSetDelPaths()); + lastComparison = Boolean.valueOf(isSetDelPaths()).compareTo(other.isSetDelPaths()); if (lastComparison != 0) { return lastComparison; } if (isSetDelPaths()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.delPaths, typedOther.delPaths); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.delPaths, other.delPaths); if (lastComparison != 0) { return lastComparison; } @@ -560,21 +558,21 @@ public class TPathChanges implements org.apache.thrift.TBase<TPathChanges, TPath { org.apache.thrift.protocol.TList _list0 = iprot.readListBegin(); struct.addPaths = new ArrayList<List<String>>(_list0.size); - for (int _i1 = 0; _i1 < _list0.size; ++_i1) + List<String> _elem1; + for (int _i2 = 0; _i2 < _list0.size; ++_i2) { - List<String> _elem2; // required { org.apache.thrift.protocol.TList _list3 = iprot.readListBegin(); - _elem2 = new ArrayList<String>(_list3.size); - for (int _i4 = 0; _i4 < _list3.size; ++_i4) + _elem1 = new ArrayList<String>(_list3.size); + String _elem4; + for (int _i5 = 0; _i5 < _list3.size; ++_i5) { - String _elem5; // required - _elem5 = iprot.readString(); - _elem2.add(_elem5); + _elem4 = iprot.readString(); + _elem1.add(_elem4); } iprot.readListEnd(); } - struct.addPaths.add(_elem2); + struct.addPaths.add(_elem1); } iprot.readListEnd(); } @@ -588,21 +586,21 @@ public class TPathChanges implements org.apache.thrift.TBase<TPathChanges, TPath { org.apache.thrift.protocol.TList _list6 = iprot.readListBegin(); struct.delPaths = new ArrayList<List<String>>(_list6.size); - for (int _i7 = 0; _i7 < _list6.size; ++_i7) + List<String> _elem7; + for (int _i8 = 0; _i8 < _list6.size; ++_i8) { - List<String> _elem8; // required { org.apache.thrift.protocol.TList _list9 = iprot.readListBegin(); - _elem8 = new ArrayList<String>(_list9.size); - for (int _i10 = 0; _i10 < _list9.size; ++_i10) + _elem7 = new ArrayList<String>(_list9.size); + String _elem10; + for (int _i11 = 0; _i11 < _list9.size; ++_i11) { - String _elem11; // required - _elem11 = iprot.readString(); - _elem8.add(_elem11); + _elem10 = iprot.readString(); + _elem7.add(_elem10); } iprot.readListEnd(); } - struct.delPaths.add(_elem8); + struct.delPaths.add(_elem7); } iprot.readListEnd(); } @@ -721,40 +719,40 @@ public class TPathChanges implements org.apache.thrift.TBase<TPathChanges, TPath { org.apache.thrift.protocol.TList _list20 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.LIST, iprot.readI32()); struct.addPaths = new ArrayList<List<String>>(_list20.size); - for (int _i21 = 0; _i21 < _list20.size; ++_i21) + List<String> _elem21; + for (int _i22 = 0; _i22 < _list20.size; ++_i22) { - List<String> _elem22; // required { org.apache.thrift.protocol.TList _list23 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - _elem22 = new ArrayList<String>(_list23.size); - for (int _i24 = 0; _i24 < _list23.size; ++_i24) + _elem21 = new ArrayList<String>(_list23.size); + String _elem24; + for (int _i25 = 0; _i25 < _list23.size; ++_i25) { - String _elem25; // required - _elem25 = iprot.readString(); - _elem22.add(_elem25); + _elem24 = iprot.readString(); + _elem21.add(_elem24); } } - struct.addPaths.add(_elem22); + struct.addPaths.add(_elem21); } } struct.setAddPathsIsSet(true); { org.apache.thrift.protocol.TList _list26 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.LIST, iprot.readI32()); struct.delPaths = new ArrayList<List<String>>(_list26.size); - for (int _i27 = 0; _i27 < _list26.size; ++_i27) + List<String> _elem27; + for (int _i28 = 0; _i28 < _list26.size; ++_i28) { - List<String> _elem28; // required { org.apache.thrift.protocol.TList _list29 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - _elem28 = new ArrayList<String>(_list29.size); - for (int _i30 = 0; _i30 < _list29.size; ++_i30) + _elem27 = new ArrayList<String>(_list29.size); + String _elem30; + for (int _i31 = 0; _i31 < _list29.size; ++_i31) { - String _elem31; // required - _elem31 = iprot.readString(); - _elem28.add(_elem31); + _elem30 = iprot.readString(); + _elem27.add(_elem30); } } - struct.delPaths.add(_elem28); + struct.delPaths.add(_elem27); } } struct.setDelPathsIsSet(true); http://git-wip-us.apache.org/repos/asf/sentry/blob/e67bde0d/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/TPathEntry.java ---------------------------------------------------------------------- diff --git a/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/TPathEntry.java b/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/TPathEntry.java index 3e03130..722eaec 100644 --- a/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/TPathEntry.java +++ b/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/TPathEntry.java @@ -1,12 +1,11 @@ /** - * Autogenerated by Thrift Compiler (0.9.0) + * Autogenerated by Thrift Compiler (0.9.3) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated */ package org.apache.sentry.hdfs.service.thrift; -import org.apache.commons.lang.builder.HashCodeBuilder; import org.apache.thrift.scheme.IScheme; import org.apache.thrift.scheme.SchemeFactory; import org.apache.thrift.scheme.StandardScheme; @@ -16,6 +15,8 @@ import org.apache.thrift.protocol.TTupleProtocol; import org.apache.thrift.protocol.TProtocolException; import org.apache.thrift.EncodingUtils; import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; import java.util.List; import java.util.ArrayList; import java.util.Map; @@ -28,10 +29,13 @@ import java.util.Collections; import java.util.BitSet; import java.nio.ByteBuffer; import java.util.Arrays; +import javax.annotation.Generated; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class TPathEntry implements org.apache.thrift.TBase<TPathEntry, TPathEntry._Fields>, java.io.Serializable, Cloneable { +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-05-05") +public class TPathEntry implements org.apache.thrift.TBase<TPathEntry, TPathEntry._Fields>, java.io.Serializable, Cloneable, Comparable<TPathEntry> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TPathEntry"); private static final org.apache.thrift.protocol.TField TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("type", org.apache.thrift.protocol.TType.BYTE, (short)1); @@ -120,7 +124,7 @@ public class TPathEntry implements org.apache.thrift.TBase<TPathEntry, TPathEntr // isset id assignments private static final int __TYPE_ISSET_ID = 0; private byte __isset_bitfield = 0; - private _Fields optionals[] = {_Fields.AUTHZ_OBJS}; + private static final _Fields optionals[] = {_Fields.AUTHZ_OBJS}; public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); @@ -163,17 +167,11 @@ public class TPathEntry implements org.apache.thrift.TBase<TPathEntry, TPathEntr this.pathElement = other.pathElement; } if (other.isSetChildren()) { - Set<Integer> __this__children = new HashSet<Integer>(); - for (Integer other_element : other.children) { - __this__children.add(other_element); - } + Set<Integer> __this__children = new HashSet<Integer>(other.children); this.children = __this__children; } if (other.isSetAuthzObjs()) { - Set<String> __this__authzObjs = new HashSet<String>(); - for (String other_element : other.authzObjs) { - __this__authzObjs.add(other_element); - } + Set<String> __this__authzObjs = new HashSet<String>(other.authzObjs); this.authzObjs = __this__authzObjs; } } @@ -352,7 +350,7 @@ public class TPathEntry implements org.apache.thrift.TBase<TPathEntry, TPathEntr public Object getFieldValue(_Fields field) { switch (field) { case TYPE: - return Byte.valueOf(getType()); + return getType(); case PATH_ELEMENT: return getPathElement(); @@ -440,75 +438,75 @@ public class TPathEntry implements org.apache.thrift.TBase<TPathEntry, TPathEntr @Override public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); + List<Object> list = new ArrayList<Object>(); boolean present_type = true; - builder.append(present_type); + list.add(present_type); if (present_type) - builder.append(type); + list.add(type); boolean present_pathElement = true && (isSetPathElement()); - builder.append(present_pathElement); + list.add(present_pathElement); if (present_pathElement) - builder.append(pathElement); + list.add(pathElement); boolean present_children = true && (isSetChildren()); - builder.append(present_children); + list.add(present_children); if (present_children) - builder.append(children); + list.add(children); boolean present_authzObjs = true && (isSetAuthzObjs()); - builder.append(present_authzObjs); + list.add(present_authzObjs); if (present_authzObjs) - builder.append(authzObjs); + list.add(authzObjs); - return builder.toHashCode(); + return list.hashCode(); } + @Override public int compareTo(TPathEntry other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - TPathEntry typedOther = (TPathEntry)other; - lastComparison = Boolean.valueOf(isSetType()).compareTo(typedOther.isSetType()); + lastComparison = Boolean.valueOf(isSetType()).compareTo(other.isSetType()); if (lastComparison != 0) { return lastComparison; } if (isSetType()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.type, typedOther.type); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.type, other.type); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetPathElement()).compareTo(typedOther.isSetPathElement()); + lastComparison = Boolean.valueOf(isSetPathElement()).compareTo(other.isSetPathElement()); if (lastComparison != 0) { return lastComparison; } if (isSetPathElement()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.pathElement, typedOther.pathElement); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.pathElement, other.pathElement); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetChildren()).compareTo(typedOther.isSetChildren()); + lastComparison = Boolean.valueOf(isSetChildren()).compareTo(other.isSetChildren()); if (lastComparison != 0) { return lastComparison; } if (isSetChildren()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.children, typedOther.children); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.children, other.children); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetAuthzObjs()).compareTo(typedOther.isSetAuthzObjs()); + lastComparison = Boolean.valueOf(isSetAuthzObjs()).compareTo(other.isSetAuthzObjs()); if (lastComparison != 0) { return lastComparison; } if (isSetAuthzObjs()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.authzObjs, typedOther.authzObjs); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.authzObjs, other.authzObjs); if (lastComparison != 0) { return lastComparison; } @@ -640,11 +638,11 @@ public class TPathEntry implements org.apache.thrift.TBase<TPathEntry, TPathEntr { org.apache.thrift.protocol.TSet _set32 = iprot.readSetBegin(); struct.children = new HashSet<Integer>(2*_set32.size); - for (int _i33 = 0; _i33 < _set32.size; ++_i33) + int _elem33; + for (int _i34 = 0; _i34 < _set32.size; ++_i34) { - int _elem34; // required - _elem34 = iprot.readI32(); - struct.children.add(_elem34); + _elem33 = iprot.readI32(); + struct.children.add(_elem33); } iprot.readSetEnd(); } @@ -658,11 +656,11 @@ public class TPathEntry implements org.apache.thrift.TBase<TPathEntry, TPathEntr { org.apache.thrift.protocol.TSet _set35 = iprot.readSetBegin(); struct.authzObjs = new HashSet<String>(2*_set35.size); - for (int _i36 = 0; _i36 < _set35.size; ++_i36) + String _elem36; + for (int _i37 = 0; _i37 < _set35.size; ++_i37) { - String _elem37; // required - _elem37 = iprot.readString(); - struct.authzObjs.add(_elem37); + _elem36 = iprot.readString(); + struct.authzObjs.add(_elem36); } iprot.readSetEnd(); } @@ -770,11 +768,11 @@ public class TPathEntry implements org.apache.thrift.TBase<TPathEntry, TPathEntr { org.apache.thrift.protocol.TSet _set42 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32()); struct.children = new HashSet<Integer>(2*_set42.size); - for (int _i43 = 0; _i43 < _set42.size; ++_i43) + int _elem43; + for (int _i44 = 0; _i44 < _set42.size; ++_i44) { - int _elem44; // required - _elem44 = iprot.readI32(); - struct.children.add(_elem44); + _elem43 = iprot.readI32(); + struct.children.add(_elem43); } } struct.setChildrenIsSet(true); @@ -783,11 +781,11 @@ public class TPathEntry implements org.apache.thrift.TBase<TPathEntry, TPathEntr { org.apache.thrift.protocol.TSet _set45 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); struct.authzObjs = new HashSet<String>(2*_set45.size); - for (int _i46 = 0; _i46 < _set45.size; ++_i46) + String _elem46; + for (int _i47 = 0; _i47 < _set45.size; ++_i47) { - String _elem47; // required - _elem47 = iprot.readString(); - struct.authzObjs.add(_elem47); + _elem46 = iprot.readString(); + struct.authzObjs.add(_elem46); } } struct.setAuthzObjsIsSet(true);
