You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by kt...@apache.org on 2014/12/05 04:51:33 UTC
[3/6] accumulo git commit: ACCUMULO-1798 Add ability to specify
compaction strategy for user specificed compactions.
http://git-wip-us.apache.org/repos/asf/accumulo/blob/2f788f48/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java
----------------------------------------------------------------------
diff --git a/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java b/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java
index 3b23175..65863b9 100644
--- a/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java
+++ b/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java
@@ -66,7 +66,7 @@ import org.slf4j.LoggerFactory;
public void cloneTable(ByteBuffer login, String tableName, String newTableName, boolean flush, Map<String,String> propertiesToSet, Set<String> propertiesToExclude) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, TableExistsException, org.apache.thrift.TException;
- public void compactTable(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, List<IteratorSetting> iterators, boolean flush, boolean wait) throws AccumuloSecurityException, TableNotFoundException, AccumuloException, org.apache.thrift.TException;
+ public void compactTable(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, List<IteratorSetting> iterators, boolean flush, boolean wait, CompactionStrategyConfig compactionStrategy) throws AccumuloSecurityException, TableNotFoundException, AccumuloException, org.apache.thrift.TException;
public void cancelCompaction(ByteBuffer login, String tableName) throws AccumuloSecurityException, TableNotFoundException, AccumuloException, org.apache.thrift.TException;
@@ -224,7 +224,7 @@ import org.slf4j.LoggerFactory;
public void cloneTable(ByteBuffer login, String tableName, String newTableName, boolean flush, Map<String,String> propertiesToSet, Set<String> propertiesToExclude, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void compactTable(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, List<IteratorSetting> iterators, boolean flush, boolean wait, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void compactTable(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, List<IteratorSetting> iterators, boolean flush, boolean wait, CompactionStrategyConfig compactionStrategy, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void cancelCompaction(ByteBuffer login, String tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -603,13 +603,13 @@ import org.slf4j.LoggerFactory;
return;
}
- public void compactTable(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, List<IteratorSetting> iterators, boolean flush, boolean wait) throws AccumuloSecurityException, TableNotFoundException, AccumuloException, org.apache.thrift.TException
+ public void compactTable(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, List<IteratorSetting> iterators, boolean flush, boolean wait, CompactionStrategyConfig compactionStrategy) throws AccumuloSecurityException, TableNotFoundException, AccumuloException, org.apache.thrift.TException
{
- send_compactTable(login, tableName, startRow, endRow, iterators, flush, wait);
+ send_compactTable(login, tableName, startRow, endRow, iterators, flush, wait, compactionStrategy);
recv_compactTable();
}
- public void send_compactTable(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, List<IteratorSetting> iterators, boolean flush, boolean wait) throws org.apache.thrift.TException
+ public void send_compactTable(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, List<IteratorSetting> iterators, boolean flush, boolean wait, CompactionStrategyConfig compactionStrategy) throws org.apache.thrift.TException
{
compactTable_args args = new compactTable_args();
args.setLogin(login);
@@ -619,6 +619,7 @@ import org.slf4j.LoggerFactory;
args.setIterators(iterators);
args.setFlush(flush);
args.setWait(wait);
+ args.setCompactionStrategy(compactionStrategy);
sendBase("compactTable", args);
}
@@ -3008,9 +3009,9 @@ import org.slf4j.LoggerFactory;
}
}
- public void compactTable(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, List<IteratorSetting> iterators, boolean flush, boolean wait, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void compactTable(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, List<IteratorSetting> iterators, boolean flush, boolean wait, CompactionStrategyConfig compactionStrategy, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
- compactTable_call method_call = new compactTable_call(login, tableName, startRow, endRow, iterators, flush, wait, resultHandler, this, ___protocolFactory, ___transport);
+ compactTable_call method_call = new compactTable_call(login, tableName, startRow, endRow, iterators, flush, wait, compactionStrategy, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
@@ -3023,7 +3024,8 @@ import org.slf4j.LoggerFactory;
private List<IteratorSetting> iterators;
private boolean flush;
private boolean wait;
- public compactTable_call(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, List<IteratorSetting> iterators, boolean flush, boolean wait, 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 {
+ private CompactionStrategyConfig compactionStrategy;
+ public compactTable_call(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, List<IteratorSetting> iterators, boolean flush, boolean wait, CompactionStrategyConfig compactionStrategy, 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.login = login;
this.tableName = tableName;
@@ -3032,6 +3034,7 @@ import org.slf4j.LoggerFactory;
this.iterators = iterators;
this.flush = flush;
this.wait = wait;
+ this.compactionStrategy = compactionStrategy;
}
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
@@ -3044,6 +3047,7 @@ import org.slf4j.LoggerFactory;
args.setIterators(iterators);
args.setFlush(flush);
args.setWait(wait);
+ args.setCompactionStrategy(compactionStrategy);
args.write(prot);
prot.writeMessageEnd();
}
@@ -5907,7 +5911,7 @@ import org.slf4j.LoggerFactory;
public compactTable_result getResult(I iface, compactTable_args args) throws org.apache.thrift.TException {
compactTable_result result = new compactTable_result();
try {
- iface.compactTable(args.login, args.tableName, args.startRow, args.endRow, args.iterators, args.flush, args.wait);
+ iface.compactTable(args.login, args.tableName, args.startRow, args.endRow, args.iterators, args.flush, args.wait, args.compactionStrategy);
} catch (AccumuloSecurityException ouch1) {
result.ouch1 = ouch1;
} catch (TableNotFoundException ouch2) {
@@ -8356,7 +8360,7 @@ import org.slf4j.LoggerFactory;
}
public void start(I iface, compactTable_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
- iface.compactTable(args.login, args.tableName, args.startRow, args.endRow, args.iterators, args.flush, args.wait,resultHandler);
+ iface.compactTable(args.login, args.tableName, args.startRow, args.endRow, args.iterators, args.flush, args.wait, args.compactionStrategy,resultHandler);
}
}
@@ -13091,15 +13095,15 @@ import org.slf4j.LoggerFactory;
case 2: // LOGIN_PROPERTIES
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map154 = iprot.readMapBegin();
- struct.loginProperties = new HashMap<String,String>(2*_map154.size);
- for (int _i155 = 0; _i155 < _map154.size; ++_i155)
+ org.apache.thrift.protocol.TMap _map164 = iprot.readMapBegin();
+ struct.loginProperties = new HashMap<String,String>(2*_map164.size);
+ for (int _i165 = 0; _i165 < _map164.size; ++_i165)
{
- String _key156;
- String _val157;
- _key156 = iprot.readString();
- _val157 = iprot.readString();
- struct.loginProperties.put(_key156, _val157);
+ String _key166;
+ String _val167;
+ _key166 = iprot.readString();
+ _val167 = iprot.readString();
+ struct.loginProperties.put(_key166, _val167);
}
iprot.readMapEnd();
}
@@ -13132,10 +13136,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> _iter158 : struct.loginProperties.entrySet())
+ for (Map.Entry<String, String> _iter168 : struct.loginProperties.entrySet())
{
- oprot.writeString(_iter158.getKey());
- oprot.writeString(_iter158.getValue());
+ oprot.writeString(_iter168.getKey());
+ oprot.writeString(_iter168.getValue());
}
oprot.writeMapEnd();
}
@@ -13172,10 +13176,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetLoginProperties()) {
{
oprot.writeI32(struct.loginProperties.size());
- for (Map.Entry<String, String> _iter159 : struct.loginProperties.entrySet())
+ for (Map.Entry<String, String> _iter169 : struct.loginProperties.entrySet())
{
- oprot.writeString(_iter159.getKey());
- oprot.writeString(_iter159.getValue());
+ oprot.writeString(_iter169.getKey());
+ oprot.writeString(_iter169.getValue());
}
}
}
@@ -13191,15 +13195,15 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TMap _map160 = 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*_map160.size);
- for (int _i161 = 0; _i161 < _map160.size; ++_i161)
+ org.apache.thrift.protocol.TMap _map170 = 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*_map170.size);
+ for (int _i171 = 0; _i171 < _map170.size; ++_i171)
{
- String _key162;
- String _val163;
- _key162 = iprot.readString();
- _val163 = iprot.readString();
- struct.loginProperties.put(_key162, _val163);
+ String _key172;
+ String _val173;
+ _key172 = iprot.readString();
+ _val173 = iprot.readString();
+ struct.loginProperties.put(_key172, _val173);
}
}
struct.setLoginPropertiesIsSet(true);
@@ -15388,13 +15392,13 @@ import org.slf4j.LoggerFactory;
case 3: // SPLITS
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set164 = iprot.readSetBegin();
- struct.splits = new HashSet<ByteBuffer>(2*_set164.size);
- for (int _i165 = 0; _i165 < _set164.size; ++_i165)
+ org.apache.thrift.protocol.TSet _set174 = iprot.readSetBegin();
+ struct.splits = new HashSet<ByteBuffer>(2*_set174.size);
+ for (int _i175 = 0; _i175 < _set174.size; ++_i175)
{
- ByteBuffer _elem166;
- _elem166 = iprot.readBinary();
- struct.splits.add(_elem166);
+ ByteBuffer _elem176;
+ _elem176 = iprot.readBinary();
+ struct.splits.add(_elem176);
}
iprot.readSetEnd();
}
@@ -15432,9 +15436,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 _iter167 : struct.splits)
+ for (ByteBuffer _iter177 : struct.splits)
{
- oprot.writeBinary(_iter167);
+ oprot.writeBinary(_iter177);
}
oprot.writeSetEnd();
}
@@ -15477,9 +15481,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSplits()) {
{
oprot.writeI32(struct.splits.size());
- for (ByteBuffer _iter168 : struct.splits)
+ for (ByteBuffer _iter178 : struct.splits)
{
- oprot.writeBinary(_iter168);
+ oprot.writeBinary(_iter178);
}
}
}
@@ -15499,13 +15503,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TSet _set169 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.splits = new HashSet<ByteBuffer>(2*_set169.size);
- for (int _i170 = 0; _i170 < _set169.size; ++_i170)
+ org.apache.thrift.protocol.TSet _set179 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.splits = new HashSet<ByteBuffer>(2*_set179.size);
+ for (int _i180 = 0; _i180 < _set179.size; ++_i180)
{
- ByteBuffer _elem171;
- _elem171 = iprot.readBinary();
- struct.splits.add(_elem171);
+ ByteBuffer _elem181;
+ _elem181 = iprot.readBinary();
+ struct.splits.add(_elem181);
}
}
struct.setSplitsIsSet(true);
@@ -16654,13 +16658,13 @@ import org.slf4j.LoggerFactory;
case 4: // SCOPES
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set172 = iprot.readSetBegin();
- struct.scopes = new HashSet<IteratorScope>(2*_set172.size);
- for (int _i173 = 0; _i173 < _set172.size; ++_i173)
+ org.apache.thrift.protocol.TSet _set182 = iprot.readSetBegin();
+ struct.scopes = new HashSet<IteratorScope>(2*_set182.size);
+ for (int _i183 = 0; _i183 < _set182.size; ++_i183)
{
- IteratorScope _elem174;
- _elem174 = IteratorScope.findByValue(iprot.readI32());
- struct.scopes.add(_elem174);
+ IteratorScope _elem184;
+ _elem184 = IteratorScope.findByValue(iprot.readI32());
+ struct.scopes.add(_elem184);
}
iprot.readSetEnd();
}
@@ -16703,9 +16707,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 _iter175 : struct.scopes)
+ for (IteratorScope _iter185 : struct.scopes)
{
- oprot.writeI32(_iter175.getValue());
+ oprot.writeI32(_iter185.getValue());
}
oprot.writeSetEnd();
}
@@ -16754,9 +16758,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetScopes()) {
{
oprot.writeI32(struct.scopes.size());
- for (IteratorScope _iter176 : struct.scopes)
+ for (IteratorScope _iter186 : struct.scopes)
{
- oprot.writeI32(_iter176.getValue());
+ oprot.writeI32(_iter186.getValue());
}
}
}
@@ -16781,13 +16785,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TSet _set177 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.scopes = new HashSet<IteratorScope>(2*_set177.size);
- for (int _i178 = 0; _i178 < _set177.size; ++_i178)
+ org.apache.thrift.protocol.TSet _set187 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.scopes = new HashSet<IteratorScope>(2*_set187.size);
+ for (int _i188 = 0; _i188 < _set187.size; ++_i188)
{
- IteratorScope _elem179;
- _elem179 = IteratorScope.findByValue(iprot.readI32());
- struct.scopes.add(_elem179);
+ IteratorScope _elem189;
+ _elem189 = IteratorScope.findByValue(iprot.readI32());
+ struct.scopes.add(_elem189);
}
}
struct.setScopesIsSet(true);
@@ -17936,13 +17940,13 @@ import org.slf4j.LoggerFactory;
case 4: // SCOPES
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set180 = iprot.readSetBegin();
- struct.scopes = new HashSet<IteratorScope>(2*_set180.size);
- for (int _i181 = 0; _i181 < _set180.size; ++_i181)
+ org.apache.thrift.protocol.TSet _set190 = iprot.readSetBegin();
+ struct.scopes = new HashSet<IteratorScope>(2*_set190.size);
+ for (int _i191 = 0; _i191 < _set190.size; ++_i191)
{
- IteratorScope _elem182;
- _elem182 = IteratorScope.findByValue(iprot.readI32());
- struct.scopes.add(_elem182);
+ IteratorScope _elem192;
+ _elem192 = IteratorScope.findByValue(iprot.readI32());
+ struct.scopes.add(_elem192);
}
iprot.readSetEnd();
}
@@ -17985,9 +17989,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 _iter183 : struct.scopes)
+ for (IteratorScope _iter193 : struct.scopes)
{
- oprot.writeI32(_iter183.getValue());
+ oprot.writeI32(_iter193.getValue());
}
oprot.writeSetEnd();
}
@@ -18036,9 +18040,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetScopes()) {
{
oprot.writeI32(struct.scopes.size());
- for (IteratorScope _iter184 : struct.scopes)
+ for (IteratorScope _iter194 : struct.scopes)
{
- oprot.writeI32(_iter184.getValue());
+ oprot.writeI32(_iter194.getValue());
}
}
}
@@ -18063,13 +18067,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TSet _set185 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.scopes = new HashSet<IteratorScope>(2*_set185.size);
- for (int _i186 = 0; _i186 < _set185.size; ++_i186)
+ org.apache.thrift.protocol.TSet _set195 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.scopes = new HashSet<IteratorScope>(2*_set195.size);
+ for (int _i196 = 0; _i196 < _set195.size; ++_i196)
{
- IteratorScope _elem187;
- _elem187 = IteratorScope.findByValue(iprot.readI32());
- struct.scopes.add(_elem187);
+ IteratorScope _elem197;
+ _elem197 = IteratorScope.findByValue(iprot.readI32());
+ struct.scopes.add(_elem197);
}
}
struct.setScopesIsSet(true);
@@ -20208,15 +20212,15 @@ import org.slf4j.LoggerFactory;
case 5: // PROPERTIES_TO_SET
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map188 = iprot.readMapBegin();
- struct.propertiesToSet = new HashMap<String,String>(2*_map188.size);
- for (int _i189 = 0; _i189 < _map188.size; ++_i189)
+ org.apache.thrift.protocol.TMap _map198 = iprot.readMapBegin();
+ struct.propertiesToSet = new HashMap<String,String>(2*_map198.size);
+ for (int _i199 = 0; _i199 < _map198.size; ++_i199)
{
- String _key190;
- String _val191;
- _key190 = iprot.readString();
- _val191 = iprot.readString();
- struct.propertiesToSet.put(_key190, _val191);
+ String _key200;
+ String _val201;
+ _key200 = iprot.readString();
+ _val201 = iprot.readString();
+ struct.propertiesToSet.put(_key200, _val201);
}
iprot.readMapEnd();
}
@@ -20228,13 +20232,13 @@ import org.slf4j.LoggerFactory;
case 6: // PROPERTIES_TO_EXCLUDE
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set192 = iprot.readSetBegin();
- struct.propertiesToExclude = new HashSet<String>(2*_set192.size);
- for (int _i193 = 0; _i193 < _set192.size; ++_i193)
+ org.apache.thrift.protocol.TSet _set202 = iprot.readSetBegin();
+ struct.propertiesToExclude = new HashSet<String>(2*_set202.size);
+ for (int _i203 = 0; _i203 < _set202.size; ++_i203)
{
- String _elem194;
- _elem194 = iprot.readString();
- struct.propertiesToExclude.add(_elem194);
+ String _elem204;
+ _elem204 = iprot.readString();
+ struct.propertiesToExclude.add(_elem204);
}
iprot.readSetEnd();
}
@@ -20280,10 +20284,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> _iter195 : struct.propertiesToSet.entrySet())
+ for (Map.Entry<String, String> _iter205 : struct.propertiesToSet.entrySet())
{
- oprot.writeString(_iter195.getKey());
- oprot.writeString(_iter195.getValue());
+ oprot.writeString(_iter205.getKey());
+ oprot.writeString(_iter205.getValue());
}
oprot.writeMapEnd();
}
@@ -20293,9 +20297,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 _iter196 : struct.propertiesToExclude)
+ for (String _iter206 : struct.propertiesToExclude)
{
- oprot.writeString(_iter196);
+ oprot.writeString(_iter206);
}
oprot.writeSetEnd();
}
@@ -20353,19 +20357,19 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPropertiesToSet()) {
{
oprot.writeI32(struct.propertiesToSet.size());
- for (Map.Entry<String, String> _iter197 : struct.propertiesToSet.entrySet())
+ for (Map.Entry<String, String> _iter207 : struct.propertiesToSet.entrySet())
{
- oprot.writeString(_iter197.getKey());
- oprot.writeString(_iter197.getValue());
+ oprot.writeString(_iter207.getKey());
+ oprot.writeString(_iter207.getValue());
}
}
}
if (struct.isSetPropertiesToExclude()) {
{
oprot.writeI32(struct.propertiesToExclude.size());
- for (String _iter198 : struct.propertiesToExclude)
+ for (String _iter208 : struct.propertiesToExclude)
{
- oprot.writeString(_iter198);
+ oprot.writeString(_iter208);
}
}
}
@@ -20393,28 +20397,28 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(4)) {
{
- org.apache.thrift.protocol.TMap _map199 = 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*_map199.size);
- for (int _i200 = 0; _i200 < _map199.size; ++_i200)
+ org.apache.thrift.protocol.TMap _map209 = 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*_map209.size);
+ for (int _i210 = 0; _i210 < _map209.size; ++_i210)
{
- String _key201;
- String _val202;
- _key201 = iprot.readString();
- _val202 = iprot.readString();
- struct.propertiesToSet.put(_key201, _val202);
+ String _key211;
+ String _val212;
+ _key211 = iprot.readString();
+ _val212 = iprot.readString();
+ struct.propertiesToSet.put(_key211, _val212);
}
}
struct.setPropertiesToSetIsSet(true);
}
if (incoming.get(5)) {
{
- org.apache.thrift.protocol.TSet _set203 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.propertiesToExclude = new HashSet<String>(2*_set203.size);
- for (int _i204 = 0; _i204 < _set203.size; ++_i204)
+ org.apache.thrift.protocol.TSet _set213 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.propertiesToExclude = new HashSet<String>(2*_set213.size);
+ for (int _i214 = 0; _i214 < _set213.size; ++_i214)
{
- String _elem205;
- _elem205 = iprot.readString();
- struct.propertiesToExclude.add(_elem205);
+ String _elem215;
+ _elem215 = iprot.readString();
+ struct.propertiesToExclude.add(_elem215);
}
}
struct.setPropertiesToExcludeIsSet(true);
@@ -21096,6 +21100,7 @@ import org.slf4j.LoggerFactory;
private static final org.apache.thrift.protocol.TField ITERATORS_FIELD_DESC = new org.apache.thrift.protocol.TField("iterators", org.apache.thrift.protocol.TType.LIST, (short)5);
private static final org.apache.thrift.protocol.TField FLUSH_FIELD_DESC = new org.apache.thrift.protocol.TField("flush", org.apache.thrift.protocol.TType.BOOL, (short)6);
private static final org.apache.thrift.protocol.TField WAIT_FIELD_DESC = new org.apache.thrift.protocol.TField("wait", org.apache.thrift.protocol.TType.BOOL, (short)7);
+ private static final org.apache.thrift.protocol.TField COMPACTION_STRATEGY_FIELD_DESC = new org.apache.thrift.protocol.TField("compactionStrategy", org.apache.thrift.protocol.TType.STRUCT, (short)8);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
@@ -21110,6 +21115,7 @@ import org.slf4j.LoggerFactory;
public List<IteratorSetting> iterators; // required
public boolean flush; // required
public boolean wait; // required
+ public CompactionStrategyConfig compactionStrategy; // 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 {
@@ -21119,7 +21125,8 @@ import org.slf4j.LoggerFactory;
END_ROW((short)4, "endRow"),
ITERATORS((short)5, "iterators"),
FLUSH((short)6, "flush"),
- WAIT((short)7, "wait");
+ WAIT((short)7, "wait"),
+ COMPACTION_STRATEGY((short)8, "compactionStrategy");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -21148,6 +21155,8 @@ import org.slf4j.LoggerFactory;
return FLUSH;
case 7: // WAIT
return WAIT;
+ case 8: // COMPACTION_STRATEGY
+ return COMPACTION_STRATEGY;
default:
return null;
}
@@ -21209,6 +21218,8 @@ import org.slf4j.LoggerFactory;
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
tmpMap.put(_Fields.WAIT, new org.apache.thrift.meta_data.FieldMetaData("wait", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
+ tmpMap.put(_Fields.COMPACTION_STRATEGY, new org.apache.thrift.meta_data.FieldMetaData("compactionStrategy", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, CompactionStrategyConfig.class)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(compactTable_args.class, metaDataMap);
}
@@ -21223,7 +21234,8 @@ import org.slf4j.LoggerFactory;
ByteBuffer endRow,
List<IteratorSetting> iterators,
boolean flush,
- boolean wait)
+ boolean wait,
+ CompactionStrategyConfig compactionStrategy)
{
this();
this.login = login;
@@ -21235,6 +21247,7 @@ import org.slf4j.LoggerFactory;
setFlushIsSet(true);
this.wait = wait;
setWaitIsSet(true);
+ this.compactionStrategy = compactionStrategy;
}
/**
@@ -21266,6 +21279,9 @@ import org.slf4j.LoggerFactory;
}
this.flush = other.flush;
this.wait = other.wait;
+ if (other.isSetCompactionStrategy()) {
+ this.compactionStrategy = new CompactionStrategyConfig(other.compactionStrategy);
+ }
}
public compactTable_args deepCopy() {
@@ -21283,6 +21299,7 @@ import org.slf4j.LoggerFactory;
this.flush = false;
setWaitIsSet(false);
this.wait = false;
+ this.compactionStrategy = null;
}
public byte[] getLogin() {
@@ -21496,6 +21513,30 @@ import org.slf4j.LoggerFactory;
__isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __WAIT_ISSET_ID, value);
}
+ public CompactionStrategyConfig getCompactionStrategy() {
+ return this.compactionStrategy;
+ }
+
+ public compactTable_args setCompactionStrategy(CompactionStrategyConfig compactionStrategy) {
+ this.compactionStrategy = compactionStrategy;
+ return this;
+ }
+
+ public void unsetCompactionStrategy() {
+ this.compactionStrategy = null;
+ }
+
+ /** Returns true if field compactionStrategy is set (has been assigned a value) and false otherwise */
+ public boolean isSetCompactionStrategy() {
+ return this.compactionStrategy != null;
+ }
+
+ public void setCompactionStrategyIsSet(boolean value) {
+ if (!value) {
+ this.compactionStrategy = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case LOGIN:
@@ -21554,6 +21595,14 @@ import org.slf4j.LoggerFactory;
}
break;
+ case COMPACTION_STRATEGY:
+ if (value == null) {
+ unsetCompactionStrategy();
+ } else {
+ setCompactionStrategy((CompactionStrategyConfig)value);
+ }
+ break;
+
}
}
@@ -21580,6 +21629,9 @@ import org.slf4j.LoggerFactory;
case WAIT:
return Boolean.valueOf(isWait());
+ case COMPACTION_STRATEGY:
+ return getCompactionStrategy();
+
}
throw new IllegalStateException();
}
@@ -21605,6 +21657,8 @@ import org.slf4j.LoggerFactory;
return isSetFlush();
case WAIT:
return isSetWait();
+ case COMPACTION_STRATEGY:
+ return isSetCompactionStrategy();
}
throw new IllegalStateException();
}
@@ -21685,6 +21739,15 @@ import org.slf4j.LoggerFactory;
return false;
}
+ boolean this_present_compactionStrategy = true && this.isSetCompactionStrategy();
+ boolean that_present_compactionStrategy = true && that.isSetCompactionStrategy();
+ if (this_present_compactionStrategy || that_present_compactionStrategy) {
+ if (!(this_present_compactionStrategy && that_present_compactionStrategy))
+ return false;
+ if (!this.compactionStrategy.equals(that.compactionStrategy))
+ return false;
+ }
+
return true;
}
@@ -21771,6 +21834,16 @@ import org.slf4j.LoggerFactory;
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(isSetCompactionStrategy()).compareTo(other.isSetCompactionStrategy());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetCompactionStrategy()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.compactionStrategy, other.compactionStrategy);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -21838,6 +21911,14 @@ import org.slf4j.LoggerFactory;
sb.append("wait:");
sb.append(this.wait);
first = false;
+ if (!first) sb.append(", ");
+ sb.append("compactionStrategy:");
+ if (this.compactionStrategy == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.compactionStrategy);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -21845,6 +21926,9 @@ import org.slf4j.LoggerFactory;
public void validate() throws org.apache.thrift.TException {
// check for required fields
// check for sub-struct validity
+ if (compactionStrategy != null) {
+ compactionStrategy.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -21918,14 +22002,14 @@ import org.slf4j.LoggerFactory;
case 5: // ITERATORS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list206 = iprot.readListBegin();
- struct.iterators = new ArrayList<IteratorSetting>(_list206.size);
- for (int _i207 = 0; _i207 < _list206.size; ++_i207)
+ org.apache.thrift.protocol.TList _list216 = iprot.readListBegin();
+ struct.iterators = new ArrayList<IteratorSetting>(_list216.size);
+ for (int _i217 = 0; _i217 < _list216.size; ++_i217)
{
- IteratorSetting _elem208;
- _elem208 = new IteratorSetting();
- _elem208.read(iprot);
- struct.iterators.add(_elem208);
+ IteratorSetting _elem218;
+ _elem218 = new IteratorSetting();
+ _elem218.read(iprot);
+ struct.iterators.add(_elem218);
}
iprot.readListEnd();
}
@@ -21950,6 +22034,15 @@ import org.slf4j.LoggerFactory;
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
+ case 8: // COMPACTION_STRATEGY
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.compactionStrategy = new CompactionStrategyConfig();
+ struct.compactionStrategy.read(iprot);
+ struct.setCompactionStrategyIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@@ -21989,9 +22082,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 _iter209 : struct.iterators)
+ for (IteratorSetting _iter219 : struct.iterators)
{
- _iter209.write(oprot);
+ _iter219.write(oprot);
}
oprot.writeListEnd();
}
@@ -22003,6 +22096,11 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(WAIT_FIELD_DESC);
oprot.writeBool(struct.wait);
oprot.writeFieldEnd();
+ if (struct.compactionStrategy != null) {
+ oprot.writeFieldBegin(COMPACTION_STRATEGY_FIELD_DESC);
+ struct.compactionStrategy.write(oprot);
+ oprot.writeFieldEnd();
+ }
oprot.writeFieldStop();
oprot.writeStructEnd();
}
@@ -22042,7 +22140,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetWait()) {
optionals.set(6);
}
- oprot.writeBitSet(optionals, 7);
+ if (struct.isSetCompactionStrategy()) {
+ optionals.set(7);
+ }
+ oprot.writeBitSet(optionals, 8);
if (struct.isSetLogin()) {
oprot.writeBinary(struct.login);
}
@@ -22058,9 +22159,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetIterators()) {
{
oprot.writeI32(struct.iterators.size());
- for (IteratorSetting _iter210 : struct.iterators)
+ for (IteratorSetting _iter220 : struct.iterators)
{
- _iter210.write(oprot);
+ _iter220.write(oprot);
}
}
}
@@ -22070,12 +22171,15 @@ import org.slf4j.LoggerFactory;
if (struct.isSetWait()) {
oprot.writeBool(struct.wait);
}
+ if (struct.isSetCompactionStrategy()) {
+ struct.compactionStrategy.write(oprot);
+ }
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, compactTable_args struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(7);
+ BitSet incoming = iprot.readBitSet(8);
if (incoming.get(0)) {
struct.login = iprot.readBinary();
struct.setLoginIsSet(true);
@@ -22094,14 +22198,14 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(4)) {
{
- org.apache.thrift.protocol.TList _list211 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.iterators = new ArrayList<IteratorSetting>(_list211.size);
- for (int _i212 = 0; _i212 < _list211.size; ++_i212)
+ org.apache.thrift.protocol.TList _list221 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.iterators = new ArrayList<IteratorSetting>(_list221.size);
+ for (int _i222 = 0; _i222 < _list221.size; ++_i222)
{
- IteratorSetting _elem213;
- _elem213 = new IteratorSetting();
- _elem213.read(iprot);
- struct.iterators.add(_elem213);
+ IteratorSetting _elem223;
+ _elem223 = new IteratorSetting();
+ _elem223.read(iprot);
+ struct.iterators.add(_elem223);
}
}
struct.setIteratorsIsSet(true);
@@ -22114,6 +22218,11 @@ import org.slf4j.LoggerFactory;
struct.wait = iprot.readBool();
struct.setWaitIsSet(true);
}
+ if (incoming.get(7)) {
+ struct.compactionStrategy = new CompactionStrategyConfig();
+ struct.compactionStrategy.read(iprot);
+ struct.setCompactionStrategyIsSet(true);
+ }
}
}
@@ -30087,13 +30196,13 @@ import org.slf4j.LoggerFactory;
case 2: // TABLES
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set214 = iprot.readSetBegin();
- struct.tables = new HashSet<String>(2*_set214.size);
- for (int _i215 = 0; _i215 < _set214.size; ++_i215)
+ org.apache.thrift.protocol.TSet _set224 = iprot.readSetBegin();
+ struct.tables = new HashSet<String>(2*_set224.size);
+ for (int _i225 = 0; _i225 < _set224.size; ++_i225)
{
- String _elem216;
- _elem216 = iprot.readString();
- struct.tables.add(_elem216);
+ String _elem226;
+ _elem226 = iprot.readString();
+ struct.tables.add(_elem226);
}
iprot.readSetEnd();
}
@@ -30126,9 +30235,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TABLES_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, struct.tables.size()));
- for (String _iter217 : struct.tables)
+ for (String _iter227 : struct.tables)
{
- oprot.writeString(_iter217);
+ oprot.writeString(_iter227);
}
oprot.writeSetEnd();
}
@@ -30165,9 +30274,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTables()) {
{
oprot.writeI32(struct.tables.size());
- for (String _iter218 : struct.tables)
+ for (String _iter228 : struct.tables)
{
- oprot.writeString(_iter218);
+ oprot.writeString(_iter228);
}
}
}
@@ -30183,13 +30292,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TSet _set219 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tables = new HashSet<String>(2*_set219.size);
- for (int _i220 = 0; _i220 < _set219.size; ++_i220)
+ org.apache.thrift.protocol.TSet _set229 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tables = new HashSet<String>(2*_set229.size);
+ for (int _i230 = 0; _i230 < _set229.size; ++_i230)
{
- String _elem221;
- _elem221 = iprot.readString();
- struct.tables.add(_elem221);
+ String _elem231;
+ _elem231 = iprot.readString();
+ struct.tables.add(_elem231);
}
}
struct.setTablesIsSet(true);
@@ -30739,14 +30848,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list222 = iprot.readListBegin();
- struct.success = new ArrayList<DiskUsage>(_list222.size);
- for (int _i223 = 0; _i223 < _list222.size; ++_i223)
+ org.apache.thrift.protocol.TList _list232 = iprot.readListBegin();
+ struct.success = new ArrayList<DiskUsage>(_list232.size);
+ for (int _i233 = 0; _i233 < _list232.size; ++_i233)
{
- DiskUsage _elem224;
- _elem224 = new DiskUsage();
- _elem224.read(iprot);
- struct.success.add(_elem224);
+ DiskUsage _elem234;
+ _elem234 = new DiskUsage();
+ _elem234.read(iprot);
+ struct.success.add(_elem234);
}
iprot.readListEnd();
}
@@ -30801,9 +30910,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (DiskUsage _iter225 : struct.success)
+ for (DiskUsage _iter235 : struct.success)
{
- _iter225.write(oprot);
+ _iter235.write(oprot);
}
oprot.writeListEnd();
}
@@ -30858,9 +30967,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (DiskUsage _iter226 : struct.success)
+ for (DiskUsage _iter236 : struct.success)
{
- _iter226.write(oprot);
+ _iter236.write(oprot);
}
}
}
@@ -30881,14 +30990,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list227 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<DiskUsage>(_list227.size);
- for (int _i228 = 0; _i228 < _list227.size; ++_i228)
+ org.apache.thrift.protocol.TList _list237 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<DiskUsage>(_list237.size);
+ for (int _i238 = 0; _i238 < _list237.size; ++_i238)
{
- DiskUsage _elem229;
- _elem229 = new DiskUsage();
- _elem229.read(iprot);
- struct.success.add(_elem229);
+ DiskUsage _elem239;
+ _elem239 = new DiskUsage();
+ _elem239.read(iprot);
+ struct.success.add(_elem239);
}
}
struct.setSuccessIsSet(true);
@@ -31924,25 +32033,25 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map230 = iprot.readMapBegin();
- struct.success = new HashMap<String,Set<String>>(2*_map230.size);
- for (int _i231 = 0; _i231 < _map230.size; ++_i231)
+ org.apache.thrift.protocol.TMap _map240 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Set<String>>(2*_map240.size);
+ for (int _i241 = 0; _i241 < _map240.size; ++_i241)
{
- String _key232;
- Set<String> _val233;
- _key232 = iprot.readString();
+ String _key242;
+ Set<String> _val243;
+ _key242 = iprot.readString();
{
- org.apache.thrift.protocol.TSet _set234 = iprot.readSetBegin();
- _val233 = new HashSet<String>(2*_set234.size);
- for (int _i235 = 0; _i235 < _set234.size; ++_i235)
+ org.apache.thrift.protocol.TSet _set244 = iprot.readSetBegin();
+ _val243 = new HashSet<String>(2*_set244.size);
+ for (int _i245 = 0; _i245 < _set244.size; ++_i245)
{
- String _elem236;
- _elem236 = iprot.readString();
- _val233.add(_elem236);
+ String _elem246;
+ _elem246 = iprot.readString();
+ _val243.add(_elem246);
}
iprot.readSetEnd();
}
- struct.success.put(_key232, _val233);
+ struct.success.put(_key242, _val243);
}
iprot.readMapEnd();
}
@@ -31997,14 +32106,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>> _iter237 : struct.success.entrySet())
+ for (Map.Entry<String, Set<String>> _iter247 : struct.success.entrySet())
{
- oprot.writeString(_iter237.getKey());
+ oprot.writeString(_iter247.getKey());
{
- oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, _iter237.getValue().size()));
- for (String _iter238 : _iter237.getValue())
+ oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, _iter247.getValue().size()));
+ for (String _iter248 : _iter247.getValue())
{
- oprot.writeString(_iter238);
+ oprot.writeString(_iter248);
}
oprot.writeSetEnd();
}
@@ -32062,14 +32171,14 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Set<String>> _iter239 : struct.success.entrySet())
+ for (Map.Entry<String, Set<String>> _iter249 : struct.success.entrySet())
{
- oprot.writeString(_iter239.getKey());
+ oprot.writeString(_iter249.getKey());
{
- oprot.writeI32(_iter239.getValue().size());
- for (String _iter240 : _iter239.getValue())
+ oprot.writeI32(_iter249.getValue().size());
+ for (String _iter250 : _iter249.getValue())
{
- oprot.writeString(_iter240);
+ oprot.writeString(_iter250);
}
}
}
@@ -32092,24 +32201,24 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map241 = 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*_map241.size);
- for (int _i242 = 0; _i242 < _map241.size; ++_i242)
+ org.apache.thrift.protocol.TMap _map251 = 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*_map251.size);
+ for (int _i252 = 0; _i252 < _map251.size; ++_i252)
{
- String _key243;
- Set<String> _val244;
- _key243 = iprot.readString();
+ String _key253;
+ Set<String> _val254;
+ _key253 = iprot.readString();
{
- org.apache.thrift.protocol.TSet _set245 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- _val244 = new HashSet<String>(2*_set245.size);
- for (int _i246 = 0; _i246 < _set245.size; ++_i246)
+ org.apache.thrift.protocol.TSet _set255 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ _val254 = new HashSet<String>(2*_set255.size);
+ for (int _i256 = 0; _i256 < _set255.size; ++_i256)
{
- String _elem247;
- _elem247 = iprot.readString();
- _val244.add(_elem247);
+ String _elem257;
+ _elem257 = iprot.readString();
+ _val254.add(_elem257);
}
}
- struct.success.put(_key243, _val244);
+ struct.success.put(_key253, _val254);
}
}
struct.setSuccessIsSet(true);
@@ -34293,13 +34402,13 @@ import org.slf4j.LoggerFactory;
case 3: // AUTHS
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set248 = iprot.readSetBegin();
- struct.auths = new HashSet<ByteBuffer>(2*_set248.size);
- for (int _i249 = 0; _i249 < _set248.size; ++_i249)
+ org.apache.thrift.protocol.TSet _set258 = iprot.readSetBegin();
+ struct.auths = new HashSet<ByteBuffer>(2*_set258.size);
+ for (int _i259 = 0; _i259 < _set258.size; ++_i259)
{
- ByteBuffer _elem250;
- _elem250 = iprot.readBinary();
- struct.auths.add(_elem250);
+ ByteBuffer _elem260;
+ _elem260 = iprot.readBinary();
+ struct.auths.add(_elem260);
}
iprot.readSetEnd();
}
@@ -34369,9 +34478,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 _iter251 : struct.auths)
+ for (ByteBuffer _iter261 : struct.auths)
{
- oprot.writeBinary(_iter251);
+ oprot.writeBinary(_iter261);
}
oprot.writeSetEnd();
}
@@ -34442,9 +34551,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetAuths()) {
{
oprot.writeI32(struct.auths.size());
- for (ByteBuffer _iter252 : struct.auths)
+ for (ByteBuffer _iter262 : struct.auths)
{
- oprot.writeBinary(_iter252);
+ oprot.writeBinary(_iter262);
}
}
}
@@ -34476,13 +34585,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TSet _set253 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.auths = new HashSet<ByteBuffer>(2*_set253.size);
- for (int _i254 = 0; _i254 < _set253.size; ++_i254)
+ org.apache.thrift.protocol.TSet _set263 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.auths = new HashSet<ByteBuffer>(2*_set263.size);
+ for (int _i264 = 0; _i264 < _set263.size; ++_i264)
{
- ByteBuffer _elem255;
- _elem255 = iprot.readBinary();
- struct.auths.add(_elem255);
+ ByteBuffer _elem265;
+ _elem265 = iprot.readBinary();
+ struct.auths.add(_elem265);
}
}
struct.setAuthsIsSet(true);
@@ -36178,15 +36287,15 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map256 = iprot.readMapBegin();
- struct.success = new HashMap<String,String>(2*_map256.size);
- for (int _i257 = 0; _i257 < _map256.size; ++_i257)
+ org.apache.thrift.protocol.TMap _map266 = iprot.readMapBegin();
+ struct.success = new HashMap<String,String>(2*_map266.size);
+ for (int _i267 = 0; _i267 < _map266.size; ++_i267)
{
- String _key258;
- String _val259;
- _key258 = iprot.readString();
- _val259 = iprot.readString();
- struct.success.put(_key258, _val259);
+ String _key268;
+ String _val269;
+ _key268 = iprot.readString();
+ _val269 = iprot.readString();
+ struct.success.put(_key268, _val269);
}
iprot.readMapEnd();
}
@@ -36241,10 +36350,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> _iter260 : struct.success.entrySet())
+ for (Map.Entry<String, String> _iter270 : struct.success.entrySet())
{
- oprot.writeString(_iter260.getKey());
- oprot.writeString(_iter260.getValue());
+ oprot.writeString(_iter270.getKey());
+ oprot.writeString(_iter270.getValue());
}
oprot.writeMapEnd();
}
@@ -36299,10 +36408,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, String> _iter261 : struct.success.entrySet())
+ for (Map.Entry<String, String> _iter271 : struct.success.entrySet())
{
- oprot.writeString(_iter261.getKey());
- oprot.writeString(_iter261.getValue());
+ oprot.writeString(_iter271.getKey());
+ oprot.writeString(_iter271.getValue());
}
}
}
@@ -36323,15 +36432,15 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map262 = 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*_map262.size);
- for (int _i263 = 0; _i263 < _map262.size; ++_i263)
+ org.apache.thrift.protocol.TMap _map272 = 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*_map272.size);
+ for (int _i273 = 0; _i273 < _map272.size; ++_i273)
{
- String _key264;
- String _val265;
- _key264 = iprot.readString();
- _val265 = iprot.readString();
- struct.success.put(_key264, _val265);
+ String _key274;
+ String _val275;
+ _key274 = iprot.readString();
+ _val275 = iprot.readString();
+ struct.success.put(_key274, _val275);
}
}
struct.setSuccessIsSet(true);
@@ -39904,13 +40013,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list266 = iprot.readListBegin();
- struct.success = new ArrayList<ByteBuffer>(_list266.size);
- for (int _i267 = 0; _i267 < _list266.size; ++_i267)
+ org.apache.thrift.protocol.TList _list276 = iprot.readListBegin();
+ struct.success = new ArrayList<ByteBuffer>(_list276.size);
+ for (int _i277 = 0; _i277 < _list276.size; ++_i277)
{
- ByteBuffer _elem268;
- _elem268 = iprot.readBinary();
- struct.success.add(_elem268);
+ ByteBuffer _elem278;
+ _elem278 = iprot.readBinary();
+ struct.success.add(_elem278);
}
iprot.readListEnd();
}
@@ -39965,9 +40074,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 _iter269 : struct.success)
+ for (ByteBuffer _iter279 : struct.success)
{
- oprot.writeBinary(_iter269);
+ oprot.writeBinary(_iter279);
}
oprot.writeListEnd();
}
@@ -40022,9 +40131,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (ByteBuffer _iter270 : struct.success)
+ for (ByteBuffer _iter280 : struct.success)
{
- oprot.writeBinary(_iter270);
+ oprot.writeBinary(_iter280);
}
}
}
@@ -40045,13 +40154,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list271 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<ByteBuffer>(_list271.size);
- for (int _i272 = 0; _i272 < _list271.size; ++_i272)
+ org.apache.thrift.protocol.TList _list281 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<ByteBuffer>(_list281.size);
+ for (int _i282 = 0; _i282 < _list281.size; ++_i282)
{
- ByteBuffer _elem273;
- _elem273 = iprot.readBinary();
- struct.success.add(_elem273);
+ ByteBuffer _elem283;
+ _elem283 = iprot.readBinary();
+ struct.success.add(_elem283);
}
}
struct.setSuccessIsSet(true);
@@ -40747,13 +40856,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set274 = iprot.readSetBegin();
- struct.success = new HashSet<String>(2*_set274.size);
- for (int _i275 = 0; _i275 < _set274.size; ++_i275)
+ org.apache.thrift.protocol.TSet _set284 = iprot.readSetBegin();
+ struct.success = new HashSet<String>(2*_set284.size);
+ for (int _i285 = 0; _i285 < _set284.size; ++_i285)
{
- String _elem276;
- _elem276 = iprot.readString();
- struct.success.add(_elem276);
+ String _elem286;
+ _elem286 = iprot.readString();
+ struct.success.add(_elem286);
}
iprot.readSetEnd();
}
@@ -40781,9 +40890,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 _iter277 : struct.success)
+ for (String _iter287 : struct.success)
{
- oprot.writeString(_iter277);
+ oprot.writeString(_iter287);
}
oprot.writeSetEnd();
}
@@ -40814,9 +40923,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter278 : struct.success)
+ for (String _iter288 : struct.success)
{
- oprot.writeString(_iter278);
+ oprot.writeString(_iter288);
}
}
}
@@ -40828,13 +40937,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TSet _set279 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new HashSet<String>(2*_set279.size);
- for (int _i280 = 0; _i280 < _set279.size; ++_i280)
+ org.apache.thrift.protocol.TSet _set289 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new HashSet<String>(2*_set289.size);
+ for (int _i290 = 0; _i290 < _set289.size; ++_i290)
{
- String _elem281;
- _elem281 = iprot.readString();
- struct.success.add(_elem281);
+ String _elem291;
+ _elem291 = iprot.readString();
+ struct.success.add(_elem291);
}
}
struct.setSuccessIsSet(true);
@@ -41858,25 +41967,25 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map282 = iprot.readMapBegin();
- struct.success = new HashMap<String,Set<IteratorScope>>(2*_map282.size);
- for (int _i283 = 0; _i283 < _map282.size; ++_i283)
+ org.apache.thrift.protocol.TMap _map292 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Set<IteratorScope>>(2*_map292.size);
+ for (int _i293 = 0; _i293 < _map292.size; ++_i293)
{
- String _key284;
- Set<IteratorScope> _val285;
- _key284 = iprot.readString();
+ String _key294;
+ Set<IteratorScope> _val295;
+ _key294 = iprot.readString();
{
- org.apache.thrift.protocol.TSet _set286 = iprot.readSetBegin();
- _val285 = new HashSet<IteratorScope>(2*_set286.size);
- for (int _i287 = 0; _i287 < _set286.size; ++_i287)
+ org.apache.thrift.protocol.TSet _set296 = iprot.readSetBegin();
+ _val295 = new HashSet<IteratorScope>(2*_set296.size);
+ for (int _i297 = 0; _i297 < _set296.size; ++_i297)
{
- IteratorScope _elem288;
- _elem288 = IteratorScope.findByValue(iprot.readI32());
- _val285.add(_elem288);
+ IteratorScope _elem298;
+ _elem298 = IteratorScope.findByValue(iprot.readI32());
+ _val295.add(_elem298);
}
iprot.readSetEnd();
}
- struct.success.put(_key284, _val285);
+ struct.success.put(_key294, _val295);
}
iprot.readMapEnd();
}
@@ -41931,14 +42040,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>> _iter289 : struct.success.entrySet())
+ for (Map.Entry<String, Set<IteratorScope>> _iter299 : struct.success.entrySet())
{
- oprot.writeString(_iter289.getKey());
+ oprot.writeString(_iter299.getKey());
{
- oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, _iter289.getValue().size()));
- for (IteratorScope _iter290 : _iter289.getValue())
+ oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, _iter299.getValue().size()));
+ for (IteratorScope _iter300 : _iter299.getValue())
{
- oprot.writeI32(_iter290.getValue());
+ oprot.writeI32(_iter300.getValue());
}
oprot.writeSetEnd();
}
@@ -41996,14 +42105,14 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Set<IteratorScope>> _iter291 : struct.success.entrySet())
+ for (Map.Entry<String, Set<IteratorScope>> _iter301 : struct.success.entrySet())
{
- oprot.writeString(_iter291.getKey());
+ oprot.writeString(_iter301.getKey());
{
- oprot.writeI32(_iter291.getValue().size());
- for (IteratorScope _iter292 : _iter291.getValue())
+ oprot.writeI32(_iter301.getValue().size());
+ for (IteratorScope _iter302 : _iter301.getValue())
{
- oprot.writeI32(_iter292.getValue());
+ oprot.writeI32(_iter302.getValue());
}
}
}
@@ -42026,24 +42135,24 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map293 = 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*_map293.size);
- for (int _i294 = 0; _i294 < _map293.size; ++_i294)
+ org.apache.thrift.protocol.TMap _map303 = 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*_map303.size);
+ for (int _i304 = 0; _i304 < _map303.size; ++_i304)
{
- String _key295;
- Set<IteratorScope> _val296;
- _key295 = iprot.readString();
+ String _key305;
+ Set<IteratorScope> _val306;
+ _key305 = iprot.readString();
{
- org.apache.thrift.protocol.TSet _set297 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32());
- _val296 = new HashSet<IteratorScope>(2*_set297.size);
- for (int _i298 = 0; _i298 < _set297.size; ++_i298)
+ org.apache.thrift.protocol.TSet _set307 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ _val306 = new HashSet<IteratorScope>(2*_set307.size);
+ for (int _i308 = 0; _i308 < _set307.size; ++_i308)
{
- IteratorScope _elem299;
- _elem299 = IteratorScope.findByValue(iprot.readI32());
- _val296.add(_elem299);
+ IteratorScope _elem309;
+ _elem309 = IteratorScope.findByValue(iprot.readI32());
+ _val306.add(_elem309);
}
}
- struct.success.put(_key295, _val296);
+ struct.success.put(_key305, _val306);
}
}
struct.setSuccessIsSet(true);
@@ -43067,15 +43176,15 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map300 = iprot.readMapBegin();
- struct.success = new HashMap<String,Integer>(2*_map300.size);
- for (int _i301 = 0; _i301 < _map300.size; ++_i301)
+ org.apache.thrift.protocol.TMap _map310 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Integer>(2*_map310.size);
+ for (int _i311 = 0; _i311 < _map310.size; ++_i311)
{
- String _key302;
- int _val303;
- _key302 = iprot.readString();
- _val303 = iprot.readI32();
- struct.success.put(_key302, _val303);
+ String _key312;
+ int _val313;
+ _key312 = iprot.readString();
+ _val313 = iprot.readI32();
+ struct.success.put(_key312, _val313);
}
iprot.readMapEnd();
}
@@ -43130,10 +43239,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> _iter304 : struct.success.entrySet())
+ for (Map.Entry<String, Integer> _iter314 : struct.success.entrySet())
{
- oprot.writeString(_iter304.getKey());
- oprot.writeI32(_iter304.getValue());
+ oprot.writeString(_iter314.getKey());
+ oprot.writeI32(_iter314.getValue());
}
oprot.writeMapEnd();
}
@@ -43188,10 +43297,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Integer> _iter305 : struct.success.entrySet())
+ for (Map.Entry<String, Integer> _iter315 : struct.success.entrySet())
{
- oprot.writeString(_iter305.getKey());
- oprot.writeI32(_iter305.getValue());
+ oprot.writeString(_iter315.getKey());
+ oprot.writeI32(_iter315.getValue());
}
}
}
@@ -43212,15 +43321,15 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map306 = 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*_map306.size);
- for (int _i307 = 0; _i307 < _map306.size; ++_i307)
+ org.apache.thrift.protocol.TMap _map316 = 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*_map316.size);
+ for (int _i317 = 0; _i317 < _map316.size; ++_i317)
{
- String _key308;
- int _val309;
- _key308 = iprot.readString();
- _val309 = iprot.readI32();
- struct.success.put(_key308, _val309);
+ String _key318;
+ int _val319;
+ _key318 = iprot.readString();
+ _val319 = iprot.readI32();
+ struct.success.put(_key318, _val319);
}
}
struct.setSuccessIsSet(true);
@@ -48440,13 +48549,13 @@ import org.slf4j.LoggerFactory;
case 4: // SCOPES
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set310 = iprot.readSetBegin();
- struct.scopes = new HashSet<IteratorScope>(2*_set310.size);
- for (int _i311 = 0; _i311 < _set310.size; ++_i311)
+ org.apache.thrift.protocol.TSet _set320 = iprot.readSetBegin();
+ struct.scopes = new HashSet<IteratorScope>(2*_set320.size);
+ for (int _i321 = 0; _i321 < _set320.size; ++_i321)
{
- IteratorScope _elem312;
- _elem312 = IteratorScope.findByValue(iprot.readI32());
- struct.scopes.add(_elem312);
+ IteratorScope _elem322;
+ _elem322 = IteratorScope.findByValue(iprot.readI32());
+ struct.scopes.add(_elem322);
}
iprot.readSetEnd();
}
@@ -48489,9 +48598,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 _iter313 : struct.scopes)
+ for (IteratorScope _iter323 : struct.scopes)
{
- oprot.writeI32(_iter313.getValue());
+ oprot.writeI32(_iter323.getValue());
}
oprot.writeSetEnd();
}
@@ -48540,9 +48649,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetScopes()) {
{
oprot.writeI32(struct.scopes.size());
- for (IteratorScope _iter314 : struct.scopes)
+ for (IteratorScope _iter324 : struct.scopes)
{
- oprot.writeI32(_iter314.getValue());
+ oprot.writeI32(_iter324.getValue());
}
}
}
@@ -48566,13 +48675,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TSet _set315 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.scopes = new HashSet<IteratorScope>(2*_set315.size);
- for (int _i316 = 0; _i316 < _set315.size; ++_i316)
+ org.apache.thrift.protocol.TSet _set325 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.scopes = new HashSet<IteratorScope>(2*_set325.size);
+ for (int _i326 = 0; _i326 < _set325.size; ++_i326)
{
- IteratorScope _elem317;
- _elem317 = IteratorScope.findByValue(iprot.readI32());
- struct.scopes.add(_elem317);
+ IteratorScope _elem327;
+ _elem327 = IteratorScope.findByValue(iprot.readI32());
+ struct.scopes.add(_elem327);
}
}
struct.setScopesIsSet(true);
@@ -51990,25 +52099,25 @@ import org.slf4j.LoggerFactory;
case 3: // GROUPS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map318 = iprot.readMapBegin();
- struct.groups = new HashMap<String,Set<String>>(2*_map318.size);
- for (int _i319 = 0; _i319 < _map318.size; ++_i319)
+ org.apache.thrift.protocol.TMap _map328 = iprot.readMapBegin();
+ struct.groups = new HashMap<String,Set<String>>(2*_map328.size);
+ for (int _i329 = 0; _i329 < _map328.size; ++_i329)
{
- String _key320;
- Set<String> _val321;
- _key320 = iprot.readString();
+ String _key330;
+ Set<String> _val331;
+ _key330 = iprot.readString();
{
- org.apache.thrift.protocol.TSet _set322 = iprot.readSetBegin();
- _val321 = new HashSet<String>(2*_set322.size);
- for (int _i323 = 0; _i323 < _set322.size; ++_i323)
+ org.apache.thrift.protocol.TSet _set332 = iprot.readSetBegin();
+ _val331 = new HashSet<String>(2*_set332.size);
+ for (int _i333 = 0; _i333 < _set332.size; ++_i333)
{
- String _elem324;
- _elem324 = iprot.readString();
- _val321.add(_elem324);
+ String _elem334;
+ _elem334 = iprot.readString();
+ _val331.add(_elem334);
}
iprot.readSetEnd();
}
- struct.groups.put(_key320, _val321);
+ struct.groups.put(_key330, _val331);
}
iprot.readMapEnd();
}
@@ -52046,14 +52155,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>> _iter325 : struct.groups.entrySet())
+ for (Map.Entry<String, Set<String>> _iter335 : struct.groups.entrySet())
{
- oprot.writeString(_iter325.getKey());
+ oprot.writeString(_iter335.getKey());
{
- oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, _iter325.getValue().size()));
- for (String _iter326 : _iter325.getValue())
+ oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, _iter335.getValue().size()));
+ for (String _iter336 : _iter335.getValue())
{
- oprot.writeString(_iter326);
+ oprot.writeString(_iter336);
}
oprot.writeSetEnd();
}
@@ -52099,14 +52208,14 @@ import org.slf4j.LoggerFactory;
if (struct.isSetGroups()) {
{
oprot.writeI32(struct.groups.size());
- for (Map.Entry<String, Set<String>> _iter327 : struct.groups.entrySet())
+ for (Map.Entry<String, Set<String>> _iter337 : struct.groups.entrySet())
{
- oprot.writeString(_iter327.getKey());
+ oprot.writeString(_iter337.getKey());
{
- oprot.writeI32(_iter327.getValue().size());
- for (String _iter328 : _iter327.getValue())
+ oprot.writeI32(_iter337.getValue().size());
+ for (String _iter338 : _iter337.getValue())
{
- oprot.writeString(_iter328);
+ oprot.writeString(_iter338);
}
}
}
@@ -52128,24 +52237,24 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TMap _map329 = 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*_map329.size);
- for (int _i330 = 0; _i330 < _map329.size; ++_i330)
+ org.apache.thrift.protocol.TMap _map339 = 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*_map339.size);
+ for (int _i340 = 0; _i340 < _map339.size; ++_i340)
{
- String _key331;
- Set<String> _val332;
- _key331 = iprot.readString();
+ String _key341;
+ Set<String> _val342;
+ _key341 = iprot.readString();
{
- org.apache.thrift.protocol.TSet _set333 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- _val332 = new HashSet<String>(2*_set333.size);
- for (int _i334 = 0; _i334 < _set333.size; ++_i334)
+ org.apache.thrift.protocol.TSet _set343 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ _val342 = new HashSet<String>(2*_set343.size);
+ for (int _i344 = 0; _i344 < _set343.size; ++_i344)
{
- String _elem335;
- _elem335 = iprot.readString();
- _val332.add(_elem335);
+ String _elem345;
+ _elem345 = iprot.readString();
+ _val342.add(_elem345);
}
}
- struct.groups.put(_key331, _val332);
+ struct.groups.put(_key341, _val342);
}
}
struct.setGroupsIsSet(true);
@@ -55148,14 +55257,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set336 = iprot.readSetBegin();
- struct.success = new HashSet<Range>(2*_set336.size);
- for (int _i337 = 0; _i337 < _set336.size; ++_i337)
+ org.apache.thrift.protocol.TSet _set346 = iprot.readSetBegin();
+ struct.success = new HashSet<Range>(2*_set346.size);
+ for (int _i347 = 0; _i347 < _set346.size; ++_i347)
{
- Range _elem338;
- _elem338 = new Range();
- _elem338.read(iprot);
- struct.success.add(_elem338);
+ Range _elem348;
+ _elem348 = new Range();
+ _elem348.read(iprot);
+ struct.success.add(_elem348);
}
iprot.readSetEnd();
}
@@ -55210,9 +55319,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 _iter339 : struct.success)
+ for (Range _iter349 : struct.success)
{
- _iter339.write(oprot);
+ _iter349.write(oprot);
}
oprot.writeSetEnd();
}
@@ -55267,9 +55376,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSucces
<TRUNCATED>