http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/94d579dd/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Response.java ---------------------------------------------------------------------- diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Response.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Response.java new file mode 100644 index 0000000..bbe28de --- /dev/null +++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Response.java @@ -0,0 +1,418 @@ +/** + * Autogenerated by Thrift Compiler (0.9.0) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.blur.thrift.generated; + +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + + + +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.IScheme; +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.SchemeFactory; +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.StandardScheme; + +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.TupleScheme; +import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TTupleProtocol; +import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolException; +import org.apache.blur.thirdparty.thrift_0_9_0.EncodingUtils; +import org.apache.blur.thirdparty.thrift_0_9_0.TException; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +//import org.slf4j.Logger; +//import org.slf4j.LoggerFactory; + +public class Response extends org.apache.blur.thirdparty.thrift_0_9_0.TUnion<Response, Response._Fields> { + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("Response"); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SHARD_TO_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("shardToValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, (short)1); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("value", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)2); + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum { + SHARD_TO_VALUE((short)1, "shardToValue"), + VALUE((short)2, "value"); + + 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: // SHARD_TO_VALUE + return SHARD_TO_VALUE; + case 2: // VALUE + return VALUE; + 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; + } + } + + public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.SHARD_TO_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("shardToValue", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.MapMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING), + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, Value.class)))); + tmpMap.put(_Fields.VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("value", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, Value.class))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(Response.class, metaDataMap); + } + + public Response() { + super(); + } + + public Response(_Fields setField, Object value) { + super(setField, value); + } + + public Response(Response other) { + super(other); + } + public Response deepCopy() { + return new Response(this); + } + + public static Response shardToValue(Map<String,Value> value) { + Response x = new Response(); + x.setShardToValue(value); + return x; + } + + public static Response value(Value value) { + Response x = new Response(); + x.setValue(value); + return x; + } + + + @Override + protected void checkType(_Fields setField, Object value) throws ClassCastException { + switch (setField) { + case SHARD_TO_VALUE: + if (value instanceof Map) { + break; + } + throw new ClassCastException("Was expecting value of type Map<String,Value> for field 'shardToValue', but got " + value.getClass().getSimpleName()); + case VALUE: + if (value instanceof Value) { + break; + } + throw new ClassCastException("Was expecting value of type Value for field 'value', but got " + value.getClass().getSimpleName()); + default: + throw new IllegalArgumentException("Unknown field id " + setField); + } + } + + @Override + protected Object standardSchemeReadValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField field) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + _Fields setField = _Fields.findByThriftId(field.id); + if (setField != null) { + switch (setField) { + case SHARD_TO_VALUE: + if (field.type == SHARD_TO_VALUE_FIELD_DESC.type) { + Map<String,Value> shardToValue; + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map232 = iprot.readMapBegin(); + shardToValue = new HashMap<String,Value>(2*_map232.size); + for (int _i233 = 0; _i233 < _map232.size; ++_i233) + { + String _key234; // optional + Value _val235; // required + _key234 = iprot.readString(); + _val235 = new Value(); + _val235.read(iprot); + shardToValue.put(_key234, _val235); + } + iprot.readMapEnd(); + } + return shardToValue; + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + case VALUE: + if (field.type == VALUE_FIELD_DESC.type) { + Value value; + value = new Value(); + value.read(iprot); + return value; + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + default: + throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!"); + } + } else { + return null; + } + } + + @Override + protected void standardSchemeWriteValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + switch (setField_) { + case SHARD_TO_VALUE: + Map<String,Value> shardToValue = (Map<String,Value>)value_; + { + oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, shardToValue.size())); + for (Map.Entry<String, Value> _iter236 : shardToValue.entrySet()) + { + oprot.writeString(_iter236.getKey()); + _iter236.getValue().write(oprot); + } + oprot.writeMapEnd(); + } + return; + case VALUE: + Value value = (Value)value_; + value.write(oprot); + return; + default: + throw new IllegalStateException("Cannot write union with unknown field " + setField_); + } + } + + @Override + protected Object tupleSchemeReadValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, short fieldID) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + _Fields setField = _Fields.findByThriftId(fieldID); + if (setField != null) { + switch (setField) { + case SHARD_TO_VALUE: + Map<String,Value> shardToValue; + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map237 = iprot.readMapBegin(); + shardToValue = new HashMap<String,Value>(2*_map237.size); + for (int _i238 = 0; _i238 < _map237.size; ++_i238) + { + String _key239; // optional + Value _val240; // required + _key239 = iprot.readString(); + _val240 = new Value(); + _val240.read(iprot); + shardToValue.put(_key239, _val240); + } + iprot.readMapEnd(); + } + return shardToValue; + case VALUE: + Value value; + value = new Value(); + value.read(iprot); + return value; + default: + throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!"); + } + } else { + throw new TProtocolException("Couldn't find a field with field id " + fieldID); + } + } + + @Override + protected void tupleSchemeWriteValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + switch (setField_) { + case SHARD_TO_VALUE: + Map<String,Value> shardToValue = (Map<String,Value>)value_; + { + oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, shardToValue.size())); + for (Map.Entry<String, Value> _iter241 : shardToValue.entrySet()) + { + oprot.writeString(_iter241.getKey()); + _iter241.getValue().write(oprot); + } + oprot.writeMapEnd(); + } + return; + case VALUE: + Value value = (Value)value_; + value.write(oprot); + return; + default: + throw new IllegalStateException("Cannot write union with unknown field " + setField_); + } + } + + @Override + protected org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField getFieldDesc(_Fields setField) { + switch (setField) { + case SHARD_TO_VALUE: + return SHARD_TO_VALUE_FIELD_DESC; + case VALUE: + return VALUE_FIELD_DESC; + default: + throw new IllegalArgumentException("Unknown field id " + setField); + } + } + + @Override + protected org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct getStructDesc() { + return STRUCT_DESC; + } + + @Override + protected _Fields enumForId(short id) { + return _Fields.findByThriftIdOrThrow(id); + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + + public Map<String,Value> getShardToValue() { + if (getSetField() == _Fields.SHARD_TO_VALUE) { + return (Map<String,Value>)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'shardToValue' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setShardToValue(Map<String,Value> value) { + if (value == null) throw new NullPointerException(); + setField_ = _Fields.SHARD_TO_VALUE; + value_ = value; + } + + public Value getValue() { + if (getSetField() == _Fields.VALUE) { + return (Value)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'value' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setValue(Value value) { + if (value == null) throw new NullPointerException(); + setField_ = _Fields.VALUE; + value_ = value; + } + + public boolean isSetShardToValue() { + return setField_ == _Fields.SHARD_TO_VALUE; + } + + + public boolean isSetValue() { + return setField_ == _Fields.VALUE; + } + + + public boolean equals(Object other) { + if (other instanceof Response) { + return equals((Response)other); + } else { + return false; + } + } + + public boolean equals(Response other) { + return other != null && getSetField() == other.getSetField() && getFieldValue().equals(other.getFieldValue()); + } + + @Override + public int compareTo(Response other) { + int lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(getSetField(), other.getSetField()); + if (lastComparison == 0) { + return org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(getFieldValue(), other.getFieldValue()); + } + return lastComparison; + } + + + /** + * If you'd like this to perform more respectably, use the hashcode generator option. + */ + @Override + public int hashCode() { + return 0; + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(out))); + } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) { + throw new java.io.IOException(te); + } + } + + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(in))); + } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) { + throw new java.io.IOException(te); + } + } + + +}
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/94d579dd/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java ---------------------------------------------------------------------- diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java index 7a7249a..5f2bbb4 100644 --- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java +++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java @@ -28,12 +28,13 @@ package org.apache.blur.thrift.generated; import org.apache.blur.thirdparty.thrift_0_9_0.scheme.IScheme; import org.apache.blur.thirdparty.thrift_0_9_0.scheme.SchemeFactory; import org.apache.blur.thirdparty.thrift_0_9_0.scheme.StandardScheme; - import org.apache.blur.thirdparty.thrift_0_9_0.scheme.TupleScheme; +import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol; import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TTupleProtocol; import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolException; import org.apache.blur.thirdparty.thrift_0_9_0.EncodingUtils; import org.apache.blur.thirdparty.thrift_0_9_0.TException; + import java.util.List; import java.util.ArrayList; import java.util.Map; @@ -51,924 +52,12 @@ import java.util.Arrays; public class SafeClientGen extends org.apache.blur.thrift.generated.Blur.Client { -private final org.apache.blur.thrift.ClientLock _lock = new org.apache.blur.thrift.ClientLock("client"); - -public SafeClientGen(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) { -super(iprot, oprot); -} - -public SafeClientGen(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot) { -super(prot); -} - -@Override -public boolean addColumnDefinition(java.lang.String arg0, org.apache.blur.thrift.generated.ColumnDefinition arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.addColumnDefinition(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void cancelQuery(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.cancelQuery(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public java.util.Map configuration() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.configuration(); - } finally {_lock.unlock();} -} - -@Override -public java.util.List controllerServerList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.controllerServerList(); - } finally {_lock.unlock();} -} - -@Override -public void createSnapshot(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.createSnapshot(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void createTable(org.apache.blur.thrift.generated.TableDescriptor arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.createTable(arg0); - } finally {_lock.unlock();} -} - -@Override -public org.apache.blur.thrift.generated.TableDescriptor describe(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.describe(arg0); - } finally {_lock.unlock();} -} - -@Override -public void disableTable(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.disableTable(arg0); - } finally {_lock.unlock();} -} - -@Override -public void enableTable(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.enableTable(arg0); - } finally {_lock.unlock();} -} - -@Override -public void enqueueMutate(org.apache.blur.thrift.generated.RowMutation arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.enqueueMutate(arg0); - } finally {_lock.unlock();} -} - -@Override -public void enqueueMutateBatch(java.util.List arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.enqueueMutateBatch(arg0); - } finally {_lock.unlock();} -} - -@Override -public org.apache.blur.thrift.generated.FetchResult fetchRow(java.lang.String arg0, org.apache.blur.thrift.generated.Selector arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.fetchRow(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public java.util.List fetchRowBatch(java.lang.String arg0, java.util.List arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.fetchRowBatch(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public boolean isInSafeMode(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.isInSafeMode(arg0); - } finally {_lock.unlock();} -} + public SafeClientGen(TProtocol iprot, TProtocol oprot) { + super(iprot, oprot); + } -@Override -public java.util.Map listSnapshots(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.listSnapshots(arg0); - } finally {_lock.unlock();} -} - -@Override -public void logging(java.lang.String arg0, org.apache.blur.thrift.generated.Level arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.logging(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public java.util.Map metrics(java.util.Set arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.metrics(arg0); - } finally {_lock.unlock();} -} - -@Override -public void mutate(org.apache.blur.thrift.generated.RowMutation arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.mutate(arg0); - } finally {_lock.unlock();} -} - -@Override -public void mutateBatch(java.util.List arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.mutateBatch(arg0); - } finally {_lock.unlock();} -} - -@Override -public void optimize(java.lang.String arg0, int arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.optimize(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public java.lang.String parseQuery(java.lang.String arg0, org.apache.blur.thrift.generated.Query arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.parseQuery(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void ping() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.ping(); - } finally {_lock.unlock();} -} - -@Override -public org.apache.blur.thrift.generated.BlurResults query(java.lang.String arg0, org.apache.blur.thrift.generated.BlurQuery arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.query(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public org.apache.blur.thrift.generated.BlurQueryStatus queryStatusById(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.queryStatusById(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public java.util.List queryStatusIdList(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.queryStatusIdList(arg0); - } finally {_lock.unlock();} -} - -@Override -public long recordFrequency(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recordFrequency(arg0, arg1, arg2, arg3); - } finally {_lock.unlock();} -} - -@Override -public boolean recv_addColumnDefinition() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_addColumnDefinition(); - } finally {_lock.unlock();} -} - -@Override -public void recv_cancelQuery() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.recv_cancelQuery(); - } finally {_lock.unlock();} -} - -@Override -public java.util.Map recv_configuration() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_configuration(); - } finally {_lock.unlock();} -} - -@Override -public java.util.List recv_controllerServerList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_controllerServerList(); - } finally {_lock.unlock();} -} - -@Override -public void recv_createSnapshot() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.recv_createSnapshot(); - } finally {_lock.unlock();} -} - -@Override -public void recv_createTable() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.recv_createTable(); - } finally {_lock.unlock();} -} - -@Override -public org.apache.blur.thrift.generated.TableDescriptor recv_describe() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_describe(); - } finally {_lock.unlock();} -} - -@Override -public void recv_disableTable() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.recv_disableTable(); - } finally {_lock.unlock();} -} - -@Override -public void recv_enableTable() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.recv_enableTable(); - } finally {_lock.unlock();} -} - -@Override -public void recv_enqueueMutate() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.recv_enqueueMutate(); - } finally {_lock.unlock();} -} - -@Override -public void recv_enqueueMutateBatch() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.recv_enqueueMutateBatch(); - } finally {_lock.unlock();} -} - -@Override -public org.apache.blur.thrift.generated.FetchResult recv_fetchRow() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_fetchRow(); - } finally {_lock.unlock();} -} - -@Override -public java.util.List recv_fetchRowBatch() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_fetchRowBatch(); - } finally {_lock.unlock();} -} - -@Override -public boolean recv_isInSafeMode() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_isInSafeMode(); - } finally {_lock.unlock();} -} - -@Override -public java.util.Map recv_listSnapshots() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_listSnapshots(); - } finally {_lock.unlock();} -} - -@Override -public void recv_logging() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.recv_logging(); - } finally {_lock.unlock();} -} - -@Override -public java.util.Map recv_metrics() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_metrics(); - } finally {_lock.unlock();} -} - -@Override -public void recv_mutate() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.recv_mutate(); - } finally {_lock.unlock();} -} - -@Override -public void recv_mutateBatch() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.recv_mutateBatch(); - } finally {_lock.unlock();} -} - -@Override -public void recv_optimize() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.recv_optimize(); - } finally {_lock.unlock();} -} - -@Override -public java.lang.String recv_parseQuery() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_parseQuery(); - } finally {_lock.unlock();} -} - -@Override -public void recv_ping() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.recv_ping(); - } finally {_lock.unlock();} -} - -@Override -public org.apache.blur.thrift.generated.BlurResults recv_query() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_query(); - } finally {_lock.unlock();} -} - -@Override -public org.apache.blur.thrift.generated.BlurQueryStatus recv_queryStatusById() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_queryStatusById(); - } finally {_lock.unlock();} -} - -@Override -public java.util.List recv_queryStatusIdList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_queryStatusIdList(); - } finally {_lock.unlock();} -} - -@Override -public long recv_recordFrequency() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_recordFrequency(); - } finally {_lock.unlock();} -} - -@Override -public void recv_removeSnapshot() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.recv_removeSnapshot(); - } finally {_lock.unlock();} -} - -@Override -public void recv_removeTable() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.recv_removeTable(); - } finally {_lock.unlock();} -} - -@Override -public void recv_resetLogging() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.recv_resetLogging(); - } finally {_lock.unlock();} -} - -@Override -public org.apache.blur.thrift.generated.Schema recv_schema() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_schema(); - } finally {_lock.unlock();} -} - -@Override -public java.util.List recv_shardClusterList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_shardClusterList(); - } finally {_lock.unlock();} -} - -@Override -public java.util.Map recv_shardServerLayout() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_shardServerLayout(); - } finally {_lock.unlock();} -} - -@Override -public java.util.Map recv_shardServerLayoutState() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_shardServerLayoutState(); - } finally {_lock.unlock();} -} - -@Override -public java.util.List recv_shardServerList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_shardServerList(); - } finally {_lock.unlock();} -} - -@Override -public java.util.List recv_tableList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_tableList(); - } finally {_lock.unlock();} -} - -@Override -public java.util.List recv_tableListByCluster() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_tableListByCluster(); - } finally {_lock.unlock();} -} - -@Override -public org.apache.blur.thrift.generated.TableStats recv_tableStats() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_tableStats(); - } finally {_lock.unlock();} -} - -@Override -public java.util.List recv_terms() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_terms(); - } finally {_lock.unlock();} -} - -@Override -public java.util.List recv_traceList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_traceList(); - } finally {_lock.unlock();} -} - -@Override -public void recv_traceRemove() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.recv_traceRemove(); - } finally {_lock.unlock();} -} - -@Override -public java.lang.String recv_traceRequestFetch() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_traceRequestFetch(); - } finally {_lock.unlock();} -} - -@Override -public java.util.List recv_traceRequestList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.recv_traceRequestList(); - } finally {_lock.unlock();} -} - -@Override -public void removeSnapshot(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.removeSnapshot(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void removeTable(java.lang.String arg0, boolean arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.removeTable(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void resetLogging() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.resetLogging(); - } finally {_lock.unlock();} -} - -@Override -public org.apache.blur.thrift.generated.Schema schema(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.schema(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_addColumnDefinition(java.lang.String arg0, org.apache.blur.thrift.generated.ColumnDefinition arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_addColumnDefinition(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void send_cancelQuery(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_cancelQuery(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void send_configuration() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_configuration(); - } finally {_lock.unlock();} -} - -@Override -public void send_controllerServerList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_controllerServerList(); - } finally {_lock.unlock();} -} - -@Override -public void send_createSnapshot(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_createSnapshot(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void send_createTable(org.apache.blur.thrift.generated.TableDescriptor arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_createTable(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_describe(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_describe(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_disableTable(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_disableTable(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_enableTable(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_enableTable(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_enqueueMutate(org.apache.blur.thrift.generated.RowMutation arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_enqueueMutate(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_enqueueMutateBatch(java.util.List arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_enqueueMutateBatch(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_fetchRow(java.lang.String arg0, org.apache.blur.thrift.generated.Selector arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_fetchRow(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void send_fetchRowBatch(java.lang.String arg0, java.util.List arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_fetchRowBatch(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void send_isInSafeMode(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_isInSafeMode(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_listSnapshots(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_listSnapshots(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_logging(java.lang.String arg0, org.apache.blur.thrift.generated.Level arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_logging(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void send_metrics(java.util.Set arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_metrics(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_mutate(org.apache.blur.thrift.generated.RowMutation arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_mutate(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_mutateBatch(java.util.List arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_mutateBatch(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_optimize(java.lang.String arg0, int arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_optimize(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void send_parseQuery(java.lang.String arg0, org.apache.blur.thrift.generated.Query arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_parseQuery(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void send_ping() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_ping(); - } finally {_lock.unlock();} -} - -@Override -public void send_query(java.lang.String arg0, org.apache.blur.thrift.generated.BlurQuery arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_query(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void send_queryStatusById(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_queryStatusById(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void send_queryStatusIdList(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_queryStatusIdList(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_recordFrequency(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_recordFrequency(arg0, arg1, arg2, arg3); - } finally {_lock.unlock();} -} - -@Override -public void send_removeSnapshot(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_removeSnapshot(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void send_removeTable(java.lang.String arg0, boolean arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_removeTable(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void send_resetLogging() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_resetLogging(); - } finally {_lock.unlock();} -} - -@Override -public void send_schema(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_schema(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_setUser(org.apache.blur.thrift.generated.User arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_setUser(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_shardClusterList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_shardClusterList(); - } finally {_lock.unlock();} -} - -@Override -public void send_shardServerLayout(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_shardServerLayout(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_shardServerLayoutState(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_shardServerLayoutState(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_shardServerList(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_shardServerList(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_startTrace(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_startTrace(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void send_tableList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_tableList(); - } finally {_lock.unlock();} -} - -@Override -public void send_tableListByCluster(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_tableListByCluster(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_tableStats(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_tableStats(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_terms(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3, short arg4) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_terms(arg0, arg1, arg2, arg3, arg4); - } finally {_lock.unlock();} -} - -@Override -public void send_traceList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_traceList(); - } finally {_lock.unlock();} -} - -@Override -public void send_traceRemove(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_traceRemove(arg0); - } finally {_lock.unlock();} -} - -@Override -public void send_traceRequestFetch(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_traceRequestFetch(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public void send_traceRequestList(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.send_traceRequestList(arg0); - } finally {_lock.unlock();} -} - -@Override -public void setUser(org.apache.blur.thrift.generated.User arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.setUser(arg0); - } finally {_lock.unlock();} -} - -@Override -public java.util.List shardClusterList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.shardClusterList(); - } finally {_lock.unlock();} -} - -@Override -public java.util.Map shardServerLayout(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.shardServerLayout(arg0); - } finally {_lock.unlock();} -} - -@Override -public java.util.Map shardServerLayoutState(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.shardServerLayoutState(arg0); - } finally {_lock.unlock();} -} - -@Override -public java.util.List shardServerList(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.shardServerList(arg0); - } finally {_lock.unlock();} -} - -@Override -public void startTrace(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.startTrace(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public java.util.List tableList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.tableList(); - } finally {_lock.unlock();} -} - -@Override -public java.util.List tableListByCluster(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.tableListByCluster(arg0); - } finally {_lock.unlock();} -} - -@Override -public org.apache.blur.thrift.generated.TableStats tableStats(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.tableStats(arg0); - } finally {_lock.unlock();} -} - -@Override -public java.util.List terms(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3, short arg4) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.terms(arg0, arg1, arg2, arg3, arg4); - } finally {_lock.unlock();} -} - -@Override -public java.util.List traceList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.traceList(); - } finally {_lock.unlock();} -} - -@Override -public void traceRemove(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - super.traceRemove(arg0); - } finally {_lock.unlock();} -} - -@Override -public java.lang.String traceRequestFetch(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.traceRequestFetch(arg0, arg1); - } finally {_lock.unlock();} -} - -@Override -public java.util.List traceRequestList(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { - _lock.errorFailLock(); try { - return super.traceRequestList(arg0); - } finally {_lock.unlock();} -} + public SafeClientGen(TProtocol prot) { + super(prot); + } } http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/94d579dd/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Value.java ---------------------------------------------------------------------- diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Value.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Value.java new file mode 100644 index 0000000..f120fd1 --- /dev/null +++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Value.java @@ -0,0 +1,794 @@ +/** + * Autogenerated by Thrift Compiler (0.9.0) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.blur.thrift.generated; + +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + + + +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.IScheme; +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.SchemeFactory; +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.StandardScheme; + +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.TupleScheme; +import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TTupleProtocol; +import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolException; +import org.apache.blur.thirdparty.thrift_0_9_0.EncodingUtils; +import org.apache.blur.thirdparty.thrift_0_9_0.TException; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +//import org.slf4j.Logger; +//import org.slf4j.LoggerFactory; + +public class Value extends org.apache.blur.thirdparty.thrift_0_9_0.TUnion<Value, Value._Fields> { + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("Value"); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField STRING_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("stringValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)1); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField INT_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("intValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, (short)2); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SHORT_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("shortValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I16, (short)3); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField LONG_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("longValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, (short)4); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField DOUBLE_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("doubleValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.DOUBLE, (short)5); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField FLOAT_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("floatValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.DOUBLE, (short)6); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField BINARY_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("binaryValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)7); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField BOOLEAN_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("booleanValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL, (short)8); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField NULL_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("nullValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL, (short)9); + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum { + STRING_VALUE((short)1, "stringValue"), + INT_VALUE((short)2, "intValue"), + SHORT_VALUE((short)3, "shortValue"), + LONG_VALUE((short)4, "longValue"), + DOUBLE_VALUE((short)5, "doubleValue"), + FLOAT_VALUE((short)6, "floatValue"), + BINARY_VALUE((short)7, "binaryValue"), + BOOLEAN_VALUE((short)8, "booleanValue"), + NULL_VALUE((short)9, "nullValue"); + + 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: // STRING_VALUE + return STRING_VALUE; + case 2: // INT_VALUE + return INT_VALUE; + case 3: // SHORT_VALUE + return SHORT_VALUE; + case 4: // LONG_VALUE + return LONG_VALUE; + case 5: // DOUBLE_VALUE + return DOUBLE_VALUE; + case 6: // FLOAT_VALUE + return FLOAT_VALUE; + case 7: // BINARY_VALUE + return BINARY_VALUE; + case 8: // BOOLEAN_VALUE + return BOOLEAN_VALUE; + case 9: // NULL_VALUE + return NULL_VALUE; + 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; + } + } + + public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.STRING_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("stringValue", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING))); + tmpMap.put(_Fields.INT_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("intValue", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32))); + tmpMap.put(_Fields.SHORT_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("shortValue", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I16))); + tmpMap.put(_Fields.LONG_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("longValue", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64))); + tmpMap.put(_Fields.DOUBLE_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("doubleValue", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.DOUBLE))); + tmpMap.put(_Fields.FLOAT_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("floatValue", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.DOUBLE))); + tmpMap.put(_Fields.BINARY_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("binaryValue", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING , true))); + tmpMap.put(_Fields.BOOLEAN_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("booleanValue", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL))); + tmpMap.put(_Fields.NULL_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("nullValue", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(Value.class, metaDataMap); + } + + public Value() { + super(); + } + + public Value(_Fields setField, Object value) { + super(setField, value); + } + + public Value(Value other) { + super(other); + } + public Value deepCopy() { + return new Value(this); + } + + public static Value stringValue(String value) { + Value x = new Value(); + x.setStringValue(value); + return x; + } + + public static Value intValue(int value) { + Value x = new Value(); + x.setIntValue(value); + return x; + } + + public static Value shortValue(short value) { + Value x = new Value(); + x.setShortValue(value); + return x; + } + + public static Value longValue(long value) { + Value x = new Value(); + x.setLongValue(value); + return x; + } + + public static Value doubleValue(double value) { + Value x = new Value(); + x.setDoubleValue(value); + return x; + } + + public static Value floatValue(double value) { + Value x = new Value(); + x.setFloatValue(value); + return x; + } + + public static Value binaryValue(ByteBuffer value) { + Value x = new Value(); + x.setBinaryValue(value); + return x; + } + + public static Value binaryValue(byte[] value) { + Value x = new Value(); + x.setBinaryValue(ByteBuffer.wrap(value)); + return x; + } + + public static Value booleanValue(boolean value) { + Value x = new Value(); + x.setBooleanValue(value); + return x; + } + + public static Value nullValue(boolean value) { + Value x = new Value(); + x.setNullValue(value); + return x; + } + + + @Override + protected void checkType(_Fields setField, Object value) throws ClassCastException { + switch (setField) { + case STRING_VALUE: + if (value instanceof String) { + break; + } + throw new ClassCastException("Was expecting value of type String for field 'stringValue', but got " + value.getClass().getSimpleName()); + case INT_VALUE: + if (value instanceof Integer) { + break; + } + throw new ClassCastException("Was expecting value of type Integer for field 'intValue', but got " + value.getClass().getSimpleName()); + case SHORT_VALUE: + if (value instanceof Short) { + break; + } + throw new ClassCastException("Was expecting value of type Short for field 'shortValue', but got " + value.getClass().getSimpleName()); + case LONG_VALUE: + if (value instanceof Long) { + break; + } + throw new ClassCastException("Was expecting value of type Long for field 'longValue', but got " + value.getClass().getSimpleName()); + case DOUBLE_VALUE: + if (value instanceof Double) { + break; + } + throw new ClassCastException("Was expecting value of type Double for field 'doubleValue', but got " + value.getClass().getSimpleName()); + case FLOAT_VALUE: + if (value instanceof Double) { + break; + } + throw new ClassCastException("Was expecting value of type Double for field 'floatValue', but got " + value.getClass().getSimpleName()); + case BINARY_VALUE: + if (value instanceof ByteBuffer) { + break; + } + throw new ClassCastException("Was expecting value of type ByteBuffer for field 'binaryValue', but got " + value.getClass().getSimpleName()); + case BOOLEAN_VALUE: + if (value instanceof Boolean) { + break; + } + throw new ClassCastException("Was expecting value of type Boolean for field 'booleanValue', but got " + value.getClass().getSimpleName()); + case NULL_VALUE: + if (value instanceof Boolean) { + break; + } + throw new ClassCastException("Was expecting value of type Boolean for field 'nullValue', but got " + value.getClass().getSimpleName()); + default: + throw new IllegalArgumentException("Unknown field id " + setField); + } + } + + @Override + protected Object standardSchemeReadValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField field) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + _Fields setField = _Fields.findByThriftId(field.id); + if (setField != null) { + switch (setField) { + case STRING_VALUE: + if (field.type == STRING_VALUE_FIELD_DESC.type) { + String stringValue; + stringValue = iprot.readString(); + return stringValue; + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + case INT_VALUE: + if (field.type == INT_VALUE_FIELD_DESC.type) { + Integer intValue; + intValue = iprot.readI32(); + return intValue; + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + case SHORT_VALUE: + if (field.type == SHORT_VALUE_FIELD_DESC.type) { + Short shortValue; + shortValue = iprot.readI16(); + return shortValue; + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + case LONG_VALUE: + if (field.type == LONG_VALUE_FIELD_DESC.type) { + Long longValue; + longValue = iprot.readI64(); + return longValue; + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + case DOUBLE_VALUE: + if (field.type == DOUBLE_VALUE_FIELD_DESC.type) { + Double doubleValue; + doubleValue = iprot.readDouble(); + return doubleValue; + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + case FLOAT_VALUE: + if (field.type == FLOAT_VALUE_FIELD_DESC.type) { + Double floatValue; + floatValue = iprot.readDouble(); + return floatValue; + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + case BINARY_VALUE: + if (field.type == BINARY_VALUE_FIELD_DESC.type) { + ByteBuffer binaryValue; + binaryValue = iprot.readBinary(); + return binaryValue; + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + case BOOLEAN_VALUE: + if (field.type == BOOLEAN_VALUE_FIELD_DESC.type) { + Boolean booleanValue; + booleanValue = iprot.readBool(); + return booleanValue; + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + case NULL_VALUE: + if (field.type == NULL_VALUE_FIELD_DESC.type) { + Boolean nullValue; + nullValue = iprot.readBool(); + return nullValue; + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + default: + throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!"); + } + } else { + return null; + } + } + + @Override + protected void standardSchemeWriteValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + switch (setField_) { + case STRING_VALUE: + String stringValue = (String)value_; + oprot.writeString(stringValue); + return; + case INT_VALUE: + Integer intValue = (Integer)value_; + oprot.writeI32(intValue); + return; + case SHORT_VALUE: + Short shortValue = (Short)value_; + oprot.writeI16(shortValue); + return; + case LONG_VALUE: + Long longValue = (Long)value_; + oprot.writeI64(longValue); + return; + case DOUBLE_VALUE: + Double doubleValue = (Double)value_; + oprot.writeDouble(doubleValue); + return; + case FLOAT_VALUE: + Double floatValue = (Double)value_; + oprot.writeDouble(floatValue); + return; + case BINARY_VALUE: + ByteBuffer binaryValue = (ByteBuffer)value_; + oprot.writeBinary(binaryValue); + return; + case BOOLEAN_VALUE: + Boolean booleanValue = (Boolean)value_; + oprot.writeBool(booleanValue); + return; + case NULL_VALUE: + Boolean nullValue = (Boolean)value_; + oprot.writeBool(nullValue); + return; + default: + throw new IllegalStateException("Cannot write union with unknown field " + setField_); + } + } + + @Override + protected Object tupleSchemeReadValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, short fieldID) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + _Fields setField = _Fields.findByThriftId(fieldID); + if (setField != null) { + switch (setField) { + case STRING_VALUE: + String stringValue; + stringValue = iprot.readString(); + return stringValue; + case INT_VALUE: + Integer intValue; + intValue = iprot.readI32(); + return intValue; + case SHORT_VALUE: + Short shortValue; + shortValue = iprot.readI16(); + return shortValue; + case LONG_VALUE: + Long longValue; + longValue = iprot.readI64(); + return longValue; + case DOUBLE_VALUE: + Double doubleValue; + doubleValue = iprot.readDouble(); + return doubleValue; + case FLOAT_VALUE: + Double floatValue; + floatValue = iprot.readDouble(); + return floatValue; + case BINARY_VALUE: + ByteBuffer binaryValue; + binaryValue = iprot.readBinary(); + return binaryValue; + case BOOLEAN_VALUE: + Boolean booleanValue; + booleanValue = iprot.readBool(); + return booleanValue; + case NULL_VALUE: + Boolean nullValue; + nullValue = iprot.readBool(); + return nullValue; + default: + throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!"); + } + } else { + throw new TProtocolException("Couldn't find a field with field id " + fieldID); + } + } + + @Override + protected void tupleSchemeWriteValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + switch (setField_) { + case STRING_VALUE: + String stringValue = (String)value_; + oprot.writeString(stringValue); + return; + case INT_VALUE: + Integer intValue = (Integer)value_; + oprot.writeI32(intValue); + return; + case SHORT_VALUE: + Short shortValue = (Short)value_; + oprot.writeI16(shortValue); + return; + case LONG_VALUE: + Long longValue = (Long)value_; + oprot.writeI64(longValue); + return; + case DOUBLE_VALUE: + Double doubleValue = (Double)value_; + oprot.writeDouble(doubleValue); + return; + case FLOAT_VALUE: + Double floatValue = (Double)value_; + oprot.writeDouble(floatValue); + return; + case BINARY_VALUE: + ByteBuffer binaryValue = (ByteBuffer)value_; + oprot.writeBinary(binaryValue); + return; + case BOOLEAN_VALUE: + Boolean booleanValue = (Boolean)value_; + oprot.writeBool(booleanValue); + return; + case NULL_VALUE: + Boolean nullValue = (Boolean)value_; + oprot.writeBool(nullValue); + return; + default: + throw new IllegalStateException("Cannot write union with unknown field " + setField_); + } + } + + @Override + protected org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField getFieldDesc(_Fields setField) { + switch (setField) { + case STRING_VALUE: + return STRING_VALUE_FIELD_DESC; + case INT_VALUE: + return INT_VALUE_FIELD_DESC; + case SHORT_VALUE: + return SHORT_VALUE_FIELD_DESC; + case LONG_VALUE: + return LONG_VALUE_FIELD_DESC; + case DOUBLE_VALUE: + return DOUBLE_VALUE_FIELD_DESC; + case FLOAT_VALUE: + return FLOAT_VALUE_FIELD_DESC; + case BINARY_VALUE: + return BINARY_VALUE_FIELD_DESC; + case BOOLEAN_VALUE: + return BOOLEAN_VALUE_FIELD_DESC; + case NULL_VALUE: + return NULL_VALUE_FIELD_DESC; + default: + throw new IllegalArgumentException("Unknown field id " + setField); + } + } + + @Override + protected org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct getStructDesc() { + return STRUCT_DESC; + } + + @Override + protected _Fields enumForId(short id) { + return _Fields.findByThriftIdOrThrow(id); + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + + public String getStringValue() { + if (getSetField() == _Fields.STRING_VALUE) { + return (String)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'stringValue' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setStringValue(String value) { + if (value == null) throw new NullPointerException(); + setField_ = _Fields.STRING_VALUE; + value_ = value; + } + + public int getIntValue() { + if (getSetField() == _Fields.INT_VALUE) { + return (Integer)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'intValue' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setIntValue(int value) { + setField_ = _Fields.INT_VALUE; + value_ = value; + } + + public short getShortValue() { + if (getSetField() == _Fields.SHORT_VALUE) { + return (Short)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'shortValue' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setShortValue(short value) { + setField_ = _Fields.SHORT_VALUE; + value_ = value; + } + + public long getLongValue() { + if (getSetField() == _Fields.LONG_VALUE) { + return (Long)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'longValue' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setLongValue(long value) { + setField_ = _Fields.LONG_VALUE; + value_ = value; + } + + public double getDoubleValue() { + if (getSetField() == _Fields.DOUBLE_VALUE) { + return (Double)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'doubleValue' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setDoubleValue(double value) { + setField_ = _Fields.DOUBLE_VALUE; + value_ = value; + } + + public double getFloatValue() { + if (getSetField() == _Fields.FLOAT_VALUE) { + return (Double)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'floatValue' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setFloatValue(double value) { + setField_ = _Fields.FLOAT_VALUE; + value_ = value; + } + + public byte[] getBinaryValue() { + setBinaryValue(org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.rightSize(bufferForBinaryValue())); + ByteBuffer b = bufferForBinaryValue(); + return b == null ? null : b.array(); + } + + public ByteBuffer bufferForBinaryValue() { + if (getSetField() == _Fields.BINARY_VALUE) { + return (ByteBuffer)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'binaryValue' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setBinaryValue(byte[] value) { + setBinaryValue(ByteBuffer.wrap(value)); + } + + public void setBinaryValue(ByteBuffer value) { + if (value == null) throw new NullPointerException(); + setField_ = _Fields.BINARY_VALUE; + value_ = value; + } + + public boolean getBooleanValue() { + if (getSetField() == _Fields.BOOLEAN_VALUE) { + return (Boolean)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'booleanValue' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setBooleanValue(boolean value) { + setField_ = _Fields.BOOLEAN_VALUE; + value_ = value; + } + + public boolean getNullValue() { + if (getSetField() == _Fields.NULL_VALUE) { + return (Boolean)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'nullValue' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setNullValue(boolean value) { + setField_ = _Fields.NULL_VALUE; + value_ = value; + } + + public boolean isSetStringValue() { + return setField_ == _Fields.STRING_VALUE; + } + + + public boolean isSetIntValue() { + return setField_ == _Fields.INT_VALUE; + } + + + public boolean isSetShortValue() { + return setField_ == _Fields.SHORT_VALUE; + } + + + public boolean isSetLongValue() { + return setField_ == _Fields.LONG_VALUE; + } + + + public boolean isSetDoubleValue() { + return setField_ == _Fields.DOUBLE_VALUE; + } + + + public boolean isSetFloatValue() { + return setField_ == _Fields.FLOAT_VALUE; + } + + + public boolean isSetBinaryValue() { + return setField_ == _Fields.BINARY_VALUE; + } + + + public boolean isSetBooleanValue() { + return setField_ == _Fields.BOOLEAN_VALUE; + } + + + public boolean isSetNullValue() { + return setField_ == _Fields.NULL_VALUE; + } + + + public boolean equals(Object other) { + if (other instanceof Value) { + return equals((Value)other); + } else { + return false; + } + } + + public boolean equals(Value other) { + return other != null && getSetField() == other.getSetField() && getFieldValue().equals(other.getFieldValue()); + } + + @Override + public int compareTo(Value other) { + int lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(getSetField(), other.getSetField()); + if (lastComparison == 0) { + return org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(getFieldValue(), other.getFieldValue()); + } + return lastComparison; + } + + + /** + * If you'd like this to perform more respectably, use the hashcode generator option. + */ + @Override + public int hashCode() { + return 0; + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(out))); + } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) { + throw new java.io.IOException(te); + } + } + + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(in))); + } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) { + throw new java.io.IOException(te); + } + } + + +} http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/94d579dd/blur-thrift/src/main/java/org/apache/blur/thrift/util/CommandExample.java ---------------------------------------------------------------------- diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/util/CommandExample.java b/blur-thrift/src/main/java/org/apache/blur/thrift/util/CommandExample.java new file mode 100644 index 0000000..3bfd1ac --- /dev/null +++ b/blur-thrift/src/main/java/org/apache/blur/thrift/util/CommandExample.java @@ -0,0 +1,33 @@ +package org.apache.blur.thrift.util; + +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +import java.io.IOException; + +import org.apache.blur.thirdparty.thrift_0_9_0.TException; +import org.apache.blur.thrift.BlurClient; +import org.apache.blur.thrift.generated.Blur.Iface; +import org.apache.blur.thrift.generated.BlurException; + +public class CommandExample { + + public static void main(String[] args) throws BlurException, TException, IOException { + Iface client = BlurClient.getClient("localhost:40020"); + System.out.println(client.execute("test", "docCount", null)); + System.out.println(client.execute("test", "docCountAggregate", null)); + } +} http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/94d579dd/distribution/src/main/scripts/interface/Blur.thrift ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/Blur.thrift b/distribution/src/main/scripts/interface/Blur.thrift index 9781d16..6692657 100644 --- a/distribution/src/main/scripts/interface/Blur.thrift +++ b/distribution/src/main/scripts/interface/Blur.thrift @@ -830,12 +830,35 @@ enum Level { ALL } +union Value { + 1:string stringValue, + 2:i32 intValue, + 3:i16 shortValue, + 4:i64 longValue, + 5:double doubleValue, + 6:double floatValue, + 7:binary binaryValue, + 8:bool booleanValue, + 9:bool nullValue +} + +union Response { + 1:map<string, Value> shardToValue, + 2:Value value +} + +struct Arguments { + 1:map<string,Value> values +} + /** * The Blur service API. This API is the same for both controller servers as well as * shards servers. Each of the methods are documented. */ service Blur { + Response execute(1:string table, 2:string commandName, 3:Arguments arguments) throws (1:BlurException ex) + //Table Commands /** @@ -1246,6 +1269,7 @@ service Blur { * Resets the logging for this instance to match the log4j file. NOTE: This will allow for dynamically changing to logging file at runtime. */ void resetLogging() throws (1:BlurException ex) + }
