You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2013/04/30 20:33:09 UTC
svn commit: r1477758 [4/6] - in /accumulo/trunk:
core/src/main/java/org/apache/accumulo/core/client/admin/
core/src/main/java/org/apache/accumulo/core/client/mock/
core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/
core/src/main/java/org/...
Modified: accumulo/trunk/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java?rev=1477758&r1=1477757&r2=1477758&view=diff
==============================================================================
--- accumulo/trunk/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java (original)
+++ accumulo/trunk/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java Tue Apr 30 18:33:06 2013
@@ -122,6 +122,8 @@ import org.slf4j.LoggerFactory;
public Map<String,String> tableIdMap(ByteBuffer login) throws org.apache.thrift.TException;
+ public List<DiskUsage> getDiskUsage(ByteBuffer login, Set<String> tables) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException;
+
public void pingTabletServer(ByteBuffer login, String tserver) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException;
public List<ActiveScan> getActiveScans(ByteBuffer login, String tserver) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException;
@@ -268,6 +270,8 @@ import org.slf4j.LoggerFactory;
public void tableIdMap(ByteBuffer login, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.tableIdMap_call> resultHandler) throws org.apache.thrift.TException;
+ public void getDiskUsage(ByteBuffer login, Set<String> tables, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getDiskUsage_call> resultHandler) throws org.apache.thrift.TException;
+
public void pingTabletServer(ByteBuffer login, String tserver, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.pingTabletServer_call> resultHandler) throws org.apache.thrift.TException;
public void getActiveScans(ByteBuffer login, String tserver, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getActiveScans_call> resultHandler) throws org.apache.thrift.TException;
@@ -1491,6 +1495,39 @@ import org.slf4j.LoggerFactory;
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "tableIdMap failed: unknown result");
}
+ public List<DiskUsage> getDiskUsage(ByteBuffer login, Set<String> tables) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
+ {
+ send_getDiskUsage(login, tables);
+ return recv_getDiskUsage();
+ }
+
+ public void send_getDiskUsage(ByteBuffer login, Set<String> tables) throws org.apache.thrift.TException
+ {
+ getDiskUsage_args args = new getDiskUsage_args();
+ args.setLogin(login);
+ args.setTables(tables);
+ sendBase("getDiskUsage", args);
+ }
+
+ public List<DiskUsage> recv_getDiskUsage() throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
+ {
+ getDiskUsage_result result = new getDiskUsage_result();
+ receiveBase(result, "getDiskUsage");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ouch1 != null) {
+ throw result.ouch1;
+ }
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ if (result.ouch3 != null) {
+ throw result.ouch3;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getDiskUsage failed: unknown result");
+ }
+
public void pingTabletServer(ByteBuffer login, String tserver) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
{
send_pingTabletServer(login, tserver);
@@ -3910,6 +3947,41 @@ import org.slf4j.LoggerFactory;
}
}
+ public void getDiskUsage(ByteBuffer login, Set<String> tables, org.apache.thrift.async.AsyncMethodCallback<getDiskUsage_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getDiskUsage_call method_call = new getDiskUsage_call(login, tables, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getDiskUsage_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private ByteBuffer login;
+ private Set<String> tables;
+ public getDiskUsage_call(ByteBuffer login, Set<String> tables, org.apache.thrift.async.AsyncMethodCallback<getDiskUsage_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.login = login;
+ this.tables = tables;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getDiskUsage", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getDiskUsage_args args = new getDiskUsage_args();
+ args.setLogin(login);
+ args.setTables(tables);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public List<DiskUsage> getResult() throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ 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_getDiskUsage();
+ }
+ }
+
public void pingTabletServer(ByteBuffer login, String tserver, org.apache.thrift.async.AsyncMethodCallback<pingTabletServer_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
pingTabletServer_call method_call = new pingTabletServer_call(login, tserver, resultHandler, this, ___protocolFactory, ___transport);
@@ -5210,6 +5282,7 @@ import org.slf4j.LoggerFactory;
processMap.put("splitRangeByTablets", new splitRangeByTablets());
processMap.put("tableExists", new tableExists());
processMap.put("tableIdMap", new tableIdMap());
+ processMap.put("getDiskUsage", new getDiskUsage());
processMap.put("pingTabletServer", new pingTabletServer());
processMap.put("getActiveScans", new getActiveScans());
processMap.put("getActiveCompactions", new getActiveCompactions());
@@ -6230,6 +6303,34 @@ import org.slf4j.LoggerFactory;
}
}
+ public static class getDiskUsage<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getDiskUsage_args> {
+ public getDiskUsage() {
+ super("getDiskUsage");
+ }
+
+ public getDiskUsage_args getEmptyArgsInstance() {
+ return new getDiskUsage_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getDiskUsage_result getResult(I iface, getDiskUsage_args args) throws org.apache.thrift.TException {
+ getDiskUsage_result result = new getDiskUsage_result();
+ try {
+ result.success = iface.getDiskUsage(args.login, args.tables);
+ } catch (AccumuloException ouch1) {
+ result.ouch1 = ouch1;
+ } catch (AccumuloSecurityException ouch2) {
+ result.ouch2 = ouch2;
+ } catch (TableNotFoundException ouch3) {
+ result.ouch3 = ouch3;
+ }
+ return result;
+ }
+ }
+
public static class pingTabletServer<I extends Iface> extends org.apache.thrift.ProcessFunction<I, pingTabletServer_args> {
public pingTabletServer() {
super("pingTabletServer");
@@ -7539,15 +7640,15 @@ import org.slf4j.LoggerFactory;
case 2: // LOGIN_PROPERTIES
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map114 = iprot.readMapBegin();
- struct.loginProperties = new HashMap<String,String>(2*_map114.size);
- for (int _i115 = 0; _i115 < _map114.size; ++_i115)
+ org.apache.thrift.protocol.TMap _map122 = iprot.readMapBegin();
+ struct.loginProperties = new HashMap<String,String>(2*_map122.size);
+ for (int _i123 = 0; _i123 < _map122.size; ++_i123)
{
- String _key116; // required
- String _val117; // required
- _key116 = iprot.readString();
- _val117 = iprot.readString();
- struct.loginProperties.put(_key116, _val117);
+ String _key124; // required
+ String _val125; // required
+ _key124 = iprot.readString();
+ _val125 = iprot.readString();
+ struct.loginProperties.put(_key124, _val125);
}
iprot.readMapEnd();
}
@@ -7580,10 +7681,10 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(LOGIN_PROPERTIES_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.loginProperties.size()));
- for (Map.Entry<String, String> _iter118 : struct.loginProperties.entrySet())
+ for (Map.Entry<String, String> _iter126 : struct.loginProperties.entrySet())
{
- oprot.writeString(_iter118.getKey());
- oprot.writeString(_iter118.getValue());
+ oprot.writeString(_iter126.getKey());
+ oprot.writeString(_iter126.getValue());
}
oprot.writeMapEnd();
}
@@ -7620,10 +7721,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetLoginProperties()) {
{
oprot.writeI32(struct.loginProperties.size());
- for (Map.Entry<String, String> _iter119 : struct.loginProperties.entrySet())
+ for (Map.Entry<String, String> _iter127 : struct.loginProperties.entrySet())
{
- oprot.writeString(_iter119.getKey());
- oprot.writeString(_iter119.getValue());
+ oprot.writeString(_iter127.getKey());
+ oprot.writeString(_iter127.getValue());
}
}
}
@@ -7639,15 +7740,15 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TMap _map120 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.loginProperties = new HashMap<String,String>(2*_map120.size);
- for (int _i121 = 0; _i121 < _map120.size; ++_i121)
+ org.apache.thrift.protocol.TMap _map128 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.loginProperties = new HashMap<String,String>(2*_map128.size);
+ for (int _i129 = 0; _i129 < _map128.size; ++_i129)
{
- String _key122; // required
- String _val123; // required
- _key122 = iprot.readString();
- _val123 = iprot.readString();
- struct.loginProperties.put(_key122, _val123);
+ String _key130; // required
+ String _val131; // required
+ _key130 = iprot.readString();
+ _val131 = iprot.readString();
+ struct.loginProperties.put(_key130, _val131);
}
}
struct.setLoginPropertiesIsSet(true);
@@ -9841,13 +9942,13 @@ import org.slf4j.LoggerFactory;
case 3: // SPLITS
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set124 = iprot.readSetBegin();
- struct.splits = new HashSet<ByteBuffer>(2*_set124.size);
- for (int _i125 = 0; _i125 < _set124.size; ++_i125)
+ org.apache.thrift.protocol.TSet _set132 = iprot.readSetBegin();
+ struct.splits = new HashSet<ByteBuffer>(2*_set132.size);
+ for (int _i133 = 0; _i133 < _set132.size; ++_i133)
{
- ByteBuffer _elem126; // required
- _elem126 = iprot.readBinary();
- struct.splits.add(_elem126);
+ ByteBuffer _elem134; // required
+ _elem134 = iprot.readBinary();
+ struct.splits.add(_elem134);
}
iprot.readSetEnd();
}
@@ -9885,9 +9986,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SPLITS_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, struct.splits.size()));
- for (ByteBuffer _iter127 : struct.splits)
+ for (ByteBuffer _iter135 : struct.splits)
{
- oprot.writeBinary(_iter127);
+ oprot.writeBinary(_iter135);
}
oprot.writeSetEnd();
}
@@ -9930,9 +10031,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSplits()) {
{
oprot.writeI32(struct.splits.size());
- for (ByteBuffer _iter128 : struct.splits)
+ for (ByteBuffer _iter136 : struct.splits)
{
- oprot.writeBinary(_iter128);
+ oprot.writeBinary(_iter136);
}
}
}
@@ -9952,13 +10053,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TSet _set129 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.splits = new HashSet<ByteBuffer>(2*_set129.size);
- for (int _i130 = 0; _i130 < _set129.size; ++_i130)
+ org.apache.thrift.protocol.TSet _set137 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.splits = new HashSet<ByteBuffer>(2*_set137.size);
+ for (int _i138 = 0; _i138 < _set137.size; ++_i138)
{
- ByteBuffer _elem131; // required
- _elem131 = iprot.readBinary();
- struct.splits.add(_elem131);
+ ByteBuffer _elem139; // required
+ _elem139 = iprot.readBinary();
+ struct.splits.add(_elem139);
}
}
struct.setSplitsIsSet(true);
@@ -11107,13 +11208,13 @@ import org.slf4j.LoggerFactory;
case 4: // SCOPES
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set132 = iprot.readSetBegin();
- struct.scopes = new HashSet<IteratorScope>(2*_set132.size);
- for (int _i133 = 0; _i133 < _set132.size; ++_i133)
+ org.apache.thrift.protocol.TSet _set140 = iprot.readSetBegin();
+ struct.scopes = new HashSet<IteratorScope>(2*_set140.size);
+ for (int _i141 = 0; _i141 < _set140.size; ++_i141)
{
- IteratorScope _elem134; // required
- _elem134 = IteratorScope.findByValue(iprot.readI32());
- struct.scopes.add(_elem134);
+ IteratorScope _elem142; // required
+ _elem142 = IteratorScope.findByValue(iprot.readI32());
+ struct.scopes.add(_elem142);
}
iprot.readSetEnd();
}
@@ -11156,9 +11257,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SCOPES_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, struct.scopes.size()));
- for (IteratorScope _iter135 : struct.scopes)
+ for (IteratorScope _iter143 : struct.scopes)
{
- oprot.writeI32(_iter135.getValue());
+ oprot.writeI32(_iter143.getValue());
}
oprot.writeSetEnd();
}
@@ -11207,9 +11308,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetScopes()) {
{
oprot.writeI32(struct.scopes.size());
- for (IteratorScope _iter136 : struct.scopes)
+ for (IteratorScope _iter144 : struct.scopes)
{
- oprot.writeI32(_iter136.getValue());
+ oprot.writeI32(_iter144.getValue());
}
}
}
@@ -11234,13 +11335,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TSet _set137 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.scopes = new HashSet<IteratorScope>(2*_set137.size);
- for (int _i138 = 0; _i138 < _set137.size; ++_i138)
+ org.apache.thrift.protocol.TSet _set145 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.scopes = new HashSet<IteratorScope>(2*_set145.size);
+ for (int _i146 = 0; _i146 < _set145.size; ++_i146)
{
- IteratorScope _elem139; // required
- _elem139 = IteratorScope.findByValue(iprot.readI32());
- struct.scopes.add(_elem139);
+ IteratorScope _elem147; // required
+ _elem147 = IteratorScope.findByValue(iprot.readI32());
+ struct.scopes.add(_elem147);
}
}
struct.setScopesIsSet(true);
@@ -12389,13 +12490,13 @@ import org.slf4j.LoggerFactory;
case 4: // SCOPES
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set140 = iprot.readSetBegin();
- struct.scopes = new HashSet<IteratorScope>(2*_set140.size);
- for (int _i141 = 0; _i141 < _set140.size; ++_i141)
+ org.apache.thrift.protocol.TSet _set148 = iprot.readSetBegin();
+ struct.scopes = new HashSet<IteratorScope>(2*_set148.size);
+ for (int _i149 = 0; _i149 < _set148.size; ++_i149)
{
- IteratorScope _elem142; // required
- _elem142 = IteratorScope.findByValue(iprot.readI32());
- struct.scopes.add(_elem142);
+ IteratorScope _elem150; // required
+ _elem150 = IteratorScope.findByValue(iprot.readI32());
+ struct.scopes.add(_elem150);
}
iprot.readSetEnd();
}
@@ -12438,9 +12539,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SCOPES_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, struct.scopes.size()));
- for (IteratorScope _iter143 : struct.scopes)
+ for (IteratorScope _iter151 : struct.scopes)
{
- oprot.writeI32(_iter143.getValue());
+ oprot.writeI32(_iter151.getValue());
}
oprot.writeSetEnd();
}
@@ -12489,9 +12590,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetScopes()) {
{
oprot.writeI32(struct.scopes.size());
- for (IteratorScope _iter144 : struct.scopes)
+ for (IteratorScope _iter152 : struct.scopes)
{
- oprot.writeI32(_iter144.getValue());
+ oprot.writeI32(_iter152.getValue());
}
}
}
@@ -12516,13 +12617,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TSet _set145 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.scopes = new HashSet<IteratorScope>(2*_set145.size);
- for (int _i146 = 0; _i146 < _set145.size; ++_i146)
+ org.apache.thrift.protocol.TSet _set153 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.scopes = new HashSet<IteratorScope>(2*_set153.size);
+ for (int _i154 = 0; _i154 < _set153.size; ++_i154)
{
- IteratorScope _elem147; // required
- _elem147 = IteratorScope.findByValue(iprot.readI32());
- struct.scopes.add(_elem147);
+ IteratorScope _elem155; // required
+ _elem155 = IteratorScope.findByValue(iprot.readI32());
+ struct.scopes.add(_elem155);
}
}
struct.setScopesIsSet(true);
@@ -14675,15 +14776,15 @@ import org.slf4j.LoggerFactory;
case 5: // PROPERTIES_TO_SET
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map148 = iprot.readMapBegin();
- struct.propertiesToSet = new HashMap<String,String>(2*_map148.size);
- for (int _i149 = 0; _i149 < _map148.size; ++_i149)
+ org.apache.thrift.protocol.TMap _map156 = iprot.readMapBegin();
+ struct.propertiesToSet = new HashMap<String,String>(2*_map156.size);
+ for (int _i157 = 0; _i157 < _map156.size; ++_i157)
{
- String _key150; // required
- String _val151; // required
- _key150 = iprot.readString();
- _val151 = iprot.readString();
- struct.propertiesToSet.put(_key150, _val151);
+ String _key158; // required
+ String _val159; // required
+ _key158 = iprot.readString();
+ _val159 = iprot.readString();
+ struct.propertiesToSet.put(_key158, _val159);
}
iprot.readMapEnd();
}
@@ -14695,13 +14796,13 @@ import org.slf4j.LoggerFactory;
case 6: // PROPERTIES_TO_EXCLUDE
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set152 = iprot.readSetBegin();
- struct.propertiesToExclude = new HashSet<String>(2*_set152.size);
- for (int _i153 = 0; _i153 < _set152.size; ++_i153)
+ org.apache.thrift.protocol.TSet _set160 = iprot.readSetBegin();
+ struct.propertiesToExclude = new HashSet<String>(2*_set160.size);
+ for (int _i161 = 0; _i161 < _set160.size; ++_i161)
{
- String _elem154; // required
- _elem154 = iprot.readString();
- struct.propertiesToExclude.add(_elem154);
+ String _elem162; // required
+ _elem162 = iprot.readString();
+ struct.propertiesToExclude.add(_elem162);
}
iprot.readSetEnd();
}
@@ -14747,10 +14848,10 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PROPERTIES_TO_SET_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.propertiesToSet.size()));
- for (Map.Entry<String, String> _iter155 : struct.propertiesToSet.entrySet())
+ for (Map.Entry<String, String> _iter163 : struct.propertiesToSet.entrySet())
{
- oprot.writeString(_iter155.getKey());
- oprot.writeString(_iter155.getValue());
+ oprot.writeString(_iter163.getKey());
+ oprot.writeString(_iter163.getValue());
}
oprot.writeMapEnd();
}
@@ -14760,9 +14861,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PROPERTIES_TO_EXCLUDE_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, struct.propertiesToExclude.size()));
- for (String _iter156 : struct.propertiesToExclude)
+ for (String _iter164 : struct.propertiesToExclude)
{
- oprot.writeString(_iter156);
+ oprot.writeString(_iter164);
}
oprot.writeSetEnd();
}
@@ -14820,19 +14921,19 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPropertiesToSet()) {
{
oprot.writeI32(struct.propertiesToSet.size());
- for (Map.Entry<String, String> _iter157 : struct.propertiesToSet.entrySet())
+ for (Map.Entry<String, String> _iter165 : struct.propertiesToSet.entrySet())
{
- oprot.writeString(_iter157.getKey());
- oprot.writeString(_iter157.getValue());
+ oprot.writeString(_iter165.getKey());
+ oprot.writeString(_iter165.getValue());
}
}
}
if (struct.isSetPropertiesToExclude()) {
{
oprot.writeI32(struct.propertiesToExclude.size());
- for (String _iter158 : struct.propertiesToExclude)
+ for (String _iter166 : struct.propertiesToExclude)
{
- oprot.writeString(_iter158);
+ oprot.writeString(_iter166);
}
}
}
@@ -14860,28 +14961,28 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(4)) {
{
- org.apache.thrift.protocol.TMap _map159 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.propertiesToSet = new HashMap<String,String>(2*_map159.size);
- for (int _i160 = 0; _i160 < _map159.size; ++_i160)
+ org.apache.thrift.protocol.TMap _map167 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.propertiesToSet = new HashMap<String,String>(2*_map167.size);
+ for (int _i168 = 0; _i168 < _map167.size; ++_i168)
{
- String _key161; // required
- String _val162; // required
- _key161 = iprot.readString();
- _val162 = iprot.readString();
- struct.propertiesToSet.put(_key161, _val162);
+ String _key169; // required
+ String _val170; // required
+ _key169 = iprot.readString();
+ _val170 = iprot.readString();
+ struct.propertiesToSet.put(_key169, _val170);
}
}
struct.setPropertiesToSetIsSet(true);
}
if (incoming.get(5)) {
{
- org.apache.thrift.protocol.TSet _set163 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.propertiesToExclude = new HashSet<String>(2*_set163.size);
- for (int _i164 = 0; _i164 < _set163.size; ++_i164)
+ org.apache.thrift.protocol.TSet _set171 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.propertiesToExclude = new HashSet<String>(2*_set171.size);
+ for (int _i172 = 0; _i172 < _set171.size; ++_i172)
{
- String _elem165; // required
- _elem165 = iprot.readString();
- struct.propertiesToExclude.add(_elem165);
+ String _elem173; // required
+ _elem173 = iprot.readString();
+ struct.propertiesToExclude.add(_elem173);
}
}
struct.setPropertiesToExcludeIsSet(true);
@@ -16385,14 +16486,14 @@ import org.slf4j.LoggerFactory;
case 5: // ITERATORS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list166 = iprot.readListBegin();
- struct.iterators = new ArrayList<IteratorSetting>(_list166.size);
- for (int _i167 = 0; _i167 < _list166.size; ++_i167)
+ org.apache.thrift.protocol.TList _list174 = iprot.readListBegin();
+ struct.iterators = new ArrayList<IteratorSetting>(_list174.size);
+ for (int _i175 = 0; _i175 < _list174.size; ++_i175)
{
- IteratorSetting _elem168; // required
- _elem168 = new IteratorSetting();
- _elem168.read(iprot);
- struct.iterators.add(_elem168);
+ IteratorSetting _elem176; // required
+ _elem176 = new IteratorSetting();
+ _elem176.read(iprot);
+ struct.iterators.add(_elem176);
}
iprot.readListEnd();
}
@@ -16456,9 +16557,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(ITERATORS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.iterators.size()));
- for (IteratorSetting _iter169 : struct.iterators)
+ for (IteratorSetting _iter177 : struct.iterators)
{
- _iter169.write(oprot);
+ _iter177.write(oprot);
}
oprot.writeListEnd();
}
@@ -16525,9 +16626,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetIterators()) {
{
oprot.writeI32(struct.iterators.size());
- for (IteratorSetting _iter170 : struct.iterators)
+ for (IteratorSetting _iter178 : struct.iterators)
{
- _iter170.write(oprot);
+ _iter178.write(oprot);
}
}
}
@@ -16561,14 +16662,14 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(4)) {
{
- org.apache.thrift.protocol.TList _list171 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.iterators = new ArrayList<IteratorSetting>(_list171.size);
- for (int _i172 = 0; _i172 < _list171.size; ++_i172)
+ org.apache.thrift.protocol.TList _list179 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.iterators = new ArrayList<IteratorSetting>(_list179.size);
+ for (int _i180 = 0; _i180 < _list179.size; ++_i180)
{
- IteratorSetting _elem173; // required
- _elem173 = new IteratorSetting();
- _elem173.read(iprot);
- struct.iterators.add(_elem173);
+ IteratorSetting _elem181; // required
+ _elem181 = new IteratorSetting();
+ _elem181.read(iprot);
+ struct.iterators.add(_elem181);
}
}
struct.setIteratorsIsSet(true);
@@ -25166,25 +25267,25 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map174 = iprot.readMapBegin();
- struct.success = new HashMap<String,Set<String>>(2*_map174.size);
- for (int _i175 = 0; _i175 < _map174.size; ++_i175)
+ org.apache.thrift.protocol.TMap _map182 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Set<String>>(2*_map182.size);
+ for (int _i183 = 0; _i183 < _map182.size; ++_i183)
{
- String _key176; // required
- Set<String> _val177; // required
- _key176 = iprot.readString();
+ String _key184; // required
+ Set<String> _val185; // required
+ _key184 = iprot.readString();
{
- org.apache.thrift.protocol.TSet _set178 = iprot.readSetBegin();
- _val177 = new HashSet<String>(2*_set178.size);
- for (int _i179 = 0; _i179 < _set178.size; ++_i179)
+ org.apache.thrift.protocol.TSet _set186 = iprot.readSetBegin();
+ _val185 = new HashSet<String>(2*_set186.size);
+ for (int _i187 = 0; _i187 < _set186.size; ++_i187)
{
- String _elem180; // required
- _elem180 = iprot.readString();
- _val177.add(_elem180);
+ String _elem188; // required
+ _elem188 = iprot.readString();
+ _val185.add(_elem188);
}
iprot.readSetEnd();
}
- struct.success.put(_key176, _val177);
+ struct.success.put(_key184, _val185);
}
iprot.readMapEnd();
}
@@ -25239,14 +25340,14 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.SET, struct.success.size()));
- for (Map.Entry<String, Set<String>> _iter181 : struct.success.entrySet())
+ for (Map.Entry<String, Set<String>> _iter189 : struct.success.entrySet())
{
- oprot.writeString(_iter181.getKey());
+ oprot.writeString(_iter189.getKey());
{
- oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, _iter181.getValue().size()));
- for (String _iter182 : _iter181.getValue())
+ oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, _iter189.getValue().size()));
+ for (String _iter190 : _iter189.getValue())
{
- oprot.writeString(_iter182);
+ oprot.writeString(_iter190);
}
oprot.writeSetEnd();
}
@@ -25304,14 +25405,14 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Set<String>> _iter183 : struct.success.entrySet())
+ for (Map.Entry<String, Set<String>> _iter191 : struct.success.entrySet())
{
- oprot.writeString(_iter183.getKey());
+ oprot.writeString(_iter191.getKey());
{
- oprot.writeI32(_iter183.getValue().size());
- for (String _iter184 : _iter183.getValue())
+ oprot.writeI32(_iter191.getValue().size());
+ for (String _iter192 : _iter191.getValue())
{
- oprot.writeString(_iter184);
+ oprot.writeString(_iter192);
}
}
}
@@ -25334,24 +25435,24 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map185 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.SET, iprot.readI32());
- struct.success = new HashMap<String,Set<String>>(2*_map185.size);
- for (int _i186 = 0; _i186 < _map185.size; ++_i186)
+ org.apache.thrift.protocol.TMap _map193 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.SET, iprot.readI32());
+ struct.success = new HashMap<String,Set<String>>(2*_map193.size);
+ for (int _i194 = 0; _i194 < _map193.size; ++_i194)
{
- String _key187; // required
- Set<String> _val188; // required
- _key187 = iprot.readString();
+ String _key195; // required
+ Set<String> _val196; // required
+ _key195 = iprot.readString();
{
- org.apache.thrift.protocol.TSet _set189 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- _val188 = new HashSet<String>(2*_set189.size);
- for (int _i190 = 0; _i190 < _set189.size; ++_i190)
+ org.apache.thrift.protocol.TSet _set197 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ _val196 = new HashSet<String>(2*_set197.size);
+ for (int _i198 = 0; _i198 < _set197.size; ++_i198)
{
- String _elem191; // required
- _elem191 = iprot.readString();
- _val188.add(_elem191);
+ String _elem199; // required
+ _elem199 = iprot.readString();
+ _val196.add(_elem199);
}
}
- struct.success.put(_key187, _val188);
+ struct.success.put(_key195, _val196);
}
}
struct.setSuccessIsSet(true);
@@ -27540,13 +27641,13 @@ import org.slf4j.LoggerFactory;
case 3: // AUTHS
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set192 = iprot.readSetBegin();
- struct.auths = new HashSet<ByteBuffer>(2*_set192.size);
- for (int _i193 = 0; _i193 < _set192.size; ++_i193)
+ org.apache.thrift.protocol.TSet _set200 = iprot.readSetBegin();
+ struct.auths = new HashSet<ByteBuffer>(2*_set200.size);
+ for (int _i201 = 0; _i201 < _set200.size; ++_i201)
{
- ByteBuffer _elem194; // required
- _elem194 = iprot.readBinary();
- struct.auths.add(_elem194);
+ ByteBuffer _elem202; // required
+ _elem202 = iprot.readBinary();
+ struct.auths.add(_elem202);
}
iprot.readSetEnd();
}
@@ -27616,9 +27717,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(AUTHS_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, struct.auths.size()));
- for (ByteBuffer _iter195 : struct.auths)
+ for (ByteBuffer _iter203 : struct.auths)
{
- oprot.writeBinary(_iter195);
+ oprot.writeBinary(_iter203);
}
oprot.writeSetEnd();
}
@@ -27689,9 +27790,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetAuths()) {
{
oprot.writeI32(struct.auths.size());
- for (ByteBuffer _iter196 : struct.auths)
+ for (ByteBuffer _iter204 : struct.auths)
{
- oprot.writeBinary(_iter196);
+ oprot.writeBinary(_iter204);
}
}
}
@@ -27723,13 +27824,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TSet _set197 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.auths = new HashSet<ByteBuffer>(2*_set197.size);
- for (int _i198 = 0; _i198 < _set197.size; ++_i198)
+ org.apache.thrift.protocol.TSet _set205 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.auths = new HashSet<ByteBuffer>(2*_set205.size);
+ for (int _i206 = 0; _i206 < _set205.size; ++_i206)
{
- ByteBuffer _elem199; // required
- _elem199 = iprot.readBinary();
- struct.auths.add(_elem199);
+ ByteBuffer _elem207; // required
+ _elem207 = iprot.readBinary();
+ struct.auths.add(_elem207);
}
}
struct.setAuthsIsSet(true);
@@ -29436,15 +29537,15 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map200 = iprot.readMapBegin();
- struct.success = new HashMap<String,String>(2*_map200.size);
- for (int _i201 = 0; _i201 < _map200.size; ++_i201)
+ org.apache.thrift.protocol.TMap _map208 = iprot.readMapBegin();
+ struct.success = new HashMap<String,String>(2*_map208.size);
+ for (int _i209 = 0; _i209 < _map208.size; ++_i209)
{
- String _key202; // required
- String _val203; // required
- _key202 = iprot.readString();
- _val203 = iprot.readString();
- struct.success.put(_key202, _val203);
+ String _key210; // required
+ String _val211; // required
+ _key210 = iprot.readString();
+ _val211 = iprot.readString();
+ struct.success.put(_key210, _val211);
}
iprot.readMapEnd();
}
@@ -29499,10 +29600,10 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (Map.Entry<String, String> _iter204 : struct.success.entrySet())
+ for (Map.Entry<String, String> _iter212 : struct.success.entrySet())
{
- oprot.writeString(_iter204.getKey());
- oprot.writeString(_iter204.getValue());
+ oprot.writeString(_iter212.getKey());
+ oprot.writeString(_iter212.getValue());
}
oprot.writeMapEnd();
}
@@ -29557,10 +29658,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, String> _iter205 : struct.success.entrySet())
+ for (Map.Entry<String, String> _iter213 : struct.success.entrySet())
{
- oprot.writeString(_iter205.getKey());
- oprot.writeString(_iter205.getValue());
+ oprot.writeString(_iter213.getKey());
+ oprot.writeString(_iter213.getValue());
}
}
}
@@ -29581,15 +29682,15 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map206 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new HashMap<String,String>(2*_map206.size);
- for (int _i207 = 0; _i207 < _map206.size; ++_i207)
+ org.apache.thrift.protocol.TMap _map214 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new HashMap<String,String>(2*_map214.size);
+ for (int _i215 = 0; _i215 < _map214.size; ++_i215)
{
- String _key208; // required
- String _val209; // required
- _key208 = iprot.readString();
- _val209 = iprot.readString();
- struct.success.put(_key208, _val209);
+ String _key216; // required
+ String _val217; // required
+ _key216 = iprot.readString();
+ _val217 = iprot.readString();
+ struct.success.put(_key216, _val217);
}
}
struct.setSuccessIsSet(true);
@@ -33167,13 +33268,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list210 = iprot.readListBegin();
- struct.success = new ArrayList<ByteBuffer>(_list210.size);
- for (int _i211 = 0; _i211 < _list210.size; ++_i211)
+ org.apache.thrift.protocol.TList _list218 = iprot.readListBegin();
+ struct.success = new ArrayList<ByteBuffer>(_list218.size);
+ for (int _i219 = 0; _i219 < _list218.size; ++_i219)
{
- ByteBuffer _elem212; // required
- _elem212 = iprot.readBinary();
- struct.success.add(_elem212);
+ ByteBuffer _elem220; // required
+ _elem220 = iprot.readBinary();
+ struct.success.add(_elem220);
}
iprot.readListEnd();
}
@@ -33228,9 +33329,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (ByteBuffer _iter213 : struct.success)
+ for (ByteBuffer _iter221 : struct.success)
{
- oprot.writeBinary(_iter213);
+ oprot.writeBinary(_iter221);
}
oprot.writeListEnd();
}
@@ -33285,9 +33386,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (ByteBuffer _iter214 : struct.success)
+ for (ByteBuffer _iter222 : struct.success)
{
- oprot.writeBinary(_iter214);
+ oprot.writeBinary(_iter222);
}
}
}
@@ -33308,13 +33409,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list215 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<ByteBuffer>(_list215.size);
- for (int _i216 = 0; _i216 < _list215.size; ++_i216)
+ org.apache.thrift.protocol.TList _list223 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<ByteBuffer>(_list223.size);
+ for (int _i224 = 0; _i224 < _list223.size; ++_i224)
{
- ByteBuffer _elem217; // required
- _elem217 = iprot.readBinary();
- struct.success.add(_elem217);
+ ByteBuffer _elem225; // required
+ _elem225 = iprot.readBinary();
+ struct.success.add(_elem225);
}
}
struct.setSuccessIsSet(true);
@@ -34013,13 +34114,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set218 = iprot.readSetBegin();
- struct.success = new HashSet<String>(2*_set218.size);
- for (int _i219 = 0; _i219 < _set218.size; ++_i219)
+ org.apache.thrift.protocol.TSet _set226 = iprot.readSetBegin();
+ struct.success = new HashSet<String>(2*_set226.size);
+ for (int _i227 = 0; _i227 < _set226.size; ++_i227)
{
- String _elem220; // required
- _elem220 = iprot.readString();
- struct.success.add(_elem220);
+ String _elem228; // required
+ _elem228 = iprot.readString();
+ struct.success.add(_elem228);
}
iprot.readSetEnd();
}
@@ -34047,9 +34148,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter221 : struct.success)
+ for (String _iter229 : struct.success)
{
- oprot.writeString(_iter221);
+ oprot.writeString(_iter229);
}
oprot.writeSetEnd();
}
@@ -34080,9 +34181,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter222 : struct.success)
+ for (String _iter230 : struct.success)
{
- oprot.writeString(_iter222);
+ oprot.writeString(_iter230);
}
}
}
@@ -34094,13 +34195,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TSet _set223 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new HashSet<String>(2*_set223.size);
- for (int _i224 = 0; _i224 < _set223.size; ++_i224)
+ org.apache.thrift.protocol.TSet _set231 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new HashSet<String>(2*_set231.size);
+ for (int _i232 = 0; _i232 < _set231.size; ++_i232)
{
- String _elem225; // required
- _elem225 = iprot.readString();
- struct.success.add(_elem225);
+ String _elem233; // required
+ _elem233 = iprot.readString();
+ struct.success.add(_elem233);
}
}
struct.setSuccessIsSet(true);
@@ -35124,25 +35225,25 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map226 = iprot.readMapBegin();
- struct.success = new HashMap<String,Set<IteratorScope>>(2*_map226.size);
- for (int _i227 = 0; _i227 < _map226.size; ++_i227)
+ org.apache.thrift.protocol.TMap _map234 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Set<IteratorScope>>(2*_map234.size);
+ for (int _i235 = 0; _i235 < _map234.size; ++_i235)
{
- String _key228; // required
- Set<IteratorScope> _val229; // required
- _key228 = iprot.readString();
+ String _key236; // required
+ Set<IteratorScope> _val237; // required
+ _key236 = iprot.readString();
{
- org.apache.thrift.protocol.TSet _set230 = iprot.readSetBegin();
- _val229 = new HashSet<IteratorScope>(2*_set230.size);
- for (int _i231 = 0; _i231 < _set230.size; ++_i231)
+ org.apache.thrift.protocol.TSet _set238 = iprot.readSetBegin();
+ _val237 = new HashSet<IteratorScope>(2*_set238.size);
+ for (int _i239 = 0; _i239 < _set238.size; ++_i239)
{
- IteratorScope _elem232; // required
- _elem232 = IteratorScope.findByValue(iprot.readI32());
- _val229.add(_elem232);
+ IteratorScope _elem240; // required
+ _elem240 = IteratorScope.findByValue(iprot.readI32());
+ _val237.add(_elem240);
}
iprot.readSetEnd();
}
- struct.success.put(_key228, _val229);
+ struct.success.put(_key236, _val237);
}
iprot.readMapEnd();
}
@@ -35197,14 +35298,14 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.SET, struct.success.size()));
- for (Map.Entry<String, Set<IteratorScope>> _iter233 : struct.success.entrySet())
+ for (Map.Entry<String, Set<IteratorScope>> _iter241 : struct.success.entrySet())
{
- oprot.writeString(_iter233.getKey());
+ oprot.writeString(_iter241.getKey());
{
- oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, _iter233.getValue().size()));
- for (IteratorScope _iter234 : _iter233.getValue())
+ oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, _iter241.getValue().size()));
+ for (IteratorScope _iter242 : _iter241.getValue())
{
- oprot.writeI32(_iter234.getValue());
+ oprot.writeI32(_iter242.getValue());
}
oprot.writeSetEnd();
}
@@ -35262,14 +35363,14 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Set<IteratorScope>> _iter235 : struct.success.entrySet())
+ for (Map.Entry<String, Set<IteratorScope>> _iter243 : struct.success.entrySet())
{
- oprot.writeString(_iter235.getKey());
+ oprot.writeString(_iter243.getKey());
{
- oprot.writeI32(_iter235.getValue().size());
- for (IteratorScope _iter236 : _iter235.getValue())
+ oprot.writeI32(_iter243.getValue().size());
+ for (IteratorScope _iter244 : _iter243.getValue())
{
- oprot.writeI32(_iter236.getValue());
+ oprot.writeI32(_iter244.getValue());
}
}
}
@@ -35292,24 +35393,24 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map237 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.SET, iprot.readI32());
- struct.success = new HashMap<String,Set<IteratorScope>>(2*_map237.size);
- for (int _i238 = 0; _i238 < _map237.size; ++_i238)
+ org.apache.thrift.protocol.TMap _map245 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.SET, iprot.readI32());
+ struct.success = new HashMap<String,Set<IteratorScope>>(2*_map245.size);
+ for (int _i246 = 0; _i246 < _map245.size; ++_i246)
{
- String _key239; // required
- Set<IteratorScope> _val240; // required
- _key239 = iprot.readString();
+ String _key247; // required
+ Set<IteratorScope> _val248; // required
+ _key247 = iprot.readString();
{
- org.apache.thrift.protocol.TSet _set241 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32());
- _val240 = new HashSet<IteratorScope>(2*_set241.size);
- for (int _i242 = 0; _i242 < _set241.size; ++_i242)
+ org.apache.thrift.protocol.TSet _set249 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ _val248 = new HashSet<IteratorScope>(2*_set249.size);
+ for (int _i250 = 0; _i250 < _set249.size; ++_i250)
{
- IteratorScope _elem243; // required
- _elem243 = IteratorScope.findByValue(iprot.readI32());
- _val240.add(_elem243);
+ IteratorScope _elem251; // required
+ _elem251 = IteratorScope.findByValue(iprot.readI32());
+ _val248.add(_elem251);
}
}
- struct.success.put(_key239, _val240);
+ struct.success.put(_key247, _val248);
}
}
struct.setSuccessIsSet(true);
@@ -36344,15 +36445,15 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map244 = iprot.readMapBegin();
- struct.success = new HashMap<String,Integer>(2*_map244.size);
- for (int _i245 = 0; _i245 < _map244.size; ++_i245)
+ org.apache.thrift.protocol.TMap _map252 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Integer>(2*_map252.size);
+ for (int _i253 = 0; _i253 < _map252.size; ++_i253)
{
- String _key246; // required
- int _val247; // required
- _key246 = iprot.readString();
- _val247 = iprot.readI32();
- struct.success.put(_key246, _val247);
+ String _key254; // required
+ int _val255; // required
+ _key254 = iprot.readString();
+ _val255 = iprot.readI32();
+ struct.success.put(_key254, _val255);
}
iprot.readMapEnd();
}
@@ -36407,10 +36508,10 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, struct.success.size()));
- for (Map.Entry<String, Integer> _iter248 : struct.success.entrySet())
+ for (Map.Entry<String, Integer> _iter256 : struct.success.entrySet())
{
- oprot.writeString(_iter248.getKey());
- oprot.writeI32(_iter248.getValue());
+ oprot.writeString(_iter256.getKey());
+ oprot.writeI32(_iter256.getValue());
}
oprot.writeMapEnd();
}
@@ -36465,10 +36566,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Integer> _iter249 : struct.success.entrySet())
+ for (Map.Entry<String, Integer> _iter257 : struct.success.entrySet())
{
- oprot.writeString(_iter249.getKey());
- oprot.writeI32(_iter249.getValue());
+ oprot.writeString(_iter257.getKey());
+ oprot.writeI32(_iter257.getValue());
}
}
}
@@ -36489,15 +36590,15 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map250 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.success = new HashMap<String,Integer>(2*_map250.size);
- for (int _i251 = 0; _i251 < _map250.size; ++_i251)
+ org.apache.thrift.protocol.TMap _map258 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.success = new HashMap<String,Integer>(2*_map258.size);
+ for (int _i259 = 0; _i259 < _map258.size; ++_i259)
{
- String _key252; // required
- int _val253; // required
- _key252 = iprot.readString();
- _val253 = iprot.readI32();
- struct.success.put(_key252, _val253);
+ String _key260; // required
+ int _val261; // required
+ _key260 = iprot.readString();
+ _val261 = iprot.readI32();
+ struct.success.put(_key260, _val261);
}
}
struct.setSuccessIsSet(true);
@@ -41517,13 +41618,13 @@ import org.slf4j.LoggerFactory;
case 4: // SCOPES
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set254 = iprot.readSetBegin();
- struct.scopes = new HashSet<IteratorScope>(2*_set254.size);
- for (int _i255 = 0; _i255 < _set254.size; ++_i255)
+ org.apache.thrift.protocol.TSet _set262 = iprot.readSetBegin();
+ struct.scopes = new HashSet<IteratorScope>(2*_set262.size);
+ for (int _i263 = 0; _i263 < _set262.size; ++_i263)
{
- IteratorScope _elem256; // required
- _elem256 = IteratorScope.findByValue(iprot.readI32());
- struct.scopes.add(_elem256);
+ IteratorScope _elem264; // required
+ _elem264 = IteratorScope.findByValue(iprot.readI32());
+ struct.scopes.add(_elem264);
}
iprot.readSetEnd();
}
@@ -41566,9 +41667,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SCOPES_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, struct.scopes.size()));
- for (IteratorScope _iter257 : struct.scopes)
+ for (IteratorScope _iter265 : struct.scopes)
{
- oprot.writeI32(_iter257.getValue());
+ oprot.writeI32(_iter265.getValue());
}
oprot.writeSetEnd();
}
@@ -41617,9 +41718,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetScopes()) {
{
oprot.writeI32(struct.scopes.size());
- for (IteratorScope _iter258 : struct.scopes)
+ for (IteratorScope _iter266 : struct.scopes)
{
- oprot.writeI32(_iter258.getValue());
+ oprot.writeI32(_iter266.getValue());
}
}
}
@@ -41643,13 +41744,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TSet _set259 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.scopes = new HashSet<IteratorScope>(2*_set259.size);
- for (int _i260 = 0; _i260 < _set259.size; ++_i260)
+ org.apache.thrift.protocol.TSet _set267 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.scopes = new HashSet<IteratorScope>(2*_set267.size);
+ for (int _i268 = 0; _i268 < _set267.size; ++_i268)
{
- IteratorScope _elem261; // required
- _elem261 = IteratorScope.findByValue(iprot.readI32());
- struct.scopes.add(_elem261);
+ IteratorScope _elem269; // required
+ _elem269 = IteratorScope.findByValue(iprot.readI32());
+ struct.scopes.add(_elem269);
}
}
struct.setScopesIsSet(true);
@@ -45070,25 +45171,25 @@ import org.slf4j.LoggerFactory;
case 3: // GROUPS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map262 = iprot.readMapBegin();
- struct.groups = new HashMap<String,Set<String>>(2*_map262.size);
- for (int _i263 = 0; _i263 < _map262.size; ++_i263)
+ org.apache.thrift.protocol.TMap _map270 = iprot.readMapBegin();
+ struct.groups = new HashMap<String,Set<String>>(2*_map270.size);
+ for (int _i271 = 0; _i271 < _map270.size; ++_i271)
{
- String _key264; // required
- Set<String> _val265; // required
- _key264 = iprot.readString();
+ String _key272; // required
+ Set<String> _val273; // required
+ _key272 = iprot.readString();
{
- org.apache.thrift.protocol.TSet _set266 = iprot.readSetBegin();
- _val265 = new HashSet<String>(2*_set266.size);
- for (int _i267 = 0; _i267 < _set266.size; ++_i267)
+ org.apache.thrift.protocol.TSet _set274 = iprot.readSetBegin();
+ _val273 = new HashSet<String>(2*_set274.size);
+ for (int _i275 = 0; _i275 < _set274.size; ++_i275)
{
- String _elem268; // required
- _elem268 = iprot.readString();
- _val265.add(_elem268);
+ String _elem276; // required
+ _elem276 = iprot.readString();
+ _val273.add(_elem276);
}
iprot.readSetEnd();
}
- struct.groups.put(_key264, _val265);
+ struct.groups.put(_key272, _val273);
}
iprot.readMapEnd();
}
@@ -45126,14 +45227,14 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(GROUPS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.SET, struct.groups.size()));
- for (Map.Entry<String, Set<String>> _iter269 : struct.groups.entrySet())
+ for (Map.Entry<String, Set<String>> _iter277 : struct.groups.entrySet())
{
- oprot.writeString(_iter269.getKey());
+ oprot.writeString(_iter277.getKey());
{
- oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, _iter269.getValue().size()));
- for (String _iter270 : _iter269.getValue())
+ oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, _iter277.getValue().size()));
+ for (String _iter278 : _iter277.getValue())
{
- oprot.writeString(_iter270);
+ oprot.writeString(_iter278);
}
oprot.writeSetEnd();
}
@@ -45179,14 +45280,14 @@ import org.slf4j.LoggerFactory;
if (struct.isSetGroups()) {
{
oprot.writeI32(struct.groups.size());
- for (Map.Entry<String, Set<String>> _iter271 : struct.groups.entrySet())
+ for (Map.Entry<String, Set<String>> _iter279 : struct.groups.entrySet())
{
- oprot.writeString(_iter271.getKey());
+ oprot.writeString(_iter279.getKey());
{
- oprot.writeI32(_iter271.getValue().size());
- for (String _iter272 : _iter271.getValue())
+ oprot.writeI32(_iter279.getValue().size());
+ for (String _iter280 : _iter279.getValue())
{
- oprot.writeString(_iter272);
+ oprot.writeString(_iter280);
}
}
}
@@ -45208,24 +45309,24 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TMap _map273 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.SET, iprot.readI32());
- struct.groups = new HashMap<String,Set<String>>(2*_map273.size);
- for (int _i274 = 0; _i274 < _map273.size; ++_i274)
+ org.apache.thrift.protocol.TMap _map281 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.SET, iprot.readI32());
+ struct.groups = new HashMap<String,Set<String>>(2*_map281.size);
+ for (int _i282 = 0; _i282 < _map281.size; ++_i282)
{
- String _key275; // required
- Set<String> _val276; // required
- _key275 = iprot.readString();
+ String _key283; // required
+ Set<String> _val284; // required
+ _key283 = iprot.readString();
{
- org.apache.thrift.protocol.TSet _set277 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- _val276 = new HashSet<String>(2*_set277.size);
- for (int _i278 = 0; _i278 < _set277.size; ++_i278)
+ org.apache.thrift.protocol.TSet _set285 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ _val284 = new HashSet<String>(2*_set285.size);
+ for (int _i286 = 0; _i286 < _set285.size; ++_i286)
{
- String _elem279; // required
- _elem279 = iprot.readString();
- _val276.add(_elem279);
+ String _elem287; // required
+ _elem287 = iprot.readString();
+ _val284.add(_elem287);
}
}
- struct.groups.put(_key275, _val276);
+ struct.groups.put(_key283, _val284);
}
}
struct.setGroupsIsSet(true);
@@ -48228,14 +48329,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set280 = iprot.readSetBegin();
- struct.success = new HashSet<Range>(2*_set280.size);
- for (int _i281 = 0; _i281 < _set280.size; ++_i281)
+ org.apache.thrift.protocol.TSet _set288 = iprot.readSetBegin();
+ struct.success = new HashSet<Range>(2*_set288.size);
+ for (int _i289 = 0; _i289 < _set288.size; ++_i289)
{
- Range _elem282; // required
- _elem282 = new Range();
- _elem282.read(iprot);
- struct.success.add(_elem282);
+ Range _elem290; // required
+ _elem290 = new Range();
+ _elem290.read(iprot);
+ struct.success.add(_elem290);
}
iprot.readSetEnd();
}
@@ -48290,9 +48391,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (Range _iter283 : struct.success)
+ for (Range _iter291 : struct.success)
{
- _iter283.write(oprot);
+ _iter291.write(oprot);
}
oprot.writeSetEnd();
}
@@ -48347,9 +48448,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Range _iter284 : struct.success)
+ for (Range _iter292 : struct.success)
{
- _iter284.write(oprot);
+ _iter292.write(oprot);
}
}
}
@@ -48370,14 +48471,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TSet _set285 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new HashSet<Range>(2*_set285.size);
- for (int _i286 = 0; _i286 < _set285.size; ++_i286)
+ org.apache.thrift.protocol.TSet _set293 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new HashSet<Range>(2*_set293.size);
+ for (int _i294 = 0; _i294 < _set293.size; ++_i294)
{
- Range _elem287; // required
- _elem287 = new Range();
- _elem287.read(iprot);
- struct.success.add(_elem287);
+ Range _elem295; // required
+ _elem295 = new Range();
+ _elem295.read(iprot);
+ struct.success.add(_elem295);
}
}
struct.setSuccessIsSet(true);
@@ -49900,15 +50001,15 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map288 = iprot.readMapBegin();
- struct.success = new HashMap<String,String>(2*_map288.size);
- for (int _i289 = 0; _i289 < _map288.size; ++_i289)
+ org.apache.thrift.protocol.TMap _map296 = iprot.readMapBegin();
+ struct.success = new HashMap<String,String>(2*_map296.size);
+ for (int _i297 = 0; _i297 < _map296.size; ++_i297)
{
- String _key290; // required
- String _val291; // required
- _key290 = iprot.readString();
- _val291 = iprot.readString();
- struct.success.put(_key290, _val291);
+ String _key298; // required
+ String _val299; // required
+ _key298 = iprot.readString();
+ _val299 = iprot.readString();
+ struct.success.put(_key298, _val299);
}
iprot.readMapEnd();
}
@@ -49936,10 +50037,10 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (Map.Entry<String, String> _iter292 : struct.success.entrySet())
+ for (Map.Entry<String, String> _iter300 : struct.success.entrySet())
{
- oprot.writeString(_iter292.getKey());
- oprot.writeString(_iter292.getValue());
+ oprot.writeString(_iter300.getKey());
+ oprot.writeString(_iter300.getValue());
}
oprot.writeMapEnd();
}
@@ -49970,10 +50071,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, String> _iter293 : struct.success.entrySet())
+ for (Map.Entry<String, String> _iter301 : struct.success.entrySet())
{
- oprot.writeString(_iter293.getKey());
- oprot.writeString(_iter293.getValue());
+ oprot.writeString(_iter301.getKey());
+ oprot.writeString(_iter301.getValue());
}
}
}
@@ -49985,15 +50086,15 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map294 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new HashMap<String,String>(2*_map294.size);
- for (int _i295 = 0; _i295 < _map294.size; ++_i295)
+ org.apache.thrift.protocol.TMap _map302 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new HashMap<String,String>(2*_map302.size);
+ for (int _i303 = 0; _i303 < _map302.size; ++_i303)
{
- String _key296; // required
- String _val297; // required
- _key296 = iprot.readString();
- _val297 = iprot.readString();
- struct.success.put(_key296, _val297);
+ String _key304; // required
+ String _val305; // required
+ _key304 = iprot.readString();
+ _val305 = iprot.readString();
+ struct.success.put(_key304, _val305);
}
}
struct.setSuccessIsSet(true);
@@ -50003,6 +50104,1237 @@ import org.slf4j.LoggerFactory;
}
+ public static class getDiskUsage_args implements org.apache.thrift.TBase<getDiskUsage_args, getDiskUsage_args._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getDiskUsage_args");
+
+ private static final org.apache.thrift.protocol.TField LOGIN_FIELD_DESC = new org.apache.thrift.protocol.TField("login", org.apache.thrift.protocol.TType.STRING, (short)1);
+ private static final org.apache.thrift.protocol.TField TABLES_FIELD_DESC = new org.apache.thrift.protocol.TField("tables", org.apache.thrift.protocol.TType.SET, (short)2);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new getDiskUsage_argsStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new getDiskUsage_argsTupleSchemeFactory());
+ }
+
+ public ByteBuffer login; // required
+ public Set<String> tables; // required
+
+ /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+ @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ LOGIN((short)1, "login"),
+ TABLES((short)2, "tables");
+
+ private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+ static {
+ for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ byName.put(field.getFieldName(), field);
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, or null if its not found.
+ */
+ public static _Fields findByThriftId(int fieldId) {
+ switch(fieldId) {
+ case 1: // LOGIN
+ return LOGIN;
+ case 2: // TABLES
+ return TABLES;
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+
+ // isset id assignments
+ 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);
+ tmpMap.put(_Fields.LOGIN, new org.apache.thrift.meta_data.FieldMetaData("login", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true)));
+ tmpMap.put(_Fields.TABLES, new org.apache.thrift.meta_data.FieldMetaData("tables", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.SetMetaData(org.apache.thrift.protocol.TType.SET,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getDiskUsage_args.class, metaDataMap);
+ }
+
+ public getDiskUsage_args() {
+ }
+
+ public getDiskUsage_args(
+ ByteBuffer login,
+ Set<String> tables)
+ {
+ this();
+ this.login = login;
+ this.tables = tables;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public getDiskUsage_args(getDiskUsage_args other) {
+ if (other.isSetLogin()) {
+ this.login = org.apache.thrift.TBaseHelper.copyBinary(other.login);
+;
+ }
+ if (other.isSetTables()) {
+ Set<String> __this__tables = new HashSet<String>();
+ for (String other_element : other.tables) {
+ __this__tables.add(other_element);
+ }
+ this.tables = __this__tables;
+ }
+ }
+
+ public getDiskUsage_args deepCopy() {
+ return new getDiskUsage_args(this);
+ }
+
+ @Override
+ public void clear() {
+ this.login = null;
+ this.tables = null;
+ }
+
+ public byte[] getLogin() {
+ setLogin(org.apache.thrift.TBaseHelper.rightSize(login));
+ return login == null ? null : login.array();
+ }
+
+ public ByteBuffer bufferForLogin() {
+ return login;
+ }
+
+ public getDiskUsage_args setLogin(byte[] login) {
+ setLogin(login == null ? (ByteBuffer)null : ByteBuffer.wrap(login));
+ return this;
+ }
+
+ public getDiskUsage_args setLogin(ByteBuffer login) {
+ this.login = login;
+ return this;
+ }
+
+ public void unsetLogin() {
+ this.login = null;
+ }
+
+ /** Returns true if field login is set (has been assigned a value) and false otherwise */
+ public boolean isSetLogin() {
+ return this.login != null;
+ }
+
+ public void setLoginIsSet(boolean value) {
+ if (!value) {
+ this.login = null;
+ }
+ }
+
+ public int getTablesSize() {
+ return (this.tables == null) ? 0 : this.tables.size();
+ }
+
+ public java.util.Iterator<String> getTablesIterator() {
+ return (this.tables == null) ? null : this.tables.iterator();
+ }
+
+ public void addToTables(String elem) {
+ if (this.tables == null) {
+ this.tables = new HashSet<String>();
+ }
+ this.tables.add(elem);
+ }
+
+ public Set<String> getTables() {
+ return this.tables;
+ }
+
+ public getDiskUsage_args setTables(Set<String> tables) {
+ this.tables = tables;
+ return this;
+ }
+
+ public void unsetTables() {
+ this.tables = null;
+ }
+
+ /** Returns true if field tables is set (has been assigned a value) and false otherwise */
+ public boolean isSetTables() {
+ return this.tables != null;
+ }
+
+ public void setTablesIsSet(boolean value) {
+ if (!value) {
+ this.tables = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case LOGIN:
+ if (value == null) {
+ unsetLogin();
+ } else {
+ setLogin((ByteBuffer)value);
+ }
+ break;
+
+ case TABLES:
+ if (value == null) {
+ unsetTables();
+ } else {
+ setTables((Set<String>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case LOGIN:
+ return getLogin();
+
+ case TABLES:
+ return getTables();
+
+ }
+ throw new IllegalStateException();
+ }
+
+ /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+ public boolean isSet(_Fields field) {
+ if (field == null) {
+ throw new IllegalArgumentException();
+ }
+
+ switch (field) {
+ case LOGIN:
+ return isSetLogin();
+ case TABLES:
+ return isSetTables();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof getDiskUsage_args)
+ return this.equals((getDiskUsage_args)that);
+ return false;
+ }
+
+ public boolean equals(getDiskUsage_args that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_login = true && this.isSetLogin();
+ boolean that_present_login = true && that.isSetLogin();
+ if (this_present_login || that_present_login) {
+ if (!(this_present_login && that_present_login))
+ return false;
+ if (!this.login.equals(that.login))
+ return false;
+ }
+
+ boolean this_present_tables = true && this.isSetTables();
+ boolean that_present_tables = true && that.isSetTables();
+ if (this_present_tables || that_present_tables) {
+ if (!(this_present_tables && that_present_tables))
+ return false;
+ if (!this.tables.equals(that.tables))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ return 0;
+ }
+
+ public int compareTo(getDiskUsage_args other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+ getDiskUsage_args typedOther = (getDiskUsage_args)other;
+
+ lastComparison = Boolean.valueOf(isSetLogin()).compareTo(typedOther.isSetLogin());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetLogin()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.login, typedOther.login);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetTables()).compareTo(typedOther.isSetTables());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetTables()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tables, typedOther.tables);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ return 0;
+ }
+
+ public _Fields fieldForId(int fieldId) {
+ return _Fields.findByThriftId(fieldId);
+ }
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("getDiskUsage_args(");
+ boolean first = true;
+
+ sb.append("login:");
+ if (this.login == null) {
+ sb.append("null");
+ } else {
+ org.apache.thrift.TBaseHelper.toString(this.login, sb);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("tables:");
+ if (this.tables == null) {
+ sb.append("null");
[... 1750 lines stripped ...]