http://git-wip-us.apache.org/repos/asf/hive/blob/10cfba20/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java index 70690a4..3ef2431 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java @@ -636,13 +636,13 @@ import org.slf4j.LoggerFactory; case 2: // FILES_ADDED if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list740 = iprot.readListBegin(); - struct.filesAdded = new ArrayList<String>(_list740.size); - String _elem741; - for (int _i742 = 0; _i742 < _list740.size; ++_i742) + org.apache.thrift.protocol.TList _list748 = iprot.readListBegin(); + struct.filesAdded = new ArrayList<String>(_list748.size); + String _elem749; + for (int _i750 = 0; _i750 < _list748.size; ++_i750) { - _elem741 = iprot.readString(); - struct.filesAdded.add(_elem741); + _elem749 = iprot.readString(); + struct.filesAdded.add(_elem749); } iprot.readListEnd(); } @@ -654,13 +654,13 @@ import org.slf4j.LoggerFactory; case 3: // FILES_ADDED_CHECKSUM if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list743 = iprot.readListBegin(); - struct.filesAddedChecksum = new ArrayList<String>(_list743.size); - String _elem744; - for (int _i745 = 0; _i745 < _list743.size; ++_i745) + org.apache.thrift.protocol.TList _list751 = iprot.readListBegin(); + struct.filesAddedChecksum = new ArrayList<String>(_list751.size); + String _elem752; + for (int _i753 = 0; _i753 < _list751.size; ++_i753) { - _elem744 = iprot.readString(); - struct.filesAddedChecksum.add(_elem744); + _elem752 = iprot.readString(); + struct.filesAddedChecksum.add(_elem752); } iprot.readListEnd(); } @@ -672,13 +672,13 @@ import org.slf4j.LoggerFactory; case 4: // SUB_DIRECTORY_LIST if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list746 = iprot.readListBegin(); - struct.subDirectoryList = new ArrayList<String>(_list746.size); - String _elem747; - for (int _i748 = 0; _i748 < _list746.size; ++_i748) + org.apache.thrift.protocol.TList _list754 = iprot.readListBegin(); + struct.subDirectoryList = new ArrayList<String>(_list754.size); + String _elem755; + for (int _i756 = 0; _i756 < _list754.size; ++_i756) { - _elem747 = iprot.readString(); - struct.subDirectoryList.add(_elem747); + _elem755 = iprot.readString(); + struct.subDirectoryList.add(_elem755); } iprot.readListEnd(); } @@ -709,9 +709,9 @@ import org.slf4j.LoggerFactory; 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 _iter749 : struct.filesAdded) + for (String _iter757 : struct.filesAdded) { - oprot.writeString(_iter749); + oprot.writeString(_iter757); } oprot.writeListEnd(); } @@ -722,9 +722,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(FILES_ADDED_CHECKSUM_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.filesAddedChecksum.size())); - for (String _iter750 : struct.filesAddedChecksum) + for (String _iter758 : struct.filesAddedChecksum) { - oprot.writeString(_iter750); + oprot.writeString(_iter758); } oprot.writeListEnd(); } @@ -736,9 +736,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(SUB_DIRECTORY_LIST_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.subDirectoryList.size())); - for (String _iter751 : struct.subDirectoryList) + for (String _iter759 : struct.subDirectoryList) { - oprot.writeString(_iter751); + oprot.writeString(_iter759); } oprot.writeListEnd(); } @@ -764,9 +764,9 @@ import org.slf4j.LoggerFactory; TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.filesAdded.size()); - for (String _iter752 : struct.filesAdded) + for (String _iter760 : struct.filesAdded) { - oprot.writeString(_iter752); + oprot.writeString(_iter760); } } BitSet optionals = new BitSet(); @@ -786,18 +786,18 @@ import org.slf4j.LoggerFactory; if (struct.isSetFilesAddedChecksum()) { { oprot.writeI32(struct.filesAddedChecksum.size()); - for (String _iter753 : struct.filesAddedChecksum) + for (String _iter761 : struct.filesAddedChecksum) { - oprot.writeString(_iter753); + oprot.writeString(_iter761); } } } if (struct.isSetSubDirectoryList()) { { oprot.writeI32(struct.subDirectoryList.size()); - for (String _iter754 : struct.subDirectoryList) + for (String _iter762 : struct.subDirectoryList) { - oprot.writeString(_iter754); + oprot.writeString(_iter762); } } } @@ -807,13 +807,13 @@ import org.slf4j.LoggerFactory; 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 _list755 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.filesAdded = new ArrayList<String>(_list755.size); - String _elem756; - for (int _i757 = 0; _i757 < _list755.size; ++_i757) + org.apache.thrift.protocol.TList _list763 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.filesAdded = new ArrayList<String>(_list763.size); + String _elem764; + for (int _i765 = 0; _i765 < _list763.size; ++_i765) { - _elem756 = iprot.readString(); - struct.filesAdded.add(_elem756); + _elem764 = iprot.readString(); + struct.filesAdded.add(_elem764); } } struct.setFilesAddedIsSet(true); @@ -824,26 +824,26 @@ import org.slf4j.LoggerFactory; } if (incoming.get(1)) { { - org.apache.thrift.protocol.TList _list758 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.filesAddedChecksum = new ArrayList<String>(_list758.size); - String _elem759; - for (int _i760 = 0; _i760 < _list758.size; ++_i760) + org.apache.thrift.protocol.TList _list766 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.filesAddedChecksum = new ArrayList<String>(_list766.size); + String _elem767; + for (int _i768 = 0; _i768 < _list766.size; ++_i768) { - _elem759 = iprot.readString(); - struct.filesAddedChecksum.add(_elem759); + _elem767 = iprot.readString(); + struct.filesAddedChecksum.add(_elem767); } } struct.setFilesAddedChecksumIsSet(true); } if (incoming.get(2)) { { - org.apache.thrift.protocol.TList _list761 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.subDirectoryList = new ArrayList<String>(_list761.size); - String _elem762; - for (int _i763 = 0; _i763 < _list761.size; ++_i763) + org.apache.thrift.protocol.TList _list769 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.subDirectoryList = new ArrayList<String>(_list769.size); + String _elem770; + for (int _i771 = 0; _i771 < _list769.size; ++_i771) { - _elem762 = iprot.readString(); - struct.subDirectoryList.add(_elem762); + _elem770 = iprot.readString(); + struct.subDirectoryList.add(_elem770); } } struct.setSubDirectoryListIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/10cfba20/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java index cabed5a..663f7d0 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java @@ -689,14 +689,14 @@ import org.slf4j.LoggerFactory; case 1: // COMPONENT if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list666 = iprot.readListBegin(); - struct.component = new ArrayList<LockComponent>(_list666.size); - LockComponent _elem667; - for (int _i668 = 0; _i668 < _list666.size; ++_i668) + org.apache.thrift.protocol.TList _list674 = iprot.readListBegin(); + struct.component = new ArrayList<LockComponent>(_list674.size); + LockComponent _elem675; + for (int _i676 = 0; _i676 < _list674.size; ++_i676) { - _elem667 = new LockComponent(); - _elem667.read(iprot); - struct.component.add(_elem667); + _elem675 = new LockComponent(); + _elem675.read(iprot); + struct.component.add(_elem675); } iprot.readListEnd(); } @@ -754,9 +754,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(COMPONENT_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.component.size())); - for (LockComponent _iter669 : struct.component) + for (LockComponent _iter677 : struct.component) { - _iter669.write(oprot); + _iter677.write(oprot); } oprot.writeListEnd(); } @@ -803,9 +803,9 @@ import org.slf4j.LoggerFactory; TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.component.size()); - for (LockComponent _iter670 : struct.component) + for (LockComponent _iter678 : struct.component) { - _iter670.write(oprot); + _iter678.write(oprot); } } oprot.writeString(struct.user); @@ -830,14 +830,14 @@ import org.slf4j.LoggerFactory; public void read(org.apache.thrift.protocol.TProtocol prot, LockRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list671 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.component = new ArrayList<LockComponent>(_list671.size); - LockComponent _elem672; - for (int _i673 = 0; _i673 < _list671.size; ++_i673) + org.apache.thrift.protocol.TList _list679 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.component = new ArrayList<LockComponent>(_list679.size); + LockComponent _elem680; + for (int _i681 = 0; _i681 < _list679.size; ++_i681) { - _elem672 = new LockComponent(); - _elem672.read(iprot); - struct.component.add(_elem672); + _elem680 = new LockComponent(); + _elem680.read(iprot); + struct.component.add(_elem680); } } struct.setComponentIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/10cfba20/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java index e86c9f6..f559a03 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java @@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory; case 1: // EVENTS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list732 = iprot.readListBegin(); - struct.events = new ArrayList<NotificationEvent>(_list732.size); - NotificationEvent _elem733; - for (int _i734 = 0; _i734 < _list732.size; ++_i734) + org.apache.thrift.protocol.TList _list740 = iprot.readListBegin(); + struct.events = new ArrayList<NotificationEvent>(_list740.size); + NotificationEvent _elem741; + for (int _i742 = 0; _i742 < _list740.size; ++_i742) { - _elem733 = new NotificationEvent(); - _elem733.read(iprot); - struct.events.add(_elem733); + _elem741 = new NotificationEvent(); + _elem741.read(iprot); + struct.events.add(_elem741); } iprot.readListEnd(); } @@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(EVENTS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.events.size())); - for (NotificationEvent _iter735 : struct.events) + for (NotificationEvent _iter743 : struct.events) { - _iter735.write(oprot); + _iter743.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory; TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.events.size()); - for (NotificationEvent _iter736 : struct.events) + for (NotificationEvent _iter744 : struct.events) { - _iter736.write(oprot); + _iter744.write(oprot); } } } @@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory; 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 _list737 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.events = new ArrayList<NotificationEvent>(_list737.size); - NotificationEvent _elem738; - for (int _i739 = 0; _i739 < _list737.size; ++_i739) + org.apache.thrift.protocol.TList _list745 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.events = new ArrayList<NotificationEvent>(_list745.size); + NotificationEvent _elem746; + for (int _i747 = 0; _i747 < _list745.size; ++_i747) { - _elem738 = new NotificationEvent(); - _elem738.read(iprot); - struct.events.add(_elem738); + _elem746 = new NotificationEvent(); + _elem746.read(iprot); + struct.events.add(_elem746); } } struct.setEventsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/10cfba20/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java index e19034c..0bbb9be 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java @@ -547,13 +547,13 @@ import org.slf4j.LoggerFactory; case 1: // FILE_IDS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list816 = iprot.readListBegin(); - struct.fileIds = new ArrayList<Long>(_list816.size); - long _elem817; - for (int _i818 = 0; _i818 < _list816.size; ++_i818) + org.apache.thrift.protocol.TList _list824 = iprot.readListBegin(); + struct.fileIds = new ArrayList<Long>(_list824.size); + long _elem825; + for (int _i826 = 0; _i826 < _list824.size; ++_i826) { - _elem817 = iprot.readI64(); - struct.fileIds.add(_elem817); + _elem825 = iprot.readI64(); + struct.fileIds.add(_elem825); } iprot.readListEnd(); } @@ -565,13 +565,13 @@ import org.slf4j.LoggerFactory; case 2: // METADATA if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list819 = iprot.readListBegin(); - struct.metadata = new ArrayList<ByteBuffer>(_list819.size); - ByteBuffer _elem820; - for (int _i821 = 0; _i821 < _list819.size; ++_i821) + org.apache.thrift.protocol.TList _list827 = iprot.readListBegin(); + struct.metadata = new ArrayList<ByteBuffer>(_list827.size); + ByteBuffer _elem828; + for (int _i829 = 0; _i829 < _list827.size; ++_i829) { - _elem820 = iprot.readBinary(); - struct.metadata.add(_elem820); + _elem828 = iprot.readBinary(); + struct.metadata.add(_elem828); } iprot.readListEnd(); } @@ -605,9 +605,9 @@ import org.slf4j.LoggerFactory; 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 _iter822 : struct.fileIds) + for (long _iter830 : struct.fileIds) { - oprot.writeI64(_iter822); + oprot.writeI64(_iter830); } oprot.writeListEnd(); } @@ -617,9 +617,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(METADATA_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.metadata.size())); - for (ByteBuffer _iter823 : struct.metadata) + for (ByteBuffer _iter831 : struct.metadata) { - oprot.writeBinary(_iter823); + oprot.writeBinary(_iter831); } oprot.writeListEnd(); } @@ -651,16 +651,16 @@ import org.slf4j.LoggerFactory; TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.fileIds.size()); - for (long _iter824 : struct.fileIds) + for (long _iter832 : struct.fileIds) { - oprot.writeI64(_iter824); + oprot.writeI64(_iter832); } } { oprot.writeI32(struct.metadata.size()); - for (ByteBuffer _iter825 : struct.metadata) + for (ByteBuffer _iter833 : struct.metadata) { - oprot.writeBinary(_iter825); + oprot.writeBinary(_iter833); } } BitSet optionals = new BitSet(); @@ -677,24 +677,24 @@ import org.slf4j.LoggerFactory; 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 _list826 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.fileIds = new ArrayList<Long>(_list826.size); - long _elem827; - for (int _i828 = 0; _i828 < _list826.size; ++_i828) + org.apache.thrift.protocol.TList _list834 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.fileIds = new ArrayList<Long>(_list834.size); + long _elem835; + for (int _i836 = 0; _i836 < _list834.size; ++_i836) { - _elem827 = iprot.readI64(); - struct.fileIds.add(_elem827); + _elem835 = iprot.readI64(); + struct.fileIds.add(_elem835); } } struct.setFileIdsIsSet(true); { - org.apache.thrift.protocol.TList _list829 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.metadata = new ArrayList<ByteBuffer>(_list829.size); - ByteBuffer _elem830; - for (int _i831 = 0; _i831 < _list829.size; ++_i831) + org.apache.thrift.protocol.TList _list837 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.metadata = new ArrayList<ByteBuffer>(_list837.size); + ByteBuffer _elem838; + for (int _i839 = 0; _i839 < _list837.size; ++_i839) { - _elem830 = iprot.readBinary(); - struct.metadata.add(_elem830); + _elem838 = iprot.readBinary(); + struct.metadata.add(_elem838); } } struct.setMetadataIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/10cfba20/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RenamePartitionRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RenamePartitionRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RenamePartitionRequest.java index 3540e99..0a0393f 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RenamePartitionRequest.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RenamePartitionRequest.java @@ -796,13 +796,13 @@ import org.slf4j.LoggerFactory; case 4: // PART_VALS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list960 = iprot.readListBegin(); - struct.partVals = new ArrayList<String>(_list960.size); - String _elem961; - for (int _i962 = 0; _i962 < _list960.size; ++_i962) + org.apache.thrift.protocol.TList _list968 = iprot.readListBegin(); + struct.partVals = new ArrayList<String>(_list968.size); + String _elem969; + for (int _i970 = 0; _i970 < _list968.size; ++_i970) { - _elem961 = iprot.readString(); - struct.partVals.add(_elem961); + _elem969 = iprot.readString(); + struct.partVals.add(_elem969); } iprot.readListEnd(); } @@ -862,9 +862,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(PART_VALS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partVals.size())); - for (String _iter963 : struct.partVals) + for (String _iter971 : struct.partVals) { - oprot.writeString(_iter963); + oprot.writeString(_iter971); } oprot.writeListEnd(); } @@ -903,9 +903,9 @@ import org.slf4j.LoggerFactory; oprot.writeString(struct.tableName); { oprot.writeI32(struct.partVals.size()); - for (String _iter964 : struct.partVals) + for (String _iter972 : struct.partVals) { - oprot.writeString(_iter964); + oprot.writeString(_iter972); } } struct.newPart.write(oprot); @@ -933,13 +933,13 @@ import org.slf4j.LoggerFactory; struct.tableName = iprot.readString(); struct.setTableNameIsSet(true); { - org.apache.thrift.protocol.TList _list965 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.partVals = new ArrayList<String>(_list965.size); - String _elem966; - for (int _i967 = 0; _i967 < _list965.size; ++_i967) + org.apache.thrift.protocol.TList _list973 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.partVals = new ArrayList<String>(_list973.size); + String _elem974; + for (int _i975 = 0; _i975 < _list973.size; ++_i975) { - _elem966 = iprot.readString(); - struct.partVals.add(_elem966); + _elem974 = iprot.readString(); + struct.partVals.add(_elem974); } } struct.setPartValsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/10cfba20/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplLastIdInfo.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplLastIdInfo.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplLastIdInfo.java new file mode 100644 index 0000000..4e317d5 --- /dev/null +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplLastIdInfo.java @@ -0,0 +1,958 @@ +/** + * Autogenerated by Thrift Compiler (0.9.3) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.hadoop.hive.metastore.api; + +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; +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 javax.annotation.Generated; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)") +@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class ReplLastIdInfo implements org.apache.thrift.TBase<ReplLastIdInfo, ReplLastIdInfo._Fields>, java.io.Serializable, Cloneable, Comparable<ReplLastIdInfo> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ReplLastIdInfo"); + + private static final org.apache.thrift.protocol.TField DATABASE_FIELD_DESC = new org.apache.thrift.protocol.TField("database", org.apache.thrift.protocol.TType.STRING, (short)1); + private static final org.apache.thrift.protocol.TField LAST_REPL_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("lastReplId", org.apache.thrift.protocol.TType.I64, (short)2); + private static final org.apache.thrift.protocol.TField TABLE_FIELD_DESC = new org.apache.thrift.protocol.TField("table", org.apache.thrift.protocol.TType.STRING, (short)3); + private static final org.apache.thrift.protocol.TField CATALOG_FIELD_DESC = new org.apache.thrift.protocol.TField("catalog", org.apache.thrift.protocol.TType.STRING, (short)4); + private static final org.apache.thrift.protocol.TField PARTITION_LIST_FIELD_DESC = new org.apache.thrift.protocol.TField("partitionList", org.apache.thrift.protocol.TType.LIST, (short)5); + private static final org.apache.thrift.protocol.TField NEED_UPDATE_DBREPL_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("needUpdateDBReplId", org.apache.thrift.protocol.TType.BOOL, (short)6); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new ReplLastIdInfoStandardSchemeFactory()); + schemes.put(TupleScheme.class, new ReplLastIdInfoTupleSchemeFactory()); + } + + private String database; // required + private long lastReplId; // required + private String table; // optional + private String catalog; // optional + private List<String> partitionList; // optional + private boolean needUpdateDBReplId; // 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 { + DATABASE((short)1, "database"), + LAST_REPL_ID((short)2, "lastReplId"), + TABLE((short)3, "table"), + CATALOG((short)4, "catalog"), + PARTITION_LIST((short)5, "partitionList"), + NEED_UPDATE_DBREPL_ID((short)6, "needUpdateDBReplId"); + + 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: // DATABASE + return DATABASE; + case 2: // LAST_REPL_ID + return LAST_REPL_ID; + case 3: // TABLE + return TABLE; + case 4: // CATALOG + return CATALOG; + case 5: // PARTITION_LIST + return PARTITION_LIST; + case 6: // NEED_UPDATE_DBREPL_ID + return NEED_UPDATE_DBREPL_ID; + 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 + private static final int __LASTREPLID_ISSET_ID = 0; + private static final int __NEEDUPDATEDBREPLID_ISSET_ID = 1; + private byte __isset_bitfield = 0; + private static final _Fields optionals[] = {_Fields.TABLE,_Fields.CATALOG,_Fields.PARTITION_LIST,_Fields.NEED_UPDATE_DBREPL_ID}; + 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); + tmpMap.put(_Fields.DATABASE, new org.apache.thrift.meta_data.FieldMetaData("database", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.LAST_REPL_ID, new org.apache.thrift.meta_data.FieldMetaData("lastReplId", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + tmpMap.put(_Fields.TABLE, new org.apache.thrift.meta_data.FieldMetaData("table", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.CATALOG, new org.apache.thrift.meta_data.FieldMetaData("catalog", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.PARTITION_LIST, new org.apache.thrift.meta_data.FieldMetaData("partitionList", 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)))); + tmpMap.put(_Fields.NEED_UPDATE_DBREPL_ID, new org.apache.thrift.meta_data.FieldMetaData("needUpdateDBReplId", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ReplLastIdInfo.class, metaDataMap); + } + + public ReplLastIdInfo() { + } + + public ReplLastIdInfo( + String database, + long lastReplId) + { + this(); + this.database = database; + this.lastReplId = lastReplId; + setLastReplIdIsSet(true); + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public ReplLastIdInfo(ReplLastIdInfo other) { + __isset_bitfield = other.__isset_bitfield; + if (other.isSetDatabase()) { + this.database = other.database; + } + this.lastReplId = other.lastReplId; + if (other.isSetTable()) { + this.table = other.table; + } + if (other.isSetCatalog()) { + this.catalog = other.catalog; + } + if (other.isSetPartitionList()) { + List<String> __this__partitionList = new ArrayList<String>(other.partitionList); + this.partitionList = __this__partitionList; + } + this.needUpdateDBReplId = other.needUpdateDBReplId; + } + + public ReplLastIdInfo deepCopy() { + return new ReplLastIdInfo(this); + } + + @Override + public void clear() { + this.database = null; + setLastReplIdIsSet(false); + this.lastReplId = 0; + this.table = null; + this.catalog = null; + this.partitionList = null; + setNeedUpdateDBReplIdIsSet(false); + this.needUpdateDBReplId = false; + } + + public String getDatabase() { + return this.database; + } + + public void setDatabase(String database) { + this.database = database; + } + + public void unsetDatabase() { + this.database = null; + } + + /** Returns true if field database is set (has been assigned a value) and false otherwise */ + public boolean isSetDatabase() { + return this.database != null; + } + + public void setDatabaseIsSet(boolean value) { + if (!value) { + this.database = null; + } + } + + public long getLastReplId() { + return this.lastReplId; + } + + public void setLastReplId(long lastReplId) { + this.lastReplId = lastReplId; + setLastReplIdIsSet(true); + } + + public void unsetLastReplId() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __LASTREPLID_ISSET_ID); + } + + /** Returns true if field lastReplId is set (has been assigned a value) and false otherwise */ + public boolean isSetLastReplId() { + return EncodingUtils.testBit(__isset_bitfield, __LASTREPLID_ISSET_ID); + } + + public void setLastReplIdIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __LASTREPLID_ISSET_ID, value); + } + + public String getTable() { + return this.table; + } + + public void setTable(String table) { + this.table = table; + } + + public void unsetTable() { + this.table = null; + } + + /** Returns true if field table is set (has been assigned a value) and false otherwise */ + public boolean isSetTable() { + return this.table != null; + } + + public void setTableIsSet(boolean value) { + if (!value) { + this.table = null; + } + } + + public String getCatalog() { + return this.catalog; + } + + public void setCatalog(String catalog) { + this.catalog = catalog; + } + + public void unsetCatalog() { + this.catalog = null; + } + + /** Returns true if field catalog is set (has been assigned a value) and false otherwise */ + public boolean isSetCatalog() { + return this.catalog != null; + } + + public void setCatalogIsSet(boolean value) { + if (!value) { + this.catalog = null; + } + } + + public int getPartitionListSize() { + return (this.partitionList == null) ? 0 : this.partitionList.size(); + } + + public java.util.Iterator<String> getPartitionListIterator() { + return (this.partitionList == null) ? null : this.partitionList.iterator(); + } + + public void addToPartitionList(String elem) { + if (this.partitionList == null) { + this.partitionList = new ArrayList<String>(); + } + this.partitionList.add(elem); + } + + public List<String> getPartitionList() { + return this.partitionList; + } + + public void setPartitionList(List<String> partitionList) { + this.partitionList = partitionList; + } + + public void unsetPartitionList() { + this.partitionList = null; + } + + /** Returns true if field partitionList is set (has been assigned a value) and false otherwise */ + public boolean isSetPartitionList() { + return this.partitionList != null; + } + + public void setPartitionListIsSet(boolean value) { + if (!value) { + this.partitionList = null; + } + } + + public boolean isNeedUpdateDBReplId() { + return this.needUpdateDBReplId; + } + + public void setNeedUpdateDBReplId(boolean needUpdateDBReplId) { + this.needUpdateDBReplId = needUpdateDBReplId; + setNeedUpdateDBReplIdIsSet(true); + } + + public void unsetNeedUpdateDBReplId() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NEEDUPDATEDBREPLID_ISSET_ID); + } + + /** Returns true if field needUpdateDBReplId is set (has been assigned a value) and false otherwise */ + public boolean isSetNeedUpdateDBReplId() { + return EncodingUtils.testBit(__isset_bitfield, __NEEDUPDATEDBREPLID_ISSET_ID); + } + + public void setNeedUpdateDBReplIdIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NEEDUPDATEDBREPLID_ISSET_ID, value); + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case DATABASE: + if (value == null) { + unsetDatabase(); + } else { + setDatabase((String)value); + } + break; + + case LAST_REPL_ID: + if (value == null) { + unsetLastReplId(); + } else { + setLastReplId((Long)value); + } + break; + + case TABLE: + if (value == null) { + unsetTable(); + } else { + setTable((String)value); + } + break; + + case CATALOG: + if (value == null) { + unsetCatalog(); + } else { + setCatalog((String)value); + } + break; + + case PARTITION_LIST: + if (value == null) { + unsetPartitionList(); + } else { + setPartitionList((List<String>)value); + } + break; + + case NEED_UPDATE_DBREPL_ID: + if (value == null) { + unsetNeedUpdateDBReplId(); + } else { + setNeedUpdateDBReplId((Boolean)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case DATABASE: + return getDatabase(); + + case LAST_REPL_ID: + return getLastReplId(); + + case TABLE: + return getTable(); + + case CATALOG: + return getCatalog(); + + case PARTITION_LIST: + return getPartitionList(); + + case NEED_UPDATE_DBREPL_ID: + return isNeedUpdateDBReplId(); + + } + 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 DATABASE: + return isSetDatabase(); + case LAST_REPL_ID: + return isSetLastReplId(); + case TABLE: + return isSetTable(); + case CATALOG: + return isSetCatalog(); + case PARTITION_LIST: + return isSetPartitionList(); + case NEED_UPDATE_DBREPL_ID: + return isSetNeedUpdateDBReplId(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof ReplLastIdInfo) + return this.equals((ReplLastIdInfo)that); + return false; + } + + public boolean equals(ReplLastIdInfo that) { + if (that == null) + return false; + + boolean this_present_database = true && this.isSetDatabase(); + boolean that_present_database = true && that.isSetDatabase(); + if (this_present_database || that_present_database) { + if (!(this_present_database && that_present_database)) + return false; + if (!this.database.equals(that.database)) + return false; + } + + boolean this_present_lastReplId = true; + boolean that_present_lastReplId = true; + if (this_present_lastReplId || that_present_lastReplId) { + if (!(this_present_lastReplId && that_present_lastReplId)) + return false; + if (this.lastReplId != that.lastReplId) + return false; + } + + boolean this_present_table = true && this.isSetTable(); + boolean that_present_table = true && that.isSetTable(); + if (this_present_table || that_present_table) { + if (!(this_present_table && that_present_table)) + return false; + if (!this.table.equals(that.table)) + return false; + } + + boolean this_present_catalog = true && this.isSetCatalog(); + boolean that_present_catalog = true && that.isSetCatalog(); + if (this_present_catalog || that_present_catalog) { + if (!(this_present_catalog && that_present_catalog)) + return false; + if (!this.catalog.equals(that.catalog)) + return false; + } + + boolean this_present_partitionList = true && this.isSetPartitionList(); + boolean that_present_partitionList = true && that.isSetPartitionList(); + if (this_present_partitionList || that_present_partitionList) { + if (!(this_present_partitionList && that_present_partitionList)) + return false; + if (!this.partitionList.equals(that.partitionList)) + return false; + } + + boolean this_present_needUpdateDBReplId = true && this.isSetNeedUpdateDBReplId(); + boolean that_present_needUpdateDBReplId = true && that.isSetNeedUpdateDBReplId(); + if (this_present_needUpdateDBReplId || that_present_needUpdateDBReplId) { + if (!(this_present_needUpdateDBReplId && that_present_needUpdateDBReplId)) + return false; + if (this.needUpdateDBReplId != that.needUpdateDBReplId) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_database = true && (isSetDatabase()); + list.add(present_database); + if (present_database) + list.add(database); + + boolean present_lastReplId = true; + list.add(present_lastReplId); + if (present_lastReplId) + list.add(lastReplId); + + boolean present_table = true && (isSetTable()); + list.add(present_table); + if (present_table) + list.add(table); + + boolean present_catalog = true && (isSetCatalog()); + list.add(present_catalog); + if (present_catalog) + list.add(catalog); + + boolean present_partitionList = true && (isSetPartitionList()); + list.add(present_partitionList); + if (present_partitionList) + list.add(partitionList); + + boolean present_needUpdateDBReplId = true && (isSetNeedUpdateDBReplId()); + list.add(present_needUpdateDBReplId); + if (present_needUpdateDBReplId) + list.add(needUpdateDBReplId); + + return list.hashCode(); + } + + @Override + public int compareTo(ReplLastIdInfo other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetDatabase()).compareTo(other.isSetDatabase()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetDatabase()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.database, other.database); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetLastReplId()).compareTo(other.isSetLastReplId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetLastReplId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.lastReplId, other.lastReplId); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetTable()).compareTo(other.isSetTable()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTable()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.table, other.table); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetCatalog()).compareTo(other.isSetCatalog()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetCatalog()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.catalog, other.catalog); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetPartitionList()).compareTo(other.isSetPartitionList()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetPartitionList()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partitionList, other.partitionList); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetNeedUpdateDBReplId()).compareTo(other.isSetNeedUpdateDBReplId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetNeedUpdateDBReplId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.needUpdateDBReplId, other.needUpdateDBReplId); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("ReplLastIdInfo("); + boolean first = true; + + sb.append("database:"); + if (this.database == null) { + sb.append("null"); + } else { + sb.append(this.database); + } + first = false; + if (!first) sb.append(", "); + sb.append("lastReplId:"); + sb.append(this.lastReplId); + first = false; + if (isSetTable()) { + if (!first) sb.append(", "); + sb.append("table:"); + if (this.table == null) { + sb.append("null"); + } else { + sb.append(this.table); + } + first = false; + } + if (isSetCatalog()) { + if (!first) sb.append(", "); + sb.append("catalog:"); + if (this.catalog == null) { + sb.append("null"); + } else { + sb.append(this.catalog); + } + first = false; + } + if (isSetPartitionList()) { + if (!first) sb.append(", "); + sb.append("partitionList:"); + if (this.partitionList == null) { + sb.append("null"); + } else { + sb.append(this.partitionList); + } + first = false; + } + if (isSetNeedUpdateDBReplId()) { + if (!first) sb.append(", "); + sb.append("needUpdateDBReplId:"); + sb.append(this.needUpdateDBReplId); + first = false; + } + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetDatabase()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'database' is unset! Struct:" + toString()); + } + + if (!isSetLastReplId()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'lastReplId' is unset! Struct:" + toString()); + } + + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. + __isset_bitfield = 0; + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class ReplLastIdInfoStandardSchemeFactory implements SchemeFactory { + public ReplLastIdInfoStandardScheme getScheme() { + return new ReplLastIdInfoStandardScheme(); + } + } + + private static class ReplLastIdInfoStandardScheme extends StandardScheme<ReplLastIdInfo> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, ReplLastIdInfo struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // DATABASE + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.database = iprot.readString(); + struct.setDatabaseIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // LAST_REPL_ID + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.lastReplId = iprot.readI64(); + struct.setLastReplIdIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // TABLE + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.table = iprot.readString(); + struct.setTableIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // CATALOG + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.catalog = iprot.readString(); + struct.setCatalogIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 5: // PARTITION_LIST + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list610 = iprot.readListBegin(); + struct.partitionList = new ArrayList<String>(_list610.size); + String _elem611; + for (int _i612 = 0; _i612 < _list610.size; ++_i612) + { + _elem611 = iprot.readString(); + struct.partitionList.add(_elem611); + } + iprot.readListEnd(); + } + struct.setPartitionListIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 6: // NEED_UPDATE_DBREPL_ID + if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) { + struct.needUpdateDBReplId = iprot.readBool(); + struct.setNeedUpdateDBReplIdIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, ReplLastIdInfo struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.database != null) { + oprot.writeFieldBegin(DATABASE_FIELD_DESC); + oprot.writeString(struct.database); + oprot.writeFieldEnd(); + } + oprot.writeFieldBegin(LAST_REPL_ID_FIELD_DESC); + oprot.writeI64(struct.lastReplId); + oprot.writeFieldEnd(); + if (struct.table != null) { + if (struct.isSetTable()) { + oprot.writeFieldBegin(TABLE_FIELD_DESC); + oprot.writeString(struct.table); + oprot.writeFieldEnd(); + } + } + if (struct.catalog != null) { + if (struct.isSetCatalog()) { + oprot.writeFieldBegin(CATALOG_FIELD_DESC); + oprot.writeString(struct.catalog); + oprot.writeFieldEnd(); + } + } + if (struct.partitionList != null) { + if (struct.isSetPartitionList()) { + oprot.writeFieldBegin(PARTITION_LIST_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partitionList.size())); + for (String _iter613 : struct.partitionList) + { + oprot.writeString(_iter613); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + } + if (struct.isSetNeedUpdateDBReplId()) { + oprot.writeFieldBegin(NEED_UPDATE_DBREPL_ID_FIELD_DESC); + oprot.writeBool(struct.needUpdateDBReplId); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class ReplLastIdInfoTupleSchemeFactory implements SchemeFactory { + public ReplLastIdInfoTupleScheme getScheme() { + return new ReplLastIdInfoTupleScheme(); + } + } + + private static class ReplLastIdInfoTupleScheme extends TupleScheme<ReplLastIdInfo> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, ReplLastIdInfo struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + oprot.writeString(struct.database); + oprot.writeI64(struct.lastReplId); + BitSet optionals = new BitSet(); + if (struct.isSetTable()) { + optionals.set(0); + } + if (struct.isSetCatalog()) { + optionals.set(1); + } + if (struct.isSetPartitionList()) { + optionals.set(2); + } + if (struct.isSetNeedUpdateDBReplId()) { + optionals.set(3); + } + oprot.writeBitSet(optionals, 4); + if (struct.isSetTable()) { + oprot.writeString(struct.table); + } + if (struct.isSetCatalog()) { + oprot.writeString(struct.catalog); + } + if (struct.isSetPartitionList()) { + { + oprot.writeI32(struct.partitionList.size()); + for (String _iter614 : struct.partitionList) + { + oprot.writeString(_iter614); + } + } + } + if (struct.isSetNeedUpdateDBReplId()) { + oprot.writeBool(struct.needUpdateDBReplId); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, ReplLastIdInfo struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + struct.database = iprot.readString(); + struct.setDatabaseIsSet(true); + struct.lastReplId = iprot.readI64(); + struct.setLastReplIdIsSet(true); + BitSet incoming = iprot.readBitSet(4); + if (incoming.get(0)) { + struct.table = iprot.readString(); + struct.setTableIsSet(true); + } + if (incoming.get(1)) { + struct.catalog = iprot.readString(); + struct.setCatalogIsSet(true); + } + if (incoming.get(2)) { + { + org.apache.thrift.protocol.TList _list615 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.partitionList = new ArrayList<String>(_list615.size); + String _elem616; + for (int _i617 = 0; _i617 < _list615.size; ++_i617) + { + _elem616 = iprot.readString(); + struct.partitionList.add(_elem616); + } + } + struct.setPartitionListIsSet(true); + } + if (incoming.get(3)) { + struct.needUpdateDBReplId = iprot.readBool(); + struct.setNeedUpdateDBReplIdIsSet(true); + } + } + } + +} + http://git-wip-us.apache.org/repos/asf/hive/blob/10cfba20/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java index f637d51..0fa8067 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java @@ -813,13 +813,13 @@ import org.slf4j.LoggerFactory; case 6: // PART_NAMES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list610 = iprot.readListBegin(); - struct.partNames = new ArrayList<String>(_list610.size); - String _elem611; - for (int _i612 = 0; _i612 < _list610.size; ++_i612) + org.apache.thrift.protocol.TList _list618 = iprot.readListBegin(); + struct.partNames = new ArrayList<String>(_list618.size); + String _elem619; + for (int _i620 = 0; _i620 < _list618.size; ++_i620) { - _elem611 = iprot.readString(); - struct.partNames.add(_elem611); + _elem619 = iprot.readString(); + struct.partNames.add(_elem619); } iprot.readListEnd(); } @@ -871,9 +871,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(PART_NAMES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partNames.size())); - for (String _iter613 : struct.partNames) + for (String _iter621 : struct.partNames) { - oprot.writeString(_iter613); + oprot.writeString(_iter621); } oprot.writeListEnd(); } @@ -910,9 +910,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetPartNames()) { { oprot.writeI32(struct.partNames.size()); - for (String _iter614 : struct.partNames) + for (String _iter622 : struct.partNames) { - oprot.writeString(_iter614); + oprot.writeString(_iter622); } } } @@ -934,13 +934,13 @@ import org.slf4j.LoggerFactory; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list615 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.partNames = new ArrayList<String>(_list615.size); - String _elem616; - for (int _i617 = 0; _i617 < _list615.size; ++_i617) + org.apache.thrift.protocol.TList _list623 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.partNames = new ArrayList<String>(_list623.size); + String _elem624; + for (int _i625 = 0; _i625 < _list623.size; ++_i625) { - _elem616 = iprot.readString(); - struct.partNames.add(_elem616); + _elem624 = iprot.readString(); + struct.partNames.add(_elem624); } } struct.setPartNamesIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/10cfba20/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java index 88d7e3f..dd16932 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java @@ -1119,14 +1119,14 @@ import org.slf4j.LoggerFactory; case 4: // COLS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list936 = iprot.readListBegin(); - struct.cols = new ArrayList<FieldSchema>(_list936.size); - FieldSchema _elem937; - for (int _i938 = 0; _i938 < _list936.size; ++_i938) + org.apache.thrift.protocol.TList _list944 = iprot.readListBegin(); + struct.cols = new ArrayList<FieldSchema>(_list944.size); + FieldSchema _elem945; + for (int _i946 = 0; _i946 < _list944.size; ++_i946) { - _elem937 = new FieldSchema(); - _elem937.read(iprot); - struct.cols.add(_elem937); + _elem945 = new FieldSchema(); + _elem945.read(iprot); + struct.cols.add(_elem945); } iprot.readListEnd(); } @@ -1212,9 +1212,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(COLS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.cols.size())); - for (FieldSchema _iter939 : struct.cols) + for (FieldSchema _iter947 : struct.cols) { - _iter939.write(oprot); + _iter947.write(oprot); } oprot.writeListEnd(); } @@ -1323,9 +1323,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetCols()) { { oprot.writeI32(struct.cols.size()); - for (FieldSchema _iter940 : struct.cols) + for (FieldSchema _iter948 : struct.cols) { - _iter940.write(oprot); + _iter948.write(oprot); } } } @@ -1368,14 +1368,14 @@ import org.slf4j.LoggerFactory; } if (incoming.get(3)) { { - org.apache.thrift.protocol.TList _list941 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.cols = new ArrayList<FieldSchema>(_list941.size); - FieldSchema _elem942; - for (int _i943 = 0; _i943 < _list941.size; ++_i943) + org.apache.thrift.protocol.TList _list949 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.cols = new ArrayList<FieldSchema>(_list949.size); + FieldSchema _elem950; + for (int _i951 = 0; _i951 < _list949.size; ++_i951) { - _elem942 = new FieldSchema(); - _elem942.read(iprot); - struct.cols.add(_elem942); + _elem950 = new FieldSchema(); + _elem950.read(iprot); + struct.cols.add(_elem950); } } struct.setColsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/10cfba20/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java index c58885f..2a7b3eb 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java @@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory; case 1: // COMPACTS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list708 = iprot.readListBegin(); - struct.compacts = new ArrayList<ShowCompactResponseElement>(_list708.size); - ShowCompactResponseElement _elem709; - for (int _i710 = 0; _i710 < _list708.size; ++_i710) + org.apache.thrift.protocol.TList _list716 = iprot.readListBegin(); + struct.compacts = new ArrayList<ShowCompactResponseElement>(_list716.size); + ShowCompactResponseElement _elem717; + for (int _i718 = 0; _i718 < _list716.size; ++_i718) { - _elem709 = new ShowCompactResponseElement(); - _elem709.read(iprot); - struct.compacts.add(_elem709); + _elem717 = new ShowCompactResponseElement(); + _elem717.read(iprot); + struct.compacts.add(_elem717); } iprot.readListEnd(); } @@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(COMPACTS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.compacts.size())); - for (ShowCompactResponseElement _iter711 : struct.compacts) + for (ShowCompactResponseElement _iter719 : struct.compacts) { - _iter711.write(oprot); + _iter719.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory; TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.compacts.size()); - for (ShowCompactResponseElement _iter712 : struct.compacts) + for (ShowCompactResponseElement _iter720 : struct.compacts) { - _iter712.write(oprot); + _iter720.write(oprot); } } } @@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory; 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 _list713 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.compacts = new ArrayList<ShowCompactResponseElement>(_list713.size); - ShowCompactResponseElement _elem714; - for (int _i715 = 0; _i715 < _list713.size; ++_i715) + org.apache.thrift.protocol.TList _list721 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.compacts = new ArrayList<ShowCompactResponseElement>(_list721.size); + ShowCompactResponseElement _elem722; + for (int _i723 = 0; _i723 < _list721.size; ++_i723) { - _elem714 = new ShowCompactResponseElement(); - _elem714.read(iprot); - struct.compacts.add(_elem714); + _elem722 = new ShowCompactResponseElement(); + _elem722.read(iprot); + struct.compacts.add(_elem722); } } struct.setCompactsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/10cfba20/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java index 4bbc8e7..477bf67 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java @@ -350,14 +350,14 @@ import org.slf4j.LoggerFactory; case 1: // LOCKS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list674 = iprot.readListBegin(); - struct.locks = new ArrayList<ShowLocksResponseElement>(_list674.size); - ShowLocksResponseElement _elem675; - for (int _i676 = 0; _i676 < _list674.size; ++_i676) + org.apache.thrift.protocol.TList _list682 = iprot.readListBegin(); + struct.locks = new ArrayList<ShowLocksResponseElement>(_list682.size); + ShowLocksResponseElement _elem683; + for (int _i684 = 0; _i684 < _list682.size; ++_i684) { - _elem675 = new ShowLocksResponseElement(); - _elem675.read(iprot); - struct.locks.add(_elem675); + _elem683 = new ShowLocksResponseElement(); + _elem683.read(iprot); + struct.locks.add(_elem683); } iprot.readListEnd(); } @@ -383,9 +383,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(LOCKS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.locks.size())); - for (ShowLocksResponseElement _iter677 : struct.locks) + for (ShowLocksResponseElement _iter685 : struct.locks) { - _iter677.write(oprot); + _iter685.write(oprot); } oprot.writeListEnd(); } @@ -416,9 +416,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetLocks()) { { oprot.writeI32(struct.locks.size()); - for (ShowLocksResponseElement _iter678 : struct.locks) + for (ShowLocksResponseElement _iter686 : struct.locks) { - _iter678.write(oprot); + _iter686.write(oprot); } } } @@ -430,14 +430,14 @@ import org.slf4j.LoggerFactory; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list679 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.locks = new ArrayList<ShowLocksResponseElement>(_list679.size); - ShowLocksResponseElement _elem680; - for (int _i681 = 0; _i681 < _list679.size; ++_i681) + org.apache.thrift.protocol.TList _list687 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.locks = new ArrayList<ShowLocksResponseElement>(_list687.size); + ShowLocksResponseElement _elem688; + for (int _i689 = 0; _i689 < _list687.size; ++_i689) { - _elem680 = new ShowLocksResponseElement(); - _elem680.read(iprot); - struct.locks.add(_elem680); + _elem688 = new ShowLocksResponseElement(); + _elem688.read(iprot); + struct.locks.add(_elem688); } } struct.setLocksIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/10cfba20/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java index 9c6ee51..118f9db 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java @@ -708,13 +708,13 @@ import org.slf4j.LoggerFactory; case 3: // INVALID_WRITE_IDS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list626 = iprot.readListBegin(); - struct.invalidWriteIds = new ArrayList<Long>(_list626.size); - long _elem627; - for (int _i628 = 0; _i628 < _list626.size; ++_i628) + org.apache.thrift.protocol.TList _list634 = iprot.readListBegin(); + struct.invalidWriteIds = new ArrayList<Long>(_list634.size); + long _elem635; + for (int _i636 = 0; _i636 < _list634.size; ++_i636) { - _elem627 = iprot.readI64(); - struct.invalidWriteIds.add(_elem627); + _elem635 = iprot.readI64(); + struct.invalidWriteIds.add(_elem635); } iprot.readListEnd(); } @@ -764,9 +764,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(INVALID_WRITE_IDS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.invalidWriteIds.size())); - for (long _iter629 : struct.invalidWriteIds) + for (long _iter637 : struct.invalidWriteIds) { - oprot.writeI64(_iter629); + oprot.writeI64(_iter637); } oprot.writeListEnd(); } @@ -803,9 +803,9 @@ import org.slf4j.LoggerFactory; oprot.writeI64(struct.writeIdHighWaterMark); { oprot.writeI32(struct.invalidWriteIds.size()); - for (long _iter630 : struct.invalidWriteIds) + for (long _iter638 : struct.invalidWriteIds) { - oprot.writeI64(_iter630); + oprot.writeI64(_iter638); } } oprot.writeBinary(struct.abortedBits); @@ -827,13 +827,13 @@ import org.slf4j.LoggerFactory; struct.writeIdHighWaterMark = iprot.readI64(); struct.setWriteIdHighWaterMarkIsSet(true); { - org.apache.thrift.protocol.TList _list631 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.invalidWriteIds = new ArrayList<Long>(_list631.size); - long _elem632; - for (int _i633 = 0; _i633 < _list631.size; ++_i633) + org.apache.thrift.protocol.TList _list639 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.invalidWriteIds = new ArrayList<Long>(_list639.size); + long _elem640; + for (int _i641 = 0; _i641 < _list639.size; ++_i641) { - _elem632 = iprot.readI64(); - struct.invalidWriteIds.add(_elem632); + _elem640 = iprot.readI64(); + struct.invalidWriteIds.add(_elem640); } } struct.setInvalidWriteIdsIsSet(true);
