http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/486d37b5/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..3f970cf 100644 --- a/distribution/src/main/scripts/interface/Blur.thrift +++ b/distribution/src/main/scripts/interface/Blur.thrift @@ -830,11 +830,53 @@ enum Level { ALL } +enum ValueType { + STRING, + INTEGER, + LONG, + DOUBLE, + FLOAT, + BINARY, + WRITABLE, + SERIALIZABLE +} + +struct Value { + 1:ValueType type, + 2:binary value +} + +struct AdhocByteCodeCommandRequest { + 1:list<Value> arguments, + 2:binary instanceData, + 3:map<string,binary> classData, + 4:list<string> libraries +} + +struct AdhocByteCodeCommandResponse { + 1:Value result +} + +union BlurCommandRequest { + 1:set<string> tablesToInvoke, + 2:AdhocByteCodeCommandRequest adhocByteCodeCommandRequest +} + +union BlurCommandResponse { + 1:AdhocByteCodeCommandResponse adhocByteCodeCommandResponse +} + +service BlurPlatform { + + BlurCommandResponse execute(1:BlurCommandRequest request) throws (1:BlurException ex) + +} + /** * 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 { +service Blur extends BlurPlatform { //Table Commands
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/486d37b5/distribution/src/main/scripts/interface/gen-html/Blur.html ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-html/Blur.html b/distribution/src/main/scripts/interface/gen-html/Blur.html index 9b3f3d3..3c6af09 100644 --- a/distribution/src/main/scripts/interface/gen-html/Blur.html +++ b/distribution/src/main/scripts/interface/gen-html/Blur.html @@ -9,7 +9,11 @@ <h1>Thrift module: Blur</h1> <table class="table-bordered table-striped table-condensed"><thead><th>Module</th><th>Services</th><th>Data types</th><th>Constants</th></thead> <tr> -<td>Blur</td><td><a href="Blur.html#Svc_Blur">Blur</a><br/> +<td>Blur</td><td><a href="Blur.html#Svc_BlurPlatform">BlurPlatform</a><br/> +<ul> +<li><a href="Blur.html#Fn_BlurPlatform_execute">execute</a></li> +</ul> +<a href="Blur.html#Svc_Blur">Blur</a><br/> <ul> <li><a href="Blur.html#Fn_Blur_addColumnDefinition">addColumnDefinition</a></li> <li><a href="Blur.html#Fn_Blur_cancelQuery">cancelQuery</a></li> @@ -57,7 +61,11 @@ <li><a href="Blur.html#Fn_Blur_traceRequestList">traceRequestList</a></li> </ul> </td> -<td><a href="Blur.html#Struct_BlurException">BlurException</a><br/> +<td><a href="Blur.html#Struct_AdhocByteCodeCommandRequest">AdhocByteCodeCommandRequest</a><br/> +<a href="Blur.html#Struct_AdhocByteCodeCommandResponse">AdhocByteCodeCommandResponse</a><br/> +<a href="Blur.html#Struct_BlurCommandRequest">BlurCommandRequest</a><br/> +<a href="Blur.html#Struct_BlurCommandResponse">BlurCommandResponse</a><br/> +<a href="Blur.html#Struct_BlurException">BlurException</a><br/> <a href="Blur.html#Struct_BlurQuery">BlurQuery</a><br/> <a href="Blur.html#Struct_BlurQueryStatus">BlurQueryStatus</a><br/> <a href="Blur.html#Struct_BlurResult">BlurResult</a><br/> @@ -91,6 +99,8 @@ <a href="Blur.html#Struct_TableDescriptor">TableDescriptor</a><br/> <a href="Blur.html#Struct_TableStats">TableStats</a><br/> <a href="Blur.html#Struct_User">User</a><br/> +<a href="Blur.html#Struct_Value">Value</a><br/> +<a href="Blur.html#Enum_ValueType">ValueType</a><br/> </td> <td></code></td> </tr></table> @@ -203,6 +213,17 @@ Logging level enum used to change the logging levels at runtime. <tr><td><code>TRACE</code></td><td><code>6</code></td></tr> <tr><td><code>ALL</code></td><td><code>7</code></td></tr> </table></div> +<div class="definition"><h3 id="Enum_ValueType">Enumeration: ValueType</h3> +<br/><table class="table-bordered table-striped table-condensed"> +<tr><td><code>STRING</code></td><td><code>0</code></td></tr> +<tr><td><code>INTEGER</code></td><td><code>1</code></td></tr> +<tr><td><code>LONG</code></td><td><code>2</code></td></tr> +<tr><td><code>DOUBLE</code></td><td><code>3</code></td></tr> +<tr><td><code>FLOAT</code></td><td><code>4</code></td></tr> +<tr><td><code>BINARY</code></td><td><code>5</code></td></tr> +<tr><td><code>WRITABLE</code></td><td><code>6</code></td></tr> +<tr><td><code>SERIALIZABLE</code></td><td><code>7</code></td></tr> +</table></div> <hr/><h2 id="Structs">Data structures</h2> <div class="definition"><h3 id="Struct_BlurException">Exception: BlurException</h3> <table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default value</th></thead> @@ -574,8 +595,33 @@ be family dot column, "family.column". <tr><td>4</td><td>doubleMap</td><td><code>map<<code>string</code>, <code>double</code>></code></td><td>map of double values emitted by the Metric. </td><td>default</td><td></td></tr> </table><br/>The Metric will hold all the information for a given Metric. -<br/></div><hr/><h2 id="Services">Services</h2> -<h3 id="Svc_Blur">Service: Blur</h3> +<br/></div><div class="definition"><h3 id="Struct_Value">Struct: Value</h3> +<table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default value</th></thead> +<tr><td>1</td><td>type</td><td><code><a href="Blur.html#Enum_ValueType">ValueType</a></code></td><td></td><td>default</td><td></td></tr> +<tr><td>2</td><td>value</td><td><code>binary</code></td><td></td><td>default</td><td></td></tr> +</table><br/></div><div class="definition"><h3 id="Struct_AdhocByteCodeCommandRequest">Struct: AdhocByteCodeCommandRequest</h3> +<table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default value</th></thead> +<tr><td>1</td><td>arguments</td><td><code>list<<code><a href="Blur.html#Struct_Value">Value</a></code>></code></td><td></td><td>default</td><td></td></tr> +<tr><td>2</td><td>instanceData</td><td><code>binary</code></td><td></td><td>default</td><td></td></tr> +<tr><td>3</td><td>classData</td><td><code>map<<code>string</code>, <code>binary</code>></code></td><td></td><td>default</td><td></td></tr> +<tr><td>4</td><td>libraries</td><td><code>list<<code>string</code>></code></td><td></td><td>default</td><td></td></tr> +</table><br/></div><div class="definition"><h3 id="Struct_AdhocByteCodeCommandResponse">Struct: AdhocByteCodeCommandResponse</h3> +<table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default value</th></thead> +<tr><td>1</td><td>result</td><td><code><a href="Blur.html#Struct_Value">Value</a></code></td><td></td><td>default</td><td></td></tr> +</table><br/></div><div class="definition"><h3 id="Struct_BlurCommandRequest">Struct: BlurCommandRequest</h3> +<table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default value</th></thead> +<tr><td>1</td><td>tablesToInvoke</td><td><code>set<<code>string</code>></code></td><td></td><td>default</td><td></td></tr> +<tr><td>2</td><td>adhocByteCodeCommandRequest</td><td><code><a href="Blur.html#Struct_AdhocByteCodeCommandRequest">AdhocByteCodeCommandRequest</a></code></td><td></td><td>default</td><td></td></tr> +</table><br/></div><div class="definition"><h3 id="Struct_BlurCommandResponse">Struct: BlurCommandResponse</h3> +<table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default value</th></thead> +<tr><td>1</td><td>adhocByteCodeCommandResponse</td><td><code><a href="Blur.html#Struct_AdhocByteCodeCommandResponse">AdhocByteCodeCommandResponse</a></code></td><td></td><td>default</td><td></td></tr> +</table><br/></div><hr/><h2 id="Services">Services</h2> +<h3 id="Svc_BlurPlatform">Service: BlurPlatform</h3> +<div class="definition"><h4 id="Fn_BlurPlatform_execute">Function: BlurPlatform.execute</h4> +<pre><code><a href="Blur.html#Struct_BlurCommandResponse">BlurCommandResponse</a></code> execute(<code><a href="Blur.html#Struct_BlurCommandRequest">BlurCommandRequest</a></code> request) + throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code> +</pre></div><h3 id="Svc_Blur">Service: Blur</h3> +<div class="extends"><em>extends</em> <code><a href="Blur.html#Svc_BlurPlatform">BlurPlatform</a></code></div> The Blur service API. This API is the same for both controller servers as well as shards servers. Each of the methods are documented. <br/><div class="definition"><h4 id="Fn_Blur_createTable">Function: Blur.createTable</h4> http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/486d37b5/distribution/src/main/scripts/interface/gen-html/index.html ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-html/index.html b/distribution/src/main/scripts/interface/gen-html/index.html index b9834e3..2b13ba3 100644 --- a/distribution/src/main/scripts/interface/gen-html/index.html +++ b/distribution/src/main/scripts/interface/gen-html/index.html @@ -5,7 +5,11 @@ <h1>All Thrift declarations</h1> <table class="table-bordered table-striped table-condensed"><thead><th>Module</th><th>Services</th><th>Data types</th><th>Constants</th></thead> <tr> -<td>Blur</td><td><a href="Blur.html#Svc_Blur">Blur</a><br/> +<td>Blur</td><td><a href="Blur.html#Svc_BlurPlatform">BlurPlatform</a><br/> +<ul> +<li><a href="Blur.html#Fn_BlurPlatform_execute">execute</a></li> +</ul> +<a href="Blur.html#Svc_Blur">Blur</a><br/> <ul> <li><a href="Blur.html#Fn_Blur_addColumnDefinition">addColumnDefinition</a></li> <li><a href="Blur.html#Fn_Blur_cancelQuery">cancelQuery</a></li> @@ -53,7 +57,11 @@ <li><a href="Blur.html#Fn_Blur_traceRequestList">traceRequestList</a></li> </ul> </td> -<td><a href="Blur.html#Struct_BlurException">BlurException</a><br/> +<td><a href="Blur.html#Struct_AdhocByteCodeCommandRequest">AdhocByteCodeCommandRequest</a><br/> +<a href="Blur.html#Struct_AdhocByteCodeCommandResponse">AdhocByteCodeCommandResponse</a><br/> +<a href="Blur.html#Struct_BlurCommandRequest">BlurCommandRequest</a><br/> +<a href="Blur.html#Struct_BlurCommandResponse">BlurCommandResponse</a><br/> +<a href="Blur.html#Struct_BlurException">BlurException</a><br/> <a href="Blur.html#Struct_BlurQuery">BlurQuery</a><br/> <a href="Blur.html#Struct_BlurQueryStatus">BlurQueryStatus</a><br/> <a href="Blur.html#Struct_BlurResult">BlurResult</a><br/> @@ -87,6 +95,8 @@ <a href="Blur.html#Struct_TableDescriptor">TableDescriptor</a><br/> <a href="Blur.html#Struct_TableStats">TableStats</a><br/> <a href="Blur.html#Struct_User">User</a><br/> +<a href="Blur.html#Struct_Value">Value</a><br/> +<a href="Blur.html#Enum_ValueType">ValueType</a><br/> </td> <td></code></td> </tr></table> http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/486d37b5/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/AdhocByteCodeCommandRequest.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/AdhocByteCodeCommandRequest.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/AdhocByteCodeCommandRequest.java new file mode 100644 index 0000000..7afcfe9 --- /dev/null +++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/AdhocByteCodeCommandRequest.java @@ -0,0 +1,886 @@ +/** + * 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 AdhocByteCodeCommandRequest implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<AdhocByteCodeCommandRequest, AdhocByteCodeCommandRequest._Fields>, java.io.Serializable, Cloneable { + 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("AdhocByteCodeCommandRequest"); + + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField ARGUMENTS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("arguments", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, (short)1); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField INSTANCE_DATA_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("instanceData", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)2); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField CLASS_DATA_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("classData", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, (short)3); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField LIBRARIES_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("libraries", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, (short)4); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new AdhocByteCodeCommandRequestStandardSchemeFactory()); + schemes.put(TupleScheme.class, new AdhocByteCodeCommandRequestTupleSchemeFactory()); + } + + public List<Value> arguments; // required + public ByteBuffer instanceData; // required + public Map<String,ByteBuffer> classData; // required + public List<String> libraries; // required + + /** 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 { + ARGUMENTS((short)1, "arguments"), + INSTANCE_DATA((short)2, "instanceData"), + CLASS_DATA((short)3, "classData"), + LIBRARIES((short)4, "libraries"); + + 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: // ARGUMENTS + return ARGUMENTS; + case 2: // INSTANCE_DATA + return INSTANCE_DATA; + case 3: // CLASS_DATA + return CLASS_DATA; + case 4: // LIBRARIES + return LIBRARIES; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.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.ARGUMENTS, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("arguments", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.ListMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, + 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.INSTANCE_DATA, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("instanceData", 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.CLASS_DATA, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("classData", 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.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING , true)))); + tmpMap.put(_Fields.LIBRARIES, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("libraries", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.ListMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(AdhocByteCodeCommandRequest.class, metaDataMap); + } + + public AdhocByteCodeCommandRequest() { + } + + public AdhocByteCodeCommandRequest( + List<Value> arguments, + ByteBuffer instanceData, + Map<String,ByteBuffer> classData, + List<String> libraries) + { + this(); + this.arguments = arguments; + this.instanceData = instanceData; + this.classData = classData; + this.libraries = libraries; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public AdhocByteCodeCommandRequest(AdhocByteCodeCommandRequest other) { + if (other.isSetArguments()) { + List<Value> __this__arguments = new ArrayList<Value>(); + for (Value other_element : other.arguments) { + __this__arguments.add(new Value(other_element)); + } + this.arguments = __this__arguments; + } + if (other.isSetInstanceData()) { + this.instanceData = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.copyBinary(other.instanceData); +; + } + if (other.isSetClassData()) { + Map<String,ByteBuffer> __this__classData = new HashMap<String,ByteBuffer>(); + for (Map.Entry<String, ByteBuffer> other_element : other.classData.entrySet()) { + + String other_element_key = other_element.getKey(); + ByteBuffer other_element_value = other_element.getValue(); + + String __this__classData_copy_key = other_element_key; + + ByteBuffer __this__classData_copy_value = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.copyBinary(other_element_value); +; + + __this__classData.put(__this__classData_copy_key, __this__classData_copy_value); + } + this.classData = __this__classData; + } + if (other.isSetLibraries()) { + List<String> __this__libraries = new ArrayList<String>(); + for (String other_element : other.libraries) { + __this__libraries.add(other_element); + } + this.libraries = __this__libraries; + } + } + + public AdhocByteCodeCommandRequest deepCopy() { + return new AdhocByteCodeCommandRequest(this); + } + + @Override + public void clear() { + this.arguments = null; + this.instanceData = null; + this.classData = null; + this.libraries = null; + } + + public int getArgumentsSize() { + return (this.arguments == null) ? 0 : this.arguments.size(); + } + + public java.util.Iterator<Value> getArgumentsIterator() { + return (this.arguments == null) ? null : this.arguments.iterator(); + } + + public void addToArguments(Value elem) { + if (this.arguments == null) { + this.arguments = new ArrayList<Value>(); + } + this.arguments.add(elem); + } + + public List<Value> getArguments() { + return this.arguments; + } + + public AdhocByteCodeCommandRequest setArguments(List<Value> arguments) { + this.arguments = arguments; + return this; + } + + public void unsetArguments() { + this.arguments = null; + } + + /** Returns true if field arguments is set (has been assigned a value) and false otherwise */ + public boolean isSetArguments() { + return this.arguments != null; + } + + public void setArgumentsIsSet(boolean value) { + if (!value) { + this.arguments = null; + } + } + + public byte[] getInstanceData() { + setInstanceData(org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.rightSize(instanceData)); + return instanceData == null ? null : instanceData.array(); + } + + public ByteBuffer bufferForInstanceData() { + return instanceData; + } + + public AdhocByteCodeCommandRequest setInstanceData(byte[] instanceData) { + setInstanceData(instanceData == null ? (ByteBuffer)null : ByteBuffer.wrap(instanceData)); + return this; + } + + public AdhocByteCodeCommandRequest setInstanceData(ByteBuffer instanceData) { + this.instanceData = instanceData; + return this; + } + + public void unsetInstanceData() { + this.instanceData = null; + } + + /** Returns true if field instanceData is set (has been assigned a value) and false otherwise */ + public boolean isSetInstanceData() { + return this.instanceData != null; + } + + public void setInstanceDataIsSet(boolean value) { + if (!value) { + this.instanceData = null; + } + } + + public int getClassDataSize() { + return (this.classData == null) ? 0 : this.classData.size(); + } + + public void putToClassData(String key, ByteBuffer val) { + if (this.classData == null) { + this.classData = new HashMap<String,ByteBuffer>(); + } + this.classData.put(key, val); + } + + public Map<String,ByteBuffer> getClassData() { + return this.classData; + } + + public AdhocByteCodeCommandRequest setClassData(Map<String,ByteBuffer> classData) { + this.classData = classData; + return this; + } + + public void unsetClassData() { + this.classData = null; + } + + /** Returns true if field classData is set (has been assigned a value) and false otherwise */ + public boolean isSetClassData() { + return this.classData != null; + } + + public void setClassDataIsSet(boolean value) { + if (!value) { + this.classData = null; + } + } + + public int getLibrariesSize() { + return (this.libraries == null) ? 0 : this.libraries.size(); + } + + public java.util.Iterator<String> getLibrariesIterator() { + return (this.libraries == null) ? null : this.libraries.iterator(); + } + + public void addToLibraries(String elem) { + if (this.libraries == null) { + this.libraries = new ArrayList<String>(); + } + this.libraries.add(elem); + } + + public List<String> getLibraries() { + return this.libraries; + } + + public AdhocByteCodeCommandRequest setLibraries(List<String> libraries) { + this.libraries = libraries; + return this; + } + + public void unsetLibraries() { + this.libraries = null; + } + + /** Returns true if field libraries is set (has been assigned a value) and false otherwise */ + public boolean isSetLibraries() { + return this.libraries != null; + } + + public void setLibrariesIsSet(boolean value) { + if (!value) { + this.libraries = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case ARGUMENTS: + if (value == null) { + unsetArguments(); + } else { + setArguments((List<Value>)value); + } + break; + + case INSTANCE_DATA: + if (value == null) { + unsetInstanceData(); + } else { + setInstanceData((ByteBuffer)value); + } + break; + + case CLASS_DATA: + if (value == null) { + unsetClassData(); + } else { + setClassData((Map<String,ByteBuffer>)value); + } + break; + + case LIBRARIES: + if (value == null) { + unsetLibraries(); + } else { + setLibraries((List<String>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case ARGUMENTS: + return getArguments(); + + case INSTANCE_DATA: + return getInstanceData(); + + case CLASS_DATA: + return getClassData(); + + case LIBRARIES: + return getLibraries(); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case ARGUMENTS: + return isSetArguments(); + case INSTANCE_DATA: + return isSetInstanceData(); + case CLASS_DATA: + return isSetClassData(); + case LIBRARIES: + return isSetLibraries(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof AdhocByteCodeCommandRequest) + return this.equals((AdhocByteCodeCommandRequest)that); + return false; + } + + public boolean equals(AdhocByteCodeCommandRequest that) { + if (that == null) + return false; + + boolean this_present_arguments = true && this.isSetArguments(); + boolean that_present_arguments = true && that.isSetArguments(); + if (this_present_arguments || that_present_arguments) { + if (!(this_present_arguments && that_present_arguments)) + return false; + if (!this.arguments.equals(that.arguments)) + return false; + } + + boolean this_present_instanceData = true && this.isSetInstanceData(); + boolean that_present_instanceData = true && that.isSetInstanceData(); + if (this_present_instanceData || that_present_instanceData) { + if (!(this_present_instanceData && that_present_instanceData)) + return false; + if (!this.instanceData.equals(that.instanceData)) + return false; + } + + boolean this_present_classData = true && this.isSetClassData(); + boolean that_present_classData = true && that.isSetClassData(); + if (this_present_classData || that_present_classData) { + if (!(this_present_classData && that_present_classData)) + return false; + if (!this.classData.equals(that.classData)) + return false; + } + + boolean this_present_libraries = true && this.isSetLibraries(); + boolean that_present_libraries = true && that.isSetLibraries(); + if (this_present_libraries || that_present_libraries) { + if (!(this_present_libraries && that_present_libraries)) + return false; + if (!this.libraries.equals(that.libraries)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(AdhocByteCodeCommandRequest other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + AdhocByteCodeCommandRequest typedOther = (AdhocByteCodeCommandRequest)other; + + lastComparison = Boolean.valueOf(isSetArguments()).compareTo(typedOther.isSetArguments()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetArguments()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.arguments, typedOther.arguments); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetInstanceData()).compareTo(typedOther.isSetInstanceData()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetInstanceData()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.instanceData, typedOther.instanceData); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetClassData()).compareTo(typedOther.isSetClassData()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetClassData()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.classData, typedOther.classData); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetLibraries()).compareTo(typedOther.isSetLibraries()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetLibraries()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.libraries, typedOther.libraries); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("AdhocByteCodeCommandRequest("); + boolean first = true; + + sb.append("arguments:"); + if (this.arguments == null) { + sb.append("null"); + } else { + sb.append(this.arguments); + } + first = false; + if (!first) sb.append(", "); + sb.append("instanceData:"); + if (this.instanceData == null) { + sb.append("null"); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.toString(this.instanceData, sb); + } + first = false; + if (!first) sb.append(", "); + sb.append("classData:"); + if (this.classData == null) { + sb.append("null"); + } else { + sb.append(this.classData); + } + first = false; + if (!first) sb.append(", "); + sb.append("libraries:"); + if (this.libraries == null) { + sb.append("null"); + } else { + sb.append(this.libraries); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + // check for required fields + // check for sub-struct validity + } + + 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); + } + } + + private static class AdhocByteCodeCommandRequestStandardSchemeFactory implements SchemeFactory { + public AdhocByteCodeCommandRequestStandardScheme getScheme() { + return new AdhocByteCodeCommandRequestStandardScheme(); + } + } + + private static class AdhocByteCodeCommandRequestStandardScheme extends StandardScheme<AdhocByteCodeCommandRequest> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, AdhocByteCodeCommandRequest struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // ARGUMENTS + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list232 = iprot.readListBegin(); + struct.arguments = new ArrayList<Value>(_list232.size); + for (int _i233 = 0; _i233 < _list232.size; ++_i233) + { + Value _elem234; // required + _elem234 = new Value(); + _elem234.read(iprot); + struct.arguments.add(_elem234); + } + iprot.readListEnd(); + } + struct.setArgumentsIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // INSTANCE_DATA + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.instanceData = iprot.readBinary(); + struct.setInstanceDataIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // CLASS_DATA + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map235 = iprot.readMapBegin(); + struct.classData = new HashMap<String,ByteBuffer>(2*_map235.size); + for (int _i236 = 0; _i236 < _map235.size; ++_i236) + { + String _key237; // optional + ByteBuffer _val238; // required + _key237 = iprot.readString(); + _val238 = iprot.readBinary(); + struct.classData.put(_key237, _val238); + } + iprot.readMapEnd(); + } + struct.setClassDataIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // LIBRARIES + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list239 = iprot.readListBegin(); + struct.libraries = new ArrayList<String>(_list239.size); + for (int _i240 = 0; _i240 < _list239.size; ++_i240) + { + String _elem241; // required + _elem241 = iprot.readString(); + struct.libraries.add(_elem241); + } + iprot.readListEnd(); + } + struct.setLibrariesIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, AdhocByteCodeCommandRequest struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.arguments != null) { + oprot.writeFieldBegin(ARGUMENTS_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, struct.arguments.size())); + for (Value _iter242 : struct.arguments) + { + _iter242.write(oprot); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + if (struct.instanceData != null) { + oprot.writeFieldBegin(INSTANCE_DATA_FIELD_DESC); + oprot.writeBinary(struct.instanceData); + oprot.writeFieldEnd(); + } + if (struct.classData != null) { + oprot.writeFieldBegin(CLASS_DATA_FIELD_DESC); + { + 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.STRING, struct.classData.size())); + for (Map.Entry<String, ByteBuffer> _iter243 : struct.classData.entrySet()) + { + oprot.writeString(_iter243.getKey()); + oprot.writeBinary(_iter243.getValue()); + } + oprot.writeMapEnd(); + } + oprot.writeFieldEnd(); + } + if (struct.libraries != null) { + oprot.writeFieldBegin(LIBRARIES_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, struct.libraries.size())); + for (String _iter244 : struct.libraries) + { + oprot.writeString(_iter244); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class AdhocByteCodeCommandRequestTupleSchemeFactory implements SchemeFactory { + public AdhocByteCodeCommandRequestTupleScheme getScheme() { + return new AdhocByteCodeCommandRequestTupleScheme(); + } + } + + private static class AdhocByteCodeCommandRequestTupleScheme extends TupleScheme<AdhocByteCodeCommandRequest> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, AdhocByteCodeCommandRequest struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetArguments()) { + optionals.set(0); + } + if (struct.isSetInstanceData()) { + optionals.set(1); + } + if (struct.isSetClassData()) { + optionals.set(2); + } + if (struct.isSetLibraries()) { + optionals.set(3); + } + oprot.writeBitSet(optionals, 4); + if (struct.isSetArguments()) { + { + oprot.writeI32(struct.arguments.size()); + for (Value _iter245 : struct.arguments) + { + _iter245.write(oprot); + } + } + } + if (struct.isSetInstanceData()) { + oprot.writeBinary(struct.instanceData); + } + if (struct.isSetClassData()) { + { + oprot.writeI32(struct.classData.size()); + for (Map.Entry<String, ByteBuffer> _iter246 : struct.classData.entrySet()) + { + oprot.writeString(_iter246.getKey()); + oprot.writeBinary(_iter246.getValue()); + } + } + } + if (struct.isSetLibraries()) { + { + oprot.writeI32(struct.libraries.size()); + for (String _iter247 : struct.libraries) + { + oprot.writeString(_iter247); + } + } + } + } + + @Override + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, AdhocByteCodeCommandRequest struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(4); + if (incoming.get(0)) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list248 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, iprot.readI32()); + struct.arguments = new ArrayList<Value>(_list248.size); + for (int _i249 = 0; _i249 < _list248.size; ++_i249) + { + Value _elem250; // required + _elem250 = new Value(); + _elem250.read(iprot); + struct.arguments.add(_elem250); + } + } + struct.setArgumentsIsSet(true); + } + if (incoming.get(1)) { + struct.instanceData = iprot.readBinary(); + struct.setInstanceDataIsSet(true); + } + if (incoming.get(2)) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map251 = 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.STRING, iprot.readI32()); + struct.classData = new HashMap<String,ByteBuffer>(2*_map251.size); + for (int _i252 = 0; _i252 < _map251.size; ++_i252) + { + String _key253; // optional + ByteBuffer _val254; // required + _key253 = iprot.readString(); + _val254 = iprot.readBinary(); + struct.classData.put(_key253, _val254); + } + } + struct.setClassDataIsSet(true); + } + if (incoming.get(3)) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list255 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32()); + struct.libraries = new ArrayList<String>(_list255.size); + for (int _i256 = 0; _i256 < _list255.size; ++_i256) + { + String _elem257; // required + _elem257 = iprot.readString(); + struct.libraries.add(_elem257); + } + } + struct.setLibrariesIsSet(true); + } + } + } + +} + http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/486d37b5/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/AdhocByteCodeCommandResponse.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/AdhocByteCodeCommandResponse.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/AdhocByteCodeCommandResponse.java new file mode 100644 index 0000000..9f38edd --- /dev/null +++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/AdhocByteCodeCommandResponse.java @@ -0,0 +1,410 @@ +/** + * 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 AdhocByteCodeCommandResponse implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<AdhocByteCodeCommandResponse, AdhocByteCodeCommandResponse._Fields>, java.io.Serializable, Cloneable { + 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("AdhocByteCodeCommandResponse"); + + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField RESULT_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("result", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)1); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new AdhocByteCodeCommandResponseStandardSchemeFactory()); + schemes.put(TupleScheme.class, new AdhocByteCodeCommandResponseTupleSchemeFactory()); + } + + public Value result; // required + + /** 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 { + RESULT((short)1, "result"); + + 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: // RESULT + return RESULT; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.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.RESULT, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("result", 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(AdhocByteCodeCommandResponse.class, metaDataMap); + } + + public AdhocByteCodeCommandResponse() { + } + + public AdhocByteCodeCommandResponse( + Value result) + { + this(); + this.result = result; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public AdhocByteCodeCommandResponse(AdhocByteCodeCommandResponse other) { + if (other.isSetResult()) { + this.result = new Value(other.result); + } + } + + public AdhocByteCodeCommandResponse deepCopy() { + return new AdhocByteCodeCommandResponse(this); + } + + @Override + public void clear() { + this.result = null; + } + + public Value getResult() { + return this.result; + } + + public AdhocByteCodeCommandResponse setResult(Value result) { + this.result = result; + return this; + } + + public void unsetResult() { + this.result = null; + } + + /** Returns true if field result is set (has been assigned a value) and false otherwise */ + public boolean isSetResult() { + return this.result != null; + } + + public void setResultIsSet(boolean value) { + if (!value) { + this.result = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case RESULT: + if (value == null) { + unsetResult(); + } else { + setResult((Value)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case RESULT: + return getResult(); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case RESULT: + return isSetResult(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof AdhocByteCodeCommandResponse) + return this.equals((AdhocByteCodeCommandResponse)that); + return false; + } + + public boolean equals(AdhocByteCodeCommandResponse that) { + if (that == null) + return false; + + boolean this_present_result = true && this.isSetResult(); + boolean that_present_result = true && that.isSetResult(); + if (this_present_result || that_present_result) { + if (!(this_present_result && that_present_result)) + return false; + if (!this.result.equals(that.result)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(AdhocByteCodeCommandResponse other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + AdhocByteCodeCommandResponse typedOther = (AdhocByteCodeCommandResponse)other; + + lastComparison = Boolean.valueOf(isSetResult()).compareTo(typedOther.isSetResult()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetResult()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.result, typedOther.result); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("AdhocByteCodeCommandResponse("); + boolean first = true; + + sb.append("result:"); + if (this.result == null) { + sb.append("null"); + } else { + sb.append(this.result); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + // check for required fields + // check for sub-struct validity + if (result != null) { + result.validate(); + } + } + + 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); + } + } + + private static class AdhocByteCodeCommandResponseStandardSchemeFactory implements SchemeFactory { + public AdhocByteCodeCommandResponseStandardScheme getScheme() { + return new AdhocByteCodeCommandResponseStandardScheme(); + } + } + + private static class AdhocByteCodeCommandResponseStandardScheme extends StandardScheme<AdhocByteCodeCommandResponse> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, AdhocByteCodeCommandResponse struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // RESULT + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT) { + struct.result = new Value(); + struct.result.read(iprot); + struct.setResultIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, AdhocByteCodeCommandResponse struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.result != null) { + oprot.writeFieldBegin(RESULT_FIELD_DESC); + struct.result.write(oprot); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class AdhocByteCodeCommandResponseTupleSchemeFactory implements SchemeFactory { + public AdhocByteCodeCommandResponseTupleScheme getScheme() { + return new AdhocByteCodeCommandResponseTupleScheme(); + } + } + + private static class AdhocByteCodeCommandResponseTupleScheme extends TupleScheme<AdhocByteCodeCommandResponse> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, AdhocByteCodeCommandResponse struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetResult()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetResult()) { + struct.result.write(oprot); + } + } + + @Override + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, AdhocByteCodeCommandResponse struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(1); + if (incoming.get(0)) { + struct.result = new Value(); + struct.result.read(iprot); + struct.setResultIsSet(true); + } + } + } + +} +
