mirror of https://github.com/apache/cassandra
Thrift generated files for CASSANDRA-3761 (CQL 3.0)
This commit is contained in:
Sylvain Lebresne
parent
655ccc3abf
commit
087d24a9d8
File diff suppressed because it is too large
Load Diff
|
|
@ -67,6 +67,8 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
private static final org.apache.thrift.protocol.TField COMPRESSION_OPTIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("compression_options", org.apache.thrift.protocol.TType.MAP, (short)32);
|
||||
private static final org.apache.thrift.protocol.TField BLOOM_FILTER_FP_CHANCE_FIELD_DESC = new org.apache.thrift.protocol.TField("bloom_filter_fp_chance", org.apache.thrift.protocol.TType.DOUBLE, (short)33);
|
||||
private static final org.apache.thrift.protocol.TField CACHING_FIELD_DESC = new org.apache.thrift.protocol.TField("caching", org.apache.thrift.protocol.TType.STRING, (short)34);
|
||||
private static final org.apache.thrift.protocol.TField COLUMN_ALIASES_FIELD_DESC = new org.apache.thrift.protocol.TField("column_aliases", org.apache.thrift.protocol.TType.LIST, (short)35);
|
||||
private static final org.apache.thrift.protocol.TField VALUE_ALIAS_FIELD_DESC = new org.apache.thrift.protocol.TField("value_alias", org.apache.thrift.protocol.TType.STRING, (short)36);
|
||||
|
||||
public String keyspace; // required
|
||||
public String name; // required
|
||||
|
|
@ -90,6 +92,8 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
public Map<String,String> compression_options; // required
|
||||
public double bloom_filter_fp_chance; // required
|
||||
public String caching; // required
|
||||
public List<ByteBuffer> column_aliases; // required
|
||||
public ByteBuffer value_alias; // required
|
||||
|
||||
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
|
||||
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
|
||||
|
|
@ -114,7 +118,9 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
COMPACTION_STRATEGY_OPTIONS((short)30, "compaction_strategy_options"),
|
||||
COMPRESSION_OPTIONS((short)32, "compression_options"),
|
||||
BLOOM_FILTER_FP_CHANCE((short)33, "bloom_filter_fp_chance"),
|
||||
CACHING((short)34, "caching");
|
||||
CACHING((short)34, "caching"),
|
||||
COLUMN_ALIASES((short)35, "column_aliases"),
|
||||
VALUE_ALIAS((short)36, "value_alias");
|
||||
|
||||
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
|
||||
|
||||
|
|
@ -173,6 +179,10 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
return BLOOM_FILTER_FP_CHANCE;
|
||||
case 34: // CACHING
|
||||
return CACHING;
|
||||
case 35: // COLUMN_ALIASES
|
||||
return COLUMN_ALIASES;
|
||||
case 36: // VALUE_ALIAS
|
||||
return VALUE_ALIAS;
|
||||
default:
|
||||
return null;
|
||||
}
|
||||
|
|
@ -275,6 +285,11 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)));
|
||||
tmpMap.put(_Fields.CACHING, new org.apache.thrift.meta_data.FieldMetaData("caching", org.apache.thrift.TFieldRequirementType.OPTIONAL,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
|
||||
tmpMap.put(_Fields.COLUMN_ALIASES, new org.apache.thrift.meta_data.FieldMetaData("column_aliases", org.apache.thrift.TFieldRequirementType.OPTIONAL,
|
||||
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true))));
|
||||
tmpMap.put(_Fields.VALUE_ALIAS, new org.apache.thrift.meta_data.FieldMetaData("value_alias", org.apache.thrift.TFieldRequirementType.OPTIONAL,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true)));
|
||||
metaDataMap = Collections.unmodifiableMap(tmpMap);
|
||||
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(CfDef.class, metaDataMap);
|
||||
}
|
||||
|
|
@ -384,6 +399,19 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
if (other.isSetCaching()) {
|
||||
this.caching = other.caching;
|
||||
}
|
||||
if (other.isSetColumn_aliases()) {
|
||||
List<ByteBuffer> __this__column_aliases = new ArrayList<ByteBuffer>();
|
||||
for (ByteBuffer other_element : other.column_aliases) {
|
||||
ByteBuffer temp_binary_element = org.apache.thrift.TBaseHelper.copyBinary(other_element);
|
||||
;
|
||||
__this__column_aliases.add(temp_binary_element);
|
||||
}
|
||||
this.column_aliases = __this__column_aliases;
|
||||
}
|
||||
if (other.isSetValue_alias()) {
|
||||
this.value_alias = org.apache.thrift.TBaseHelper.copyBinary(other.value_alias);
|
||||
;
|
||||
}
|
||||
}
|
||||
|
||||
public CfDef deepCopy() {
|
||||
|
|
@ -425,6 +453,8 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
this.bloom_filter_fp_chance = 0.0;
|
||||
this.caching = "keys_only";
|
||||
|
||||
this.column_aliases = null;
|
||||
this.value_alias = null;
|
||||
}
|
||||
|
||||
public String getKeyspace() {
|
||||
|
|
@ -994,6 +1024,79 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
}
|
||||
}
|
||||
|
||||
public int getColumn_aliasesSize() {
|
||||
return (this.column_aliases == null) ? 0 : this.column_aliases.size();
|
||||
}
|
||||
|
||||
public java.util.Iterator<ByteBuffer> getColumn_aliasesIterator() {
|
||||
return (this.column_aliases == null) ? null : this.column_aliases.iterator();
|
||||
}
|
||||
|
||||
public void addToColumn_aliases(ByteBuffer elem) {
|
||||
if (this.column_aliases == null) {
|
||||
this.column_aliases = new ArrayList<ByteBuffer>();
|
||||
}
|
||||
this.column_aliases.add(elem);
|
||||
}
|
||||
|
||||
public List<ByteBuffer> getColumn_aliases() {
|
||||
return this.column_aliases;
|
||||
}
|
||||
|
||||
public CfDef setColumn_aliases(List<ByteBuffer> column_aliases) {
|
||||
this.column_aliases = column_aliases;
|
||||
return this;
|
||||
}
|
||||
|
||||
public void unsetColumn_aliases() {
|
||||
this.column_aliases = null;
|
||||
}
|
||||
|
||||
/** Returns true if field column_aliases is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetColumn_aliases() {
|
||||
return this.column_aliases != null;
|
||||
}
|
||||
|
||||
public void setColumn_aliasesIsSet(boolean value) {
|
||||
if (!value) {
|
||||
this.column_aliases = null;
|
||||
}
|
||||
}
|
||||
|
||||
public byte[] getValue_alias() {
|
||||
setValue_alias(org.apache.thrift.TBaseHelper.rightSize(value_alias));
|
||||
return value_alias == null ? null : value_alias.array();
|
||||
}
|
||||
|
||||
public ByteBuffer bufferForValue_alias() {
|
||||
return value_alias;
|
||||
}
|
||||
|
||||
public CfDef setValue_alias(byte[] value_alias) {
|
||||
setValue_alias(value_alias == null ? (ByteBuffer)null : ByteBuffer.wrap(value_alias));
|
||||
return this;
|
||||
}
|
||||
|
||||
public CfDef setValue_alias(ByteBuffer value_alias) {
|
||||
this.value_alias = value_alias;
|
||||
return this;
|
||||
}
|
||||
|
||||
public void unsetValue_alias() {
|
||||
this.value_alias = null;
|
||||
}
|
||||
|
||||
/** Returns true if field value_alias is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetValue_alias() {
|
||||
return this.value_alias != null;
|
||||
}
|
||||
|
||||
public void setValue_aliasIsSet(boolean value) {
|
||||
if (!value) {
|
||||
this.value_alias = null;
|
||||
}
|
||||
}
|
||||
|
||||
public void setFieldValue(_Fields field, Object value) {
|
||||
switch (field) {
|
||||
case KEYSPACE:
|
||||
|
|
@ -1172,6 +1275,22 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
}
|
||||
break;
|
||||
|
||||
case COLUMN_ALIASES:
|
||||
if (value == null) {
|
||||
unsetColumn_aliases();
|
||||
} else {
|
||||
setColumn_aliases((List<ByteBuffer>)value);
|
||||
}
|
||||
break;
|
||||
|
||||
case VALUE_ALIAS:
|
||||
if (value == null) {
|
||||
unsetValue_alias();
|
||||
} else {
|
||||
setValue_alias((ByteBuffer)value);
|
||||
}
|
||||
break;
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
|
|
@ -1243,6 +1362,12 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
case CACHING:
|
||||
return getCaching();
|
||||
|
||||
case COLUMN_ALIASES:
|
||||
return getColumn_aliases();
|
||||
|
||||
case VALUE_ALIAS:
|
||||
return getValue_alias();
|
||||
|
||||
}
|
||||
throw new IllegalStateException();
|
||||
}
|
||||
|
|
@ -1298,6 +1423,10 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
return isSetBloom_filter_fp_chance();
|
||||
case CACHING:
|
||||
return isSetCaching();
|
||||
case COLUMN_ALIASES:
|
||||
return isSetColumn_aliases();
|
||||
case VALUE_ALIAS:
|
||||
return isSetValue_alias();
|
||||
}
|
||||
throw new IllegalStateException();
|
||||
}
|
||||
|
|
@ -1513,6 +1642,24 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
return false;
|
||||
}
|
||||
|
||||
boolean this_present_column_aliases = true && this.isSetColumn_aliases();
|
||||
boolean that_present_column_aliases = true && that.isSetColumn_aliases();
|
||||
if (this_present_column_aliases || that_present_column_aliases) {
|
||||
if (!(this_present_column_aliases && that_present_column_aliases))
|
||||
return false;
|
||||
if (!this.column_aliases.equals(that.column_aliases))
|
||||
return false;
|
||||
}
|
||||
|
||||
boolean this_present_value_alias = true && this.isSetValue_alias();
|
||||
boolean that_present_value_alias = true && that.isSetValue_alias();
|
||||
if (this_present_value_alias || that_present_value_alias) {
|
||||
if (!(this_present_value_alias && that_present_value_alias))
|
||||
return false;
|
||||
if (!this.value_alias.equals(that.value_alias))
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
|
|
@ -1630,6 +1777,16 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
if (present_caching)
|
||||
builder.append(caching);
|
||||
|
||||
boolean present_column_aliases = true && (isSetColumn_aliases());
|
||||
builder.append(present_column_aliases);
|
||||
if (present_column_aliases)
|
||||
builder.append(column_aliases);
|
||||
|
||||
boolean present_value_alias = true && (isSetValue_alias());
|
||||
builder.append(present_value_alias);
|
||||
if (present_value_alias)
|
||||
builder.append(value_alias);
|
||||
|
||||
return builder.toHashCode();
|
||||
}
|
||||
|
||||
|
|
@ -1861,6 +2018,26 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
return lastComparison;
|
||||
}
|
||||
}
|
||||
lastComparison = Boolean.valueOf(isSetColumn_aliases()).compareTo(typedOther.isSetColumn_aliases());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetColumn_aliases()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.column_aliases, typedOther.column_aliases);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
}
|
||||
lastComparison = Boolean.valueOf(isSetValue_alias()).compareTo(typedOther.isSetValue_alias());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetValue_alias()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.value_alias, typedOther.value_alias);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
|
@ -2075,6 +2252,30 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
|
||||
}
|
||||
break;
|
||||
case 35: // COLUMN_ALIASES
|
||||
if (field.type == org.apache.thrift.protocol.TType.LIST) {
|
||||
{
|
||||
org.apache.thrift.protocol.TList _list57 = iprot.readListBegin();
|
||||
this.column_aliases = new ArrayList<ByteBuffer>(_list57.size);
|
||||
for (int _i58 = 0; _i58 < _list57.size; ++_i58)
|
||||
{
|
||||
ByteBuffer _elem59; // required
|
||||
_elem59 = iprot.readBinary();
|
||||
this.column_aliases.add(_elem59);
|
||||
}
|
||||
iprot.readListEnd();
|
||||
}
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
|
||||
}
|
||||
break;
|
||||
case 36: // VALUE_ALIAS
|
||||
if (field.type == org.apache.thrift.protocol.TType.STRING) {
|
||||
this.value_alias = iprot.readBinary();
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
|
||||
}
|
||||
break;
|
||||
default:
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
|
||||
}
|
||||
|
|
@ -2138,9 +2339,9 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
oprot.writeFieldBegin(COLUMN_METADATA_FIELD_DESC);
|
||||
{
|
||||
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.column_metadata.size()));
|
||||
for (ColumnDef _iter57 : this.column_metadata)
|
||||
for (ColumnDef _iter60 : this.column_metadata)
|
||||
{
|
||||
_iter57.write(oprot);
|
||||
_iter60.write(oprot);
|
||||
}
|
||||
oprot.writeListEnd();
|
||||
}
|
||||
|
|
@ -2210,10 +2411,10 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
oprot.writeFieldBegin(COMPACTION_STRATEGY_OPTIONS_FIELD_DESC);
|
||||
{
|
||||
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.compaction_strategy_options.size()));
|
||||
for (Map.Entry<String, String> _iter58 : this.compaction_strategy_options.entrySet())
|
||||
for (Map.Entry<String, String> _iter61 : this.compaction_strategy_options.entrySet())
|
||||
{
|
||||
oprot.writeString(_iter58.getKey());
|
||||
oprot.writeString(_iter58.getValue());
|
||||
oprot.writeString(_iter61.getKey());
|
||||
oprot.writeString(_iter61.getValue());
|
||||
}
|
||||
oprot.writeMapEnd();
|
||||
}
|
||||
|
|
@ -2225,10 +2426,10 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
oprot.writeFieldBegin(COMPRESSION_OPTIONS_FIELD_DESC);
|
||||
{
|
||||
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.compression_options.size()));
|
||||
for (Map.Entry<String, String> _iter59 : this.compression_options.entrySet())
|
||||
for (Map.Entry<String, String> _iter62 : this.compression_options.entrySet())
|
||||
{
|
||||
oprot.writeString(_iter59.getKey());
|
||||
oprot.writeString(_iter59.getValue());
|
||||
oprot.writeString(_iter62.getKey());
|
||||
oprot.writeString(_iter62.getValue());
|
||||
}
|
||||
oprot.writeMapEnd();
|
||||
}
|
||||
|
|
@ -2247,6 +2448,27 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
oprot.writeFieldEnd();
|
||||
}
|
||||
}
|
||||
if (this.column_aliases != null) {
|
||||
if (isSetColumn_aliases()) {
|
||||
oprot.writeFieldBegin(COLUMN_ALIASES_FIELD_DESC);
|
||||
{
|
||||
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, this.column_aliases.size()));
|
||||
for (ByteBuffer _iter63 : this.column_aliases)
|
||||
{
|
||||
oprot.writeBinary(_iter63);
|
||||
}
|
||||
oprot.writeListEnd();
|
||||
}
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
}
|
||||
if (this.value_alias != null) {
|
||||
if (isSetValue_alias()) {
|
||||
oprot.writeFieldBegin(VALUE_ALIAS_FIELD_DESC);
|
||||
oprot.writeBinary(this.value_alias);
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
}
|
||||
oprot.writeFieldStop();
|
||||
oprot.writeStructEnd();
|
||||
}
|
||||
|
|
@ -2439,6 +2661,26 @@ public class CfDef implements org.apache.thrift.TBase<CfDef, CfDef._Fields>, jav
|
|||
}
|
||||
first = false;
|
||||
}
|
||||
if (isSetColumn_aliases()) {
|
||||
if (!first) sb.append(", ");
|
||||
sb.append("column_aliases:");
|
||||
if (this.column_aliases == null) {
|
||||
sb.append("null");
|
||||
} else {
|
||||
sb.append(this.column_aliases);
|
||||
}
|
||||
first = false;
|
||||
}
|
||||
if (isSetValue_alias()) {
|
||||
if (!first) sb.append(", ");
|
||||
sb.append("value_alias:");
|
||||
if (this.value_alias == null) {
|
||||
sb.append("null");
|
||||
} else {
|
||||
org.apache.thrift.TBaseHelper.toString(this.value_alias, sb);
|
||||
}
|
||||
first = false;
|
||||
}
|
||||
sb.append(")");
|
||||
return sb.toString();
|
||||
}
|
||||
|
|
|
|||
|
|
@ -44,6 +44,6 @@ import org.slf4j.LoggerFactory;
|
|||
|
||||
public class Constants {
|
||||
|
||||
public static final String VERSION = "19.25.0";
|
||||
public static final String VERSION = "19.26.0";
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -554,15 +554,15 @@ public class CqlMetadata implements org.apache.thrift.TBase<CqlMetadata, CqlMeta
|
|||
case 1: // NAME_TYPES
|
||||
if (field.type == org.apache.thrift.protocol.TType.MAP) {
|
||||
{
|
||||
org.apache.thrift.protocol.TMap _map73 = iprot.readMapBegin();
|
||||
this.name_types = new HashMap<ByteBuffer,String>(2*_map73.size);
|
||||
for (int _i74 = 0; _i74 < _map73.size; ++_i74)
|
||||
org.apache.thrift.protocol.TMap _map77 = iprot.readMapBegin();
|
||||
this.name_types = new HashMap<ByteBuffer,String>(2*_map77.size);
|
||||
for (int _i78 = 0; _i78 < _map77.size; ++_i78)
|
||||
{
|
||||
ByteBuffer _key75; // required
|
||||
String _val76; // required
|
||||
_key75 = iprot.readBinary();
|
||||
_val76 = iprot.readString();
|
||||
this.name_types.put(_key75, _val76);
|
||||
ByteBuffer _key79; // required
|
||||
String _val80; // required
|
||||
_key79 = iprot.readBinary();
|
||||
_val80 = iprot.readString();
|
||||
this.name_types.put(_key79, _val80);
|
||||
}
|
||||
iprot.readMapEnd();
|
||||
}
|
||||
|
|
@ -573,15 +573,15 @@ public class CqlMetadata implements org.apache.thrift.TBase<CqlMetadata, CqlMeta
|
|||
case 2: // VALUE_TYPES
|
||||
if (field.type == org.apache.thrift.protocol.TType.MAP) {
|
||||
{
|
||||
org.apache.thrift.protocol.TMap _map77 = iprot.readMapBegin();
|
||||
this.value_types = new HashMap<ByteBuffer,String>(2*_map77.size);
|
||||
for (int _i78 = 0; _i78 < _map77.size; ++_i78)
|
||||
org.apache.thrift.protocol.TMap _map81 = iprot.readMapBegin();
|
||||
this.value_types = new HashMap<ByteBuffer,String>(2*_map81.size);
|
||||
for (int _i82 = 0; _i82 < _map81.size; ++_i82)
|
||||
{
|
||||
ByteBuffer _key79; // required
|
||||
String _val80; // required
|
||||
_key79 = iprot.readBinary();
|
||||
_val80 = iprot.readString();
|
||||
this.value_types.put(_key79, _val80);
|
||||
ByteBuffer _key83; // required
|
||||
String _val84; // required
|
||||
_key83 = iprot.readBinary();
|
||||
_val84 = iprot.readString();
|
||||
this.value_types.put(_key83, _val84);
|
||||
}
|
||||
iprot.readMapEnd();
|
||||
}
|
||||
|
|
@ -622,10 +622,10 @@ public class CqlMetadata implements org.apache.thrift.TBase<CqlMetadata, CqlMeta
|
|||
oprot.writeFieldBegin(NAME_TYPES_FIELD_DESC);
|
||||
{
|
||||
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.name_types.size()));
|
||||
for (Map.Entry<ByteBuffer, String> _iter81 : this.name_types.entrySet())
|
||||
for (Map.Entry<ByteBuffer, String> _iter85 : this.name_types.entrySet())
|
||||
{
|
||||
oprot.writeBinary(_iter81.getKey());
|
||||
oprot.writeString(_iter81.getValue());
|
||||
oprot.writeBinary(_iter85.getKey());
|
||||
oprot.writeString(_iter85.getValue());
|
||||
}
|
||||
oprot.writeMapEnd();
|
||||
}
|
||||
|
|
@ -635,10 +635,10 @@ public class CqlMetadata implements org.apache.thrift.TBase<CqlMetadata, CqlMeta
|
|||
oprot.writeFieldBegin(VALUE_TYPES_FIELD_DESC);
|
||||
{
|
||||
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.value_types.size()));
|
||||
for (Map.Entry<ByteBuffer, String> _iter82 : this.value_types.entrySet())
|
||||
for (Map.Entry<ByteBuffer, String> _iter86 : this.value_types.entrySet())
|
||||
{
|
||||
oprot.writeBinary(_iter82.getKey());
|
||||
oprot.writeString(_iter82.getValue());
|
||||
oprot.writeBinary(_iter86.getKey());
|
||||
oprot.writeString(_iter86.getValue());
|
||||
}
|
||||
oprot.writeMapEnd();
|
||||
}
|
||||
|
|
|
|||
|
|
@ -541,14 +541,14 @@ public class CqlResult implements org.apache.thrift.TBase<CqlResult, CqlResult._
|
|||
case 2: // ROWS
|
||||
if (field.type == org.apache.thrift.protocol.TType.LIST) {
|
||||
{
|
||||
org.apache.thrift.protocol.TList _list83 = iprot.readListBegin();
|
||||
this.rows = new ArrayList<CqlRow>(_list83.size);
|
||||
for (int _i84 = 0; _i84 < _list83.size; ++_i84)
|
||||
org.apache.thrift.protocol.TList _list87 = iprot.readListBegin();
|
||||
this.rows = new ArrayList<CqlRow>(_list87.size);
|
||||
for (int _i88 = 0; _i88 < _list87.size; ++_i88)
|
||||
{
|
||||
CqlRow _elem85; // required
|
||||
_elem85 = new CqlRow();
|
||||
_elem85.read(iprot);
|
||||
this.rows.add(_elem85);
|
||||
CqlRow _elem89; // required
|
||||
_elem89 = new CqlRow();
|
||||
_elem89.read(iprot);
|
||||
this.rows.add(_elem89);
|
||||
}
|
||||
iprot.readListEnd();
|
||||
}
|
||||
|
|
@ -597,9 +597,9 @@ public class CqlResult implements org.apache.thrift.TBase<CqlResult, CqlResult._
|
|||
oprot.writeFieldBegin(ROWS_FIELD_DESC);
|
||||
{
|
||||
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.rows.size()));
|
||||
for (CqlRow _iter86 : this.rows)
|
||||
for (CqlRow _iter90 : this.rows)
|
||||
{
|
||||
_iter86.write(oprot);
|
||||
_iter90.write(oprot);
|
||||
}
|
||||
oprot.writeListEnd();
|
||||
}
|
||||
|
|
|
|||
|
|
@ -395,14 +395,14 @@ public class CqlRow implements org.apache.thrift.TBase<CqlRow, CqlRow._Fields>,
|
|||
case 2: // COLUMNS
|
||||
if (field.type == org.apache.thrift.protocol.TType.LIST) {
|
||||
{
|
||||
org.apache.thrift.protocol.TList _list69 = iprot.readListBegin();
|
||||
this.columns = new ArrayList<Column>(_list69.size);
|
||||
for (int _i70 = 0; _i70 < _list69.size; ++_i70)
|
||||
org.apache.thrift.protocol.TList _list73 = iprot.readListBegin();
|
||||
this.columns = new ArrayList<Column>(_list73.size);
|
||||
for (int _i74 = 0; _i74 < _list73.size; ++_i74)
|
||||
{
|
||||
Column _elem71; // required
|
||||
_elem71 = new Column();
|
||||
_elem71.read(iprot);
|
||||
this.columns.add(_elem71);
|
||||
Column _elem75; // required
|
||||
_elem75 = new Column();
|
||||
_elem75.read(iprot);
|
||||
this.columns.add(_elem75);
|
||||
}
|
||||
iprot.readListEnd();
|
||||
}
|
||||
|
|
@ -434,9 +434,9 @@ public class CqlRow implements org.apache.thrift.TBase<CqlRow, CqlRow._Fields>,
|
|||
oprot.writeFieldBegin(COLUMNS_FIELD_DESC);
|
||||
{
|
||||
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.columns.size()));
|
||||
for (Column _iter72 : this.columns)
|
||||
for (Column _iter76 : this.columns)
|
||||
{
|
||||
_iter72.write(oprot);
|
||||
_iter76.write(oprot);
|
||||
}
|
||||
oprot.writeListEnd();
|
||||
}
|
||||
|
|
|
|||
|
|
@ -718,15 +718,15 @@ public class KsDef implements org.apache.thrift.TBase<KsDef, KsDef._Fields>, jav
|
|||
case 3: // STRATEGY_OPTIONS
|
||||
if (field.type == org.apache.thrift.protocol.TType.MAP) {
|
||||
{
|
||||
org.apache.thrift.protocol.TMap _map60 = iprot.readMapBegin();
|
||||
this.strategy_options = new HashMap<String,String>(2*_map60.size);
|
||||
for (int _i61 = 0; _i61 < _map60.size; ++_i61)
|
||||
org.apache.thrift.protocol.TMap _map64 = iprot.readMapBegin();
|
||||
this.strategy_options = new HashMap<String,String>(2*_map64.size);
|
||||
for (int _i65 = 0; _i65 < _map64.size; ++_i65)
|
||||
{
|
||||
String _key62; // required
|
||||
String _val63; // required
|
||||
_key62 = iprot.readString();
|
||||
_val63 = iprot.readString();
|
||||
this.strategy_options.put(_key62, _val63);
|
||||
String _key66; // required
|
||||
String _val67; // required
|
||||
_key66 = iprot.readString();
|
||||
_val67 = iprot.readString();
|
||||
this.strategy_options.put(_key66, _val67);
|
||||
}
|
||||
iprot.readMapEnd();
|
||||
}
|
||||
|
|
@ -745,14 +745,14 @@ public class KsDef implements org.apache.thrift.TBase<KsDef, KsDef._Fields>, jav
|
|||
case 5: // CF_DEFS
|
||||
if (field.type == org.apache.thrift.protocol.TType.LIST) {
|
||||
{
|
||||
org.apache.thrift.protocol.TList _list64 = iprot.readListBegin();
|
||||
this.cf_defs = new ArrayList<CfDef>(_list64.size);
|
||||
for (int _i65 = 0; _i65 < _list64.size; ++_i65)
|
||||
org.apache.thrift.protocol.TList _list68 = iprot.readListBegin();
|
||||
this.cf_defs = new ArrayList<CfDef>(_list68.size);
|
||||
for (int _i69 = 0; _i69 < _list68.size; ++_i69)
|
||||
{
|
||||
CfDef _elem66; // required
|
||||
_elem66 = new CfDef();
|
||||
_elem66.read(iprot);
|
||||
this.cf_defs.add(_elem66);
|
||||
CfDef _elem70; // required
|
||||
_elem70 = new CfDef();
|
||||
_elem70.read(iprot);
|
||||
this.cf_defs.add(_elem70);
|
||||
}
|
||||
iprot.readListEnd();
|
||||
}
|
||||
|
|
@ -798,10 +798,10 @@ public class KsDef implements org.apache.thrift.TBase<KsDef, KsDef._Fields>, jav
|
|||
oprot.writeFieldBegin(STRATEGY_OPTIONS_FIELD_DESC);
|
||||
{
|
||||
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.strategy_options.size()));
|
||||
for (Map.Entry<String, String> _iter67 : this.strategy_options.entrySet())
|
||||
for (Map.Entry<String, String> _iter71 : this.strategy_options.entrySet())
|
||||
{
|
||||
oprot.writeString(_iter67.getKey());
|
||||
oprot.writeString(_iter67.getValue());
|
||||
oprot.writeString(_iter71.getKey());
|
||||
oprot.writeString(_iter71.getValue());
|
||||
}
|
||||
oprot.writeMapEnd();
|
||||
}
|
||||
|
|
@ -817,9 +817,9 @@ public class KsDef implements org.apache.thrift.TBase<KsDef, KsDef._Fields>, jav
|
|||
oprot.writeFieldBegin(CF_DEFS_FIELD_DESC);
|
||||
{
|
||||
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.cf_defs.size()));
|
||||
for (CfDef _iter68 : this.cf_defs)
|
||||
for (CfDef _iter72 : this.cf_defs)
|
||||
{
|
||||
_iter68.write(oprot);
|
||||
_iter72.write(oprot);
|
||||
}
|
||||
oprot.writeListEnd();
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue