You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by we...@apache.org on 2016/05/27 18:23:33 UTC
[5/8] hive git commit: HIVE-13354 : Add ability to specify Compaction
options per table and per request (Wei Zheng, reviewed by Eugene Koifman)
http://git-wip-us.apache.org/repos/asf/hive/blob/c57a5961/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java
index e028ecb..d3fc92a 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java
@@ -43,6 +43,7 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
private static final org.apache.thrift.protocol.TField PARTITIONNAME_FIELD_DESC = new org.apache.thrift.protocol.TField("partitionname", org.apache.thrift.protocol.TType.STRING, (short)3);
private static final org.apache.thrift.protocol.TField TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("type", org.apache.thrift.protocol.TType.I32, (short)4);
private static final org.apache.thrift.protocol.TField RUNAS_FIELD_DESC = new org.apache.thrift.protocol.TField("runas", org.apache.thrift.protocol.TType.STRING, (short)5);
+ private static final org.apache.thrift.protocol.TField PROPERTIES_FIELD_DESC = new org.apache.thrift.protocol.TField("properties", org.apache.thrift.protocol.TType.MAP, (short)6);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
@@ -55,6 +56,7 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
private String partitionname; // optional
private CompactionType type; // required
private String runas; // optional
+ private Map<String,String> properties; // optional
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
@@ -66,7 +68,8 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
* @see CompactionType
*/
TYPE((short)4, "type"),
- RUNAS((short)5, "runas");
+ RUNAS((short)5, "runas"),
+ PROPERTIES((short)6, "properties");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -91,6 +94,8 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
return TYPE;
case 5: // RUNAS
return RUNAS;
+ case 6: // PROPERTIES
+ return PROPERTIES;
default:
return null;
}
@@ -131,7 +136,7 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
}
// isset id assignments
- private static final _Fields optionals[] = {_Fields.PARTITIONNAME,_Fields.RUNAS};
+ private static final _Fields optionals[] = {_Fields.PARTITIONNAME,_Fields.RUNAS,_Fields.PROPERTIES};
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -145,6 +150,10 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, CompactionType.class)));
tmpMap.put(_Fields.RUNAS, new org.apache.thrift.meta_data.FieldMetaData("runas", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.PROPERTIES, new org.apache.thrift.meta_data.FieldMetaData("properties", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING),
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(CompactionRequest.class, metaDataMap);
}
@@ -182,6 +191,10 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
if (other.isSetRunas()) {
this.runas = other.runas;
}
+ if (other.isSetProperties()) {
+ Map<String,String> __this__properties = new HashMap<String,String>(other.properties);
+ this.properties = __this__properties;
+ }
}
public CompactionRequest deepCopy() {
@@ -195,6 +208,7 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
this.partitionname = null;
this.type = null;
this.runas = null;
+ this.properties = null;
}
public String getDbname() {
@@ -320,6 +334,40 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
}
}
+ public int getPropertiesSize() {
+ return (this.properties == null) ? 0 : this.properties.size();
+ }
+
+ public void putToProperties(String key, String val) {
+ if (this.properties == null) {
+ this.properties = new HashMap<String,String>();
+ }
+ this.properties.put(key, val);
+ }
+
+ public Map<String,String> getProperties() {
+ return this.properties;
+ }
+
+ public void setProperties(Map<String,String> properties) {
+ this.properties = properties;
+ }
+
+ public void unsetProperties() {
+ this.properties = null;
+ }
+
+ /** Returns true if field properties is set (has been assigned a value) and false otherwise */
+ public boolean isSetProperties() {
+ return this.properties != null;
+ }
+
+ public void setPropertiesIsSet(boolean value) {
+ if (!value) {
+ this.properties = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case DBNAME:
@@ -362,6 +410,14 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
}
break;
+ case PROPERTIES:
+ if (value == null) {
+ unsetProperties();
+ } else {
+ setProperties((Map<String,String>)value);
+ }
+ break;
+
}
}
@@ -382,6 +438,9 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
case RUNAS:
return getRunas();
+ case PROPERTIES:
+ return getProperties();
+
}
throw new IllegalStateException();
}
@@ -403,6 +462,8 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
return isSetType();
case RUNAS:
return isSetRunas();
+ case PROPERTIES:
+ return isSetProperties();
}
throw new IllegalStateException();
}
@@ -465,6 +526,15 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
return false;
}
+ boolean this_present_properties = true && this.isSetProperties();
+ boolean that_present_properties = true && that.isSetProperties();
+ if (this_present_properties || that_present_properties) {
+ if (!(this_present_properties && that_present_properties))
+ return false;
+ if (!this.properties.equals(that.properties))
+ return false;
+ }
+
return true;
}
@@ -497,6 +567,11 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
if (present_runas)
list.add(runas);
+ boolean present_properties = true && (isSetProperties());
+ list.add(present_properties);
+ if (present_properties)
+ list.add(properties);
+
return list.hashCode();
}
@@ -558,6 +633,16 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(isSetProperties()).compareTo(other.isSetProperties());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetProperties()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.properties, other.properties);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -621,6 +706,16 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
}
first = false;
}
+ if (isSetProperties()) {
+ if (!first) sb.append(", ");
+ sb.append("properties:");
+ if (this.properties == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.properties);
+ }
+ first = false;
+ }
sb.append(")");
return sb.toString();
}
@@ -716,6 +811,26 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
+ case 6: // PROPERTIES
+ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
+ {
+ org.apache.thrift.protocol.TMap _map524 = iprot.readMapBegin();
+ struct.properties = new HashMap<String,String>(2*_map524.size);
+ String _key525;
+ String _val526;
+ for (int _i527 = 0; _i527 < _map524.size; ++_i527)
+ {
+ _key525 = iprot.readString();
+ _val526 = iprot.readString();
+ struct.properties.put(_key525, _val526);
+ }
+ iprot.readMapEnd();
+ }
+ struct.setPropertiesIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@@ -758,6 +873,21 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
oprot.writeFieldEnd();
}
}
+ if (struct.properties != null) {
+ if (struct.isSetProperties()) {
+ oprot.writeFieldBegin(PROPERTIES_FIELD_DESC);
+ {
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.properties.size()));
+ for (Map.Entry<String, String> _iter528 : struct.properties.entrySet())
+ {
+ oprot.writeString(_iter528.getKey());
+ oprot.writeString(_iter528.getValue());
+ }
+ oprot.writeMapEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ }
oprot.writeFieldStop();
oprot.writeStructEnd();
}
@@ -785,13 +915,26 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
if (struct.isSetRunas()) {
optionals.set(1);
}
- oprot.writeBitSet(optionals, 2);
+ if (struct.isSetProperties()) {
+ optionals.set(2);
+ }
+ oprot.writeBitSet(optionals, 3);
if (struct.isSetPartitionname()) {
oprot.writeString(struct.partitionname);
}
if (struct.isSetRunas()) {
oprot.writeString(struct.runas);
}
+ if (struct.isSetProperties()) {
+ {
+ oprot.writeI32(struct.properties.size());
+ for (Map.Entry<String, String> _iter529 : struct.properties.entrySet())
+ {
+ oprot.writeString(_iter529.getKey());
+ oprot.writeString(_iter529.getValue());
+ }
+ }
+ }
}
@Override
@@ -803,7 +946,7 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
struct.setTablenameIsSet(true);
struct.type = org.apache.hadoop.hive.metastore.api.CompactionType.findByValue(iprot.readI32());
struct.setTypeIsSet(true);
- BitSet incoming = iprot.readBitSet(2);
+ BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
struct.partitionname = iprot.readString();
struct.setPartitionnameIsSet(true);
@@ -812,6 +955,21 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
struct.runas = iprot.readString();
struct.setRunasIsSet(true);
}
+ if (incoming.get(2)) {
+ {
+ org.apache.thrift.protocol.TMap _map530 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.properties = new HashMap<String,String>(2*_map530.size);
+ String _key531;
+ String _val532;
+ for (int _i533 = 0; _i533 < _map530.size; ++_i533)
+ {
+ _key531 = iprot.readString();
+ _val532 = iprot.readString();
+ struct.properties.put(_key531, _val532);
+ }
+ }
+ struct.setPropertiesIsSet(true);
+ }
}
}
http://git-wip-us.apache.org/repos/asf/hive/blob/c57a5961/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
index 763fe5e..6772338 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
@@ -713,13 +713,13 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques
case 5: // PARTITION_VALS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list556 = iprot.readListBegin();
- struct.partitionVals = new ArrayList<String>(_list556.size);
- String _elem557;
- for (int _i558 = 0; _i558 < _list556.size; ++_i558)
+ org.apache.thrift.protocol.TList _list566 = iprot.readListBegin();
+ struct.partitionVals = new ArrayList<String>(_list566.size);
+ String _elem567;
+ for (int _i568 = 0; _i568 < _list566.size; ++_i568)
{
- _elem557 = iprot.readString();
- struct.partitionVals.add(_elem557);
+ _elem567 = iprot.readString();
+ struct.partitionVals.add(_elem567);
}
iprot.readListEnd();
}
@@ -768,9 +768,9 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques
oprot.writeFieldBegin(PARTITION_VALS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partitionVals.size()));
- for (String _iter559 : struct.partitionVals)
+ for (String _iter569 : struct.partitionVals)
{
- oprot.writeString(_iter559);
+ oprot.writeString(_iter569);
}
oprot.writeListEnd();
}
@@ -816,9 +816,9 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques
if (struct.isSetPartitionVals()) {
{
oprot.writeI32(struct.partitionVals.size());
- for (String _iter560 : struct.partitionVals)
+ for (String _iter570 : struct.partitionVals)
{
- oprot.writeString(_iter560);
+ oprot.writeString(_iter570);
}
}
}
@@ -843,13 +843,13 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list561 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partitionVals = new ArrayList<String>(_list561.size);
- String _elem562;
- for (int _i563 = 0; _i563 < _list561.size; ++_i563)
+ org.apache.thrift.protocol.TList _list571 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partitionVals = new ArrayList<String>(_list571.size);
+ String _elem572;
+ for (int _i573 = 0; _i573 < _list571.size; ++_i573)
{
- _elem562 = iprot.readString();
- struct.partitionVals.add(_elem562);
+ _elem572 = iprot.readString();
+ struct.partitionVals.add(_elem572);
}
}
struct.setPartitionValsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/c57a5961/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java
index c30e7b8..f427a3a 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java
@@ -346,14 +346,14 @@ public class GetAllFunctionsResponse implements org.apache.thrift.TBase<GetAllFu
case 1: // FUNCTIONS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list624 = iprot.readListBegin();
- struct.functions = new ArrayList<Function>(_list624.size);
- Function _elem625;
- for (int _i626 = 0; _i626 < _list624.size; ++_i626)
+ org.apache.thrift.protocol.TList _list634 = iprot.readListBegin();
+ struct.functions = new ArrayList<Function>(_list634.size);
+ Function _elem635;
+ for (int _i636 = 0; _i636 < _list634.size; ++_i636)
{
- _elem625 = new Function();
- _elem625.read(iprot);
- struct.functions.add(_elem625);
+ _elem635 = new Function();
+ _elem635.read(iprot);
+ struct.functions.add(_elem635);
}
iprot.readListEnd();
}
@@ -380,9 +380,9 @@ public class GetAllFunctionsResponse implements org.apache.thrift.TBase<GetAllFu
oprot.writeFieldBegin(FUNCTIONS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.functions.size()));
- for (Function _iter627 : struct.functions)
+ for (Function _iter637 : struct.functions)
{
- _iter627.write(oprot);
+ _iter637.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ public class GetAllFunctionsResponse implements org.apache.thrift.TBase<GetAllFu
if (struct.isSetFunctions()) {
{
oprot.writeI32(struct.functions.size());
- for (Function _iter628 : struct.functions)
+ for (Function _iter638 : struct.functions)
{
- _iter628.write(oprot);
+ _iter638.write(oprot);
}
}
}
@@ -428,14 +428,14 @@ public class GetAllFunctionsResponse implements org.apache.thrift.TBase<GetAllFu
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list629 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.functions = new ArrayList<Function>(_list629.size);
- Function _elem630;
- for (int _i631 = 0; _i631 < _list629.size; ++_i631)
+ org.apache.thrift.protocol.TList _list639 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.functions = new ArrayList<Function>(_list639.size);
+ Function _elem640;
+ for (int _i641 = 0; _i641 < _list639.size; ++_i641)
{
- _elem630 = new Function();
- _elem630.read(iprot);
- struct.functions.add(_elem630);
+ _elem640 = new Function();
+ _elem640.read(iprot);
+ struct.functions.add(_elem640);
}
}
struct.setFunctionsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/c57a5961/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java
index 4ba95ba..1ea90a0 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java
@@ -619,13 +619,13 @@ public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<Get
case 1: // FILE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list574 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list574.size);
- long _elem575;
- for (int _i576 = 0; _i576 < _list574.size; ++_i576)
+ org.apache.thrift.protocol.TList _list584 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list584.size);
+ long _elem585;
+ for (int _i586 = 0; _i586 < _list584.size; ++_i586)
{
- _elem575 = iprot.readI64();
- struct.fileIds.add(_elem575);
+ _elem585 = iprot.readI64();
+ struct.fileIds.add(_elem585);
}
iprot.readListEnd();
}
@@ -675,9 +675,9 @@ public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<Get
oprot.writeFieldBegin(FILE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.fileIds.size()));
- for (long _iter577 : struct.fileIds)
+ for (long _iter587 : struct.fileIds)
{
- oprot.writeI64(_iter577);
+ oprot.writeI64(_iter587);
}
oprot.writeListEnd();
}
@@ -719,9 +719,9 @@ public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<Get
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter578 : struct.fileIds)
+ for (long _iter588 : struct.fileIds)
{
- oprot.writeI64(_iter578);
+ oprot.writeI64(_iter588);
}
}
oprot.writeBinary(struct.expr);
@@ -745,13 +745,13 @@ public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<Get
public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataByExprRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list579 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list579.size);
- long _elem580;
- for (int _i581 = 0; _i581 < _list579.size; ++_i581)
+ org.apache.thrift.protocol.TList _list589 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list589.size);
+ long _elem590;
+ for (int _i591 = 0; _i591 < _list589.size; ++_i591)
{
- _elem580 = iprot.readI64();
- struct.fileIds.add(_elem580);
+ _elem590 = iprot.readI64();
+ struct.fileIds.add(_elem590);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/c57a5961/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java
index 2e0bd9c..609abc5 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java
@@ -444,16 +444,16 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF
case 1: // METADATA
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map564 = iprot.readMapBegin();
- struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map564.size);
- long _key565;
- MetadataPpdResult _val566;
- for (int _i567 = 0; _i567 < _map564.size; ++_i567)
+ org.apache.thrift.protocol.TMap _map574 = iprot.readMapBegin();
+ struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map574.size);
+ long _key575;
+ MetadataPpdResult _val576;
+ for (int _i577 = 0; _i577 < _map574.size; ++_i577)
{
- _key565 = iprot.readI64();
- _val566 = new MetadataPpdResult();
- _val566.read(iprot);
- struct.metadata.put(_key565, _val566);
+ _key575 = iprot.readI64();
+ _val576 = new MetadataPpdResult();
+ _val576.read(iprot);
+ struct.metadata.put(_key575, _val576);
}
iprot.readMapEnd();
}
@@ -487,10 +487,10 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF
oprot.writeFieldBegin(METADATA_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, struct.metadata.size()));
- for (Map.Entry<Long, MetadataPpdResult> _iter568 : struct.metadata.entrySet())
+ for (Map.Entry<Long, MetadataPpdResult> _iter578 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter568.getKey());
- _iter568.getValue().write(oprot);
+ oprot.writeI64(_iter578.getKey());
+ _iter578.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -518,10 +518,10 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.metadata.size());
- for (Map.Entry<Long, MetadataPpdResult> _iter569 : struct.metadata.entrySet())
+ for (Map.Entry<Long, MetadataPpdResult> _iter579 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter569.getKey());
- _iter569.getValue().write(oprot);
+ oprot.writeI64(_iter579.getKey());
+ _iter579.getValue().write(oprot);
}
}
oprot.writeBool(struct.isSupported);
@@ -531,16 +531,16 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF
public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataByExprResult struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TMap _map570 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map570.size);
- long _key571;
- MetadataPpdResult _val572;
- for (int _i573 = 0; _i573 < _map570.size; ++_i573)
+ org.apache.thrift.protocol.TMap _map580 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map580.size);
+ long _key581;
+ MetadataPpdResult _val582;
+ for (int _i583 = 0; _i583 < _map580.size; ++_i583)
{
- _key571 = iprot.readI64();
- _val572 = new MetadataPpdResult();
- _val572.read(iprot);
- struct.metadata.put(_key571, _val572);
+ _key581 = iprot.readI64();
+ _val582 = new MetadataPpdResult();
+ _val582.read(iprot);
+ struct.metadata.put(_key581, _val582);
}
}
struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/c57a5961/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java
index c079ecd..5cf880a 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java
@@ -351,13 +351,13 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe
case 1: // FILE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list592 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list592.size);
- long _elem593;
- for (int _i594 = 0; _i594 < _list592.size; ++_i594)
+ org.apache.thrift.protocol.TList _list602 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list602.size);
+ long _elem603;
+ for (int _i604 = 0; _i604 < _list602.size; ++_i604)
{
- _elem593 = iprot.readI64();
- struct.fileIds.add(_elem593);
+ _elem603 = iprot.readI64();
+ struct.fileIds.add(_elem603);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe
oprot.writeFieldBegin(FILE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.fileIds.size()));
- for (long _iter595 : struct.fileIds)
+ for (long _iter605 : struct.fileIds)
{
- oprot.writeI64(_iter595);
+ oprot.writeI64(_iter605);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter596 : struct.fileIds)
+ for (long _iter606 : struct.fileIds)
{
- oprot.writeI64(_iter596);
+ oprot.writeI64(_iter606);
}
}
}
@@ -421,13 +421,13 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe
public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list597 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list597.size);
- long _elem598;
- for (int _i599 = 0; _i599 < _list597.size; ++_i599)
+ org.apache.thrift.protocol.TList _list607 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list607.size);
+ long _elem608;
+ for (int _i609 = 0; _i609 < _list607.size; ++_i609)
{
- _elem598 = iprot.readI64();
- struct.fileIds.add(_elem598);
+ _elem608 = iprot.readI64();
+ struct.fileIds.add(_elem608);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/c57a5961/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java
index fb2a64a..8870c2f 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java
@@ -433,15 +433,15 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet
case 1: // METADATA
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map582 = iprot.readMapBegin();
- struct.metadata = new HashMap<Long,ByteBuffer>(2*_map582.size);
- long _key583;
- ByteBuffer _val584;
- for (int _i585 = 0; _i585 < _map582.size; ++_i585)
+ org.apache.thrift.protocol.TMap _map592 = iprot.readMapBegin();
+ struct.metadata = new HashMap<Long,ByteBuffer>(2*_map592.size);
+ long _key593;
+ ByteBuffer _val594;
+ for (int _i595 = 0; _i595 < _map592.size; ++_i595)
{
- _key583 = iprot.readI64();
- _val584 = iprot.readBinary();
- struct.metadata.put(_key583, _val584);
+ _key593 = iprot.readI64();
+ _val594 = iprot.readBinary();
+ struct.metadata.put(_key593, _val594);
}
iprot.readMapEnd();
}
@@ -475,10 +475,10 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet
oprot.writeFieldBegin(METADATA_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, struct.metadata.size()));
- for (Map.Entry<Long, ByteBuffer> _iter586 : struct.metadata.entrySet())
+ for (Map.Entry<Long, ByteBuffer> _iter596 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter586.getKey());
- oprot.writeBinary(_iter586.getValue());
+ oprot.writeI64(_iter596.getKey());
+ oprot.writeBinary(_iter596.getValue());
}
oprot.writeMapEnd();
}
@@ -506,10 +506,10 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.metadata.size());
- for (Map.Entry<Long, ByteBuffer> _iter587 : struct.metadata.entrySet())
+ for (Map.Entry<Long, ByteBuffer> _iter597 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter587.getKey());
- oprot.writeBinary(_iter587.getValue());
+ oprot.writeI64(_iter597.getKey());
+ oprot.writeBinary(_iter597.getValue());
}
}
oprot.writeBool(struct.isSupported);
@@ -519,15 +519,15 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet
public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataResult struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TMap _map588 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.metadata = new HashMap<Long,ByteBuffer>(2*_map588.size);
- long _key589;
- ByteBuffer _val590;
- for (int _i591 = 0; _i591 < _map588.size; ++_i591)
+ org.apache.thrift.protocol.TMap _map598 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.metadata = new HashMap<Long,ByteBuffer>(2*_map598.size);
+ long _key599;
+ ByteBuffer _val600;
+ for (int _i601 = 0; _i601 < _map598.size; ++_i601)
{
- _key589 = iprot.readI64();
- _val590 = iprot.readBinary();
- struct.metadata.put(_key589, _val590);
+ _key599 = iprot.readI64();
+ _val600 = iprot.readBinary();
+ struct.metadata.put(_key599, _val600);
}
}
struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/c57a5961/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
index 820a573..a8df524 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
@@ -351,13 +351,13 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
case 1: // FILES_ADDED
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list548 = iprot.readListBegin();
- struct.filesAdded = new ArrayList<String>(_list548.size);
- String _elem549;
- for (int _i550 = 0; _i550 < _list548.size; ++_i550)
+ org.apache.thrift.protocol.TList _list558 = iprot.readListBegin();
+ struct.filesAdded = new ArrayList<String>(_list558.size);
+ String _elem559;
+ for (int _i560 = 0; _i560 < _list558.size; ++_i560)
{
- _elem549 = iprot.readString();
- struct.filesAdded.add(_elem549);
+ _elem559 = iprot.readString();
+ struct.filesAdded.add(_elem559);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
oprot.writeFieldBegin(FILES_ADDED_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.filesAdded.size()));
- for (String _iter551 : struct.filesAdded)
+ for (String _iter561 : struct.filesAdded)
{
- oprot.writeString(_iter551);
+ oprot.writeString(_iter561);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.filesAdded.size());
- for (String _iter552 : struct.filesAdded)
+ for (String _iter562 : struct.filesAdded)
{
- oprot.writeString(_iter552);
+ oprot.writeString(_iter562);
}
}
}
@@ -421,13 +421,13 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
public void read(org.apache.thrift.protocol.TProtocol prot, InsertEventRequestData struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list553 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.filesAdded = new ArrayList<String>(_list553.size);
- String _elem554;
- for (int _i555 = 0; _i555 < _list553.size; ++_i555)
+ org.apache.thrift.protocol.TList _list563 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.filesAdded = new ArrayList<String>(_list563.size);
+ String _elem564;
+ for (int _i565 = 0; _i565 < _list563.size; ++_i565)
{
- _elem554 = iprot.readString();
- struct.filesAdded.add(_elem554);
+ _elem564 = iprot.readString();
+ struct.filesAdded.add(_elem564);
}
}
struct.setFilesAddedIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/c57a5961/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
index ce8aca3..edc548a 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
@@ -354,14 +354,14 @@ public class NotificationEventResponse implements org.apache.thrift.TBase<Notifi
case 1: // EVENTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list540 = iprot.readListBegin();
- struct.events = new ArrayList<NotificationEvent>(_list540.size);
- NotificationEvent _elem541;
- for (int _i542 = 0; _i542 < _list540.size; ++_i542)
+ org.apache.thrift.protocol.TList _list550 = iprot.readListBegin();
+ struct.events = new ArrayList<NotificationEvent>(_list550.size);
+ NotificationEvent _elem551;
+ for (int _i552 = 0; _i552 < _list550.size; ++_i552)
{
- _elem541 = new NotificationEvent();
- _elem541.read(iprot);
- struct.events.add(_elem541);
+ _elem551 = new NotificationEvent();
+ _elem551.read(iprot);
+ struct.events.add(_elem551);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ public class NotificationEventResponse implements org.apache.thrift.TBase<Notifi
oprot.writeFieldBegin(EVENTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.events.size()));
- for (NotificationEvent _iter543 : struct.events)
+ for (NotificationEvent _iter553 : struct.events)
{
- _iter543.write(oprot);
+ _iter553.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ public class NotificationEventResponse implements org.apache.thrift.TBase<Notifi
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.events.size());
- for (NotificationEvent _iter544 : struct.events)
+ for (NotificationEvent _iter554 : struct.events)
{
- _iter544.write(oprot);
+ _iter554.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ public class NotificationEventResponse implements org.apache.thrift.TBase<Notifi
public void read(org.apache.thrift.protocol.TProtocol prot, NotificationEventResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list545 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.events = new ArrayList<NotificationEvent>(_list545.size);
- NotificationEvent _elem546;
- for (int _i547 = 0; _i547 < _list545.size; ++_i547)
+ org.apache.thrift.protocol.TList _list555 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.events = new ArrayList<NotificationEvent>(_list555.size);
+ NotificationEvent _elem556;
+ for (int _i557 = 0; _i557 < _list555.size; ++_i557)
{
- _elem546 = new NotificationEvent();
- _elem546.read(iprot);
- struct.events.add(_elem546);
+ _elem556 = new NotificationEvent();
+ _elem556.read(iprot);
+ struct.events.add(_elem556);
}
}
struct.setEventsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/c57a5961/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
index 9323d9f..6eff25d 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
@@ -547,13 +547,13 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe
case 1: // FILE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list600 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list600.size);
- long _elem601;
- for (int _i602 = 0; _i602 < _list600.size; ++_i602)
+ org.apache.thrift.protocol.TList _list610 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list610.size);
+ long _elem611;
+ for (int _i612 = 0; _i612 < _list610.size; ++_i612)
{
- _elem601 = iprot.readI64();
- struct.fileIds.add(_elem601);
+ _elem611 = iprot.readI64();
+ struct.fileIds.add(_elem611);
}
iprot.readListEnd();
}
@@ -565,13 +565,13 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe
case 2: // METADATA
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list603 = iprot.readListBegin();
- struct.metadata = new ArrayList<ByteBuffer>(_list603.size);
- ByteBuffer _elem604;
- for (int _i605 = 0; _i605 < _list603.size; ++_i605)
+ org.apache.thrift.protocol.TList _list613 = iprot.readListBegin();
+ struct.metadata = new ArrayList<ByteBuffer>(_list613.size);
+ ByteBuffer _elem614;
+ for (int _i615 = 0; _i615 < _list613.size; ++_i615)
{
- _elem604 = iprot.readBinary();
- struct.metadata.add(_elem604);
+ _elem614 = iprot.readBinary();
+ struct.metadata.add(_elem614);
}
iprot.readListEnd();
}
@@ -605,9 +605,9 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe
oprot.writeFieldBegin(FILE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.fileIds.size()));
- for (long _iter606 : struct.fileIds)
+ for (long _iter616 : struct.fileIds)
{
- oprot.writeI64(_iter606);
+ oprot.writeI64(_iter616);
}
oprot.writeListEnd();
}
@@ -617,9 +617,9 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe
oprot.writeFieldBegin(METADATA_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.metadata.size()));
- for (ByteBuffer _iter607 : struct.metadata)
+ for (ByteBuffer _iter617 : struct.metadata)
{
- oprot.writeBinary(_iter607);
+ oprot.writeBinary(_iter617);
}
oprot.writeListEnd();
}
@@ -651,16 +651,16 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter608 : struct.fileIds)
+ for (long _iter618 : struct.fileIds)
{
- oprot.writeI64(_iter608);
+ oprot.writeI64(_iter618);
}
}
{
oprot.writeI32(struct.metadata.size());
- for (ByteBuffer _iter609 : struct.metadata)
+ for (ByteBuffer _iter619 : struct.metadata)
{
- oprot.writeBinary(_iter609);
+ oprot.writeBinary(_iter619);
}
}
BitSet optionals = new BitSet();
@@ -677,24 +677,24 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe
public void read(org.apache.thrift.protocol.TProtocol prot, PutFileMetadataRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list610 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list610.size);
- long _elem611;
- for (int _i612 = 0; _i612 < _list610.size; ++_i612)
+ org.apache.thrift.protocol.TList _list620 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list620.size);
+ long _elem621;
+ for (int _i622 = 0; _i622 < _list620.size; ++_i622)
{
- _elem611 = iprot.readI64();
- struct.fileIds.add(_elem611);
+ _elem621 = iprot.readI64();
+ struct.fileIds.add(_elem621);
}
}
struct.setFileIdsIsSet(true);
{
- org.apache.thrift.protocol.TList _list613 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.metadata = new ArrayList<ByteBuffer>(_list613.size);
- ByteBuffer _elem614;
- for (int _i615 = 0; _i615 < _list613.size; ++_i615)
+ org.apache.thrift.protocol.TList _list623 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.metadata = new ArrayList<ByteBuffer>(_list623.size);
+ ByteBuffer _elem624;
+ for (int _i625 = 0; _i625 < _list623.size; ++_i625)
{
- _elem614 = iprot.readBinary();
- struct.metadata.add(_elem614);
+ _elem624 = iprot.readBinary();
+ struct.metadata.add(_elem624);
}
}
struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/c57a5961/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
index 6641c7e..ed86165 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
@@ -354,14 +354,14 @@ public class ShowCompactResponse implements org.apache.thrift.TBase<ShowCompactR
case 1: // COMPACTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list524 = iprot.readListBegin();
- struct.compacts = new ArrayList<ShowCompactResponseElement>(_list524.size);
- ShowCompactResponseElement _elem525;
- for (int _i526 = 0; _i526 < _list524.size; ++_i526)
+ org.apache.thrift.protocol.TList _list534 = iprot.readListBegin();
+ struct.compacts = new ArrayList<ShowCompactResponseElement>(_list534.size);
+ ShowCompactResponseElement _elem535;
+ for (int _i536 = 0; _i536 < _list534.size; ++_i536)
{
- _elem525 = new ShowCompactResponseElement();
- _elem525.read(iprot);
- struct.compacts.add(_elem525);
+ _elem535 = new ShowCompactResponseElement();
+ _elem535.read(iprot);
+ struct.compacts.add(_elem535);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ public class ShowCompactResponse implements org.apache.thrift.TBase<ShowCompactR
oprot.writeFieldBegin(COMPACTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.compacts.size()));
- for (ShowCompactResponseElement _iter527 : struct.compacts)
+ for (ShowCompactResponseElement _iter537 : struct.compacts)
{
- _iter527.write(oprot);
+ _iter537.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ public class ShowCompactResponse implements org.apache.thrift.TBase<ShowCompactR
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.compacts.size());
- for (ShowCompactResponseElement _iter528 : struct.compacts)
+ for (ShowCompactResponseElement _iter538 : struct.compacts)
{
- _iter528.write(oprot);
+ _iter538.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ public class ShowCompactResponse implements org.apache.thrift.TBase<ShowCompactR
public void read(org.apache.thrift.protocol.TProtocol prot, ShowCompactResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list529 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.compacts = new ArrayList<ShowCompactResponseElement>(_list529.size);
- ShowCompactResponseElement _elem530;
- for (int _i531 = 0; _i531 < _list529.size; ++_i531)
+ org.apache.thrift.protocol.TList _list539 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.compacts = new ArrayList<ShowCompactResponseElement>(_list539.size);
+ ShowCompactResponseElement _elem540;
+ for (int _i541 = 0; _i541 < _list539.size; ++_i541)
{
- _elem530 = new ShowCompactResponseElement();
- _elem530.read(iprot);
- struct.compacts.add(_elem530);
+ _elem540 = new ShowCompactResponseElement();
+ _elem540.read(iprot);
+ struct.compacts.add(_elem540);
}
}
struct.setCompactsIsSet(true);