You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by dj...@apache.org on 2018/05/08 18:42:13 UTC
[08/58] [abbrv] hive git commit: HIVE-18988: Support bootstrap
replication of ACID tables (Sankar Hariappan, reviewed by Mahesh Kumar Behera,
Thejas M Nair)
http://git-wip-us.apache.org/repos/asf/hive/blob/4c0475ff/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
index c7100a7..0a240e0 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
@@ -538,13 +538,13 @@ import org.slf4j.LoggerFactory;
case 2: // FILES_ADDED
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list716 = iprot.readListBegin();
- struct.filesAdded = new ArrayList<String>(_list716.size);
- String _elem717;
- for (int _i718 = 0; _i718 < _list716.size; ++_i718)
+ org.apache.thrift.protocol.TList _list724 = iprot.readListBegin();
+ struct.filesAdded = new ArrayList<String>(_list724.size);
+ String _elem725;
+ for (int _i726 = 0; _i726 < _list724.size; ++_i726)
{
- _elem717 = iprot.readString();
- struct.filesAdded.add(_elem717);
+ _elem725 = iprot.readString();
+ struct.filesAdded.add(_elem725);
}
iprot.readListEnd();
}
@@ -556,13 +556,13 @@ import org.slf4j.LoggerFactory;
case 3: // FILES_ADDED_CHECKSUM
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list719 = iprot.readListBegin();
- struct.filesAddedChecksum = new ArrayList<String>(_list719.size);
- String _elem720;
- for (int _i721 = 0; _i721 < _list719.size; ++_i721)
+ org.apache.thrift.protocol.TList _list727 = iprot.readListBegin();
+ struct.filesAddedChecksum = new ArrayList<String>(_list727.size);
+ String _elem728;
+ for (int _i729 = 0; _i729 < _list727.size; ++_i729)
{
- _elem720 = iprot.readString();
- struct.filesAddedChecksum.add(_elem720);
+ _elem728 = iprot.readString();
+ struct.filesAddedChecksum.add(_elem728);
}
iprot.readListEnd();
}
@@ -593,9 +593,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 _iter722 : struct.filesAdded)
+ for (String _iter730 : struct.filesAdded)
{
- oprot.writeString(_iter722);
+ oprot.writeString(_iter730);
}
oprot.writeListEnd();
}
@@ -606,9 +606,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 _iter723 : struct.filesAddedChecksum)
+ for (String _iter731 : struct.filesAddedChecksum)
{
- oprot.writeString(_iter723);
+ oprot.writeString(_iter731);
}
oprot.writeListEnd();
}
@@ -634,9 +634,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.filesAdded.size());
- for (String _iter724 : struct.filesAdded)
+ for (String _iter732 : struct.filesAdded)
{
- oprot.writeString(_iter724);
+ oprot.writeString(_iter732);
}
}
BitSet optionals = new BitSet();
@@ -653,9 +653,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetFilesAddedChecksum()) {
{
oprot.writeI32(struct.filesAddedChecksum.size());
- for (String _iter725 : struct.filesAddedChecksum)
+ for (String _iter733 : struct.filesAddedChecksum)
{
- oprot.writeString(_iter725);
+ oprot.writeString(_iter733);
}
}
}
@@ -665,13 +665,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 _list726 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.filesAdded = new ArrayList<String>(_list726.size);
- String _elem727;
- for (int _i728 = 0; _i728 < _list726.size; ++_i728)
+ org.apache.thrift.protocol.TList _list734 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.filesAdded = new ArrayList<String>(_list734.size);
+ String _elem735;
+ for (int _i736 = 0; _i736 < _list734.size; ++_i736)
{
- _elem727 = iprot.readString();
- struct.filesAdded.add(_elem727);
+ _elem735 = iprot.readString();
+ struct.filesAdded.add(_elem735);
}
}
struct.setFilesAddedIsSet(true);
@@ -682,13 +682,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list729 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.filesAddedChecksum = new ArrayList<String>(_list729.size);
- String _elem730;
- for (int _i731 = 0; _i731 < _list729.size; ++_i731)
+ org.apache.thrift.protocol.TList _list737 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.filesAddedChecksum = new ArrayList<String>(_list737.size);
+ String _elem738;
+ for (int _i739 = 0; _i739 < _list737.size; ++_i739)
{
- _elem730 = iprot.readString();
- struct.filesAddedChecksum.add(_elem730);
+ _elem738 = iprot.readString();
+ struct.filesAddedChecksum.add(_elem738);
}
}
struct.setFilesAddedChecksumIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4c0475ff/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
index d1134b5..d0dc21c 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
+++ b/standalone-metastore/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 _list642 = iprot.readListBegin();
- struct.component = new ArrayList<LockComponent>(_list642.size);
- LockComponent _elem643;
- for (int _i644 = 0; _i644 < _list642.size; ++_i644)
+ org.apache.thrift.protocol.TList _list650 = iprot.readListBegin();
+ struct.component = new ArrayList<LockComponent>(_list650.size);
+ LockComponent _elem651;
+ for (int _i652 = 0; _i652 < _list650.size; ++_i652)
{
- _elem643 = new LockComponent();
- _elem643.read(iprot);
- struct.component.add(_elem643);
+ _elem651 = new LockComponent();
+ _elem651.read(iprot);
+ struct.component.add(_elem651);
}
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 _iter645 : struct.component)
+ for (LockComponent _iter653 : struct.component)
{
- _iter645.write(oprot);
+ _iter653.write(oprot);
}
oprot.writeListEnd();
}
@@ -803,9 +803,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.component.size());
- for (LockComponent _iter646 : struct.component)
+ for (LockComponent _iter654 : struct.component)
{
- _iter646.write(oprot);
+ _iter654.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 _list647 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.component = new ArrayList<LockComponent>(_list647.size);
- LockComponent _elem648;
- for (int _i649 = 0; _i649 < _list647.size; ++_i649)
+ org.apache.thrift.protocol.TList _list655 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.component = new ArrayList<LockComponent>(_list655.size);
+ LockComponent _elem656;
+ for (int _i657 = 0; _i657 < _list655.size; ++_i657)
{
- _elem648 = new LockComponent();
- _elem648.read(iprot);
- struct.component.add(_elem648);
+ _elem656 = new LockComponent();
+ _elem656.read(iprot);
+ struct.component.add(_elem656);
}
}
struct.setComponentIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4c0475ff/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Materialization.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Materialization.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Materialization.java
index 403c7aa..4e792bc 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Materialization.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Materialization.java
@@ -589,13 +589,13 @@ import org.slf4j.LoggerFactory;
case 1: // TABLES_USED
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set832 = iprot.readSetBegin();
- struct.tablesUsed = new HashSet<String>(2*_set832.size);
- String _elem833;
- for (int _i834 = 0; _i834 < _set832.size; ++_i834)
+ org.apache.thrift.protocol.TSet _set840 = iprot.readSetBegin();
+ struct.tablesUsed = new HashSet<String>(2*_set840.size);
+ String _elem841;
+ for (int _i842 = 0; _i842 < _set840.size; ++_i842)
{
- _elem833 = iprot.readString();
- struct.tablesUsed.add(_elem833);
+ _elem841 = iprot.readString();
+ struct.tablesUsed.add(_elem841);
}
iprot.readSetEnd();
}
@@ -645,9 +645,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TABLES_USED_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, struct.tablesUsed.size()));
- for (String _iter835 : struct.tablesUsed)
+ for (String _iter843 : struct.tablesUsed)
{
- oprot.writeString(_iter835);
+ oprot.writeString(_iter843);
}
oprot.writeSetEnd();
}
@@ -689,9 +689,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.tablesUsed.size());
- for (String _iter836 : struct.tablesUsed)
+ for (String _iter844 : struct.tablesUsed)
{
- oprot.writeString(_iter836);
+ oprot.writeString(_iter844);
}
}
BitSet optionals = new BitSet();
@@ -720,13 +720,13 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, Materialization struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TSet _set837 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tablesUsed = new HashSet<String>(2*_set837.size);
- String _elem838;
- for (int _i839 = 0; _i839 < _set837.size; ++_i839)
+ org.apache.thrift.protocol.TSet _set845 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tablesUsed = new HashSet<String>(2*_set845.size);
+ String _elem846;
+ for (int _i847 = 0; _i847 < _set845.size; ++_i847)
{
- _elem838 = iprot.readString();
- struct.tablesUsed.add(_elem838);
+ _elem846 = iprot.readString();
+ struct.tablesUsed.add(_elem846);
}
}
struct.setTablesUsedIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4c0475ff/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
index baa4224..0c850fa 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
+++ b/standalone-metastore/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 _list708 = iprot.readListBegin();
- struct.events = new ArrayList<NotificationEvent>(_list708.size);
- NotificationEvent _elem709;
- for (int _i710 = 0; _i710 < _list708.size; ++_i710)
+ org.apache.thrift.protocol.TList _list716 = iprot.readListBegin();
+ struct.events = new ArrayList<NotificationEvent>(_list716.size);
+ NotificationEvent _elem717;
+ for (int _i718 = 0; _i718 < _list716.size; ++_i718)
{
- _elem709 = new NotificationEvent();
- _elem709.read(iprot);
- struct.events.add(_elem709);
+ _elem717 = new NotificationEvent();
+ _elem717.read(iprot);
+ struct.events.add(_elem717);
}
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 _iter711 : struct.events)
+ for (NotificationEvent _iter719 : struct.events)
{
- _iter711.write(oprot);
+ _iter719.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.events.size());
- for (NotificationEvent _iter712 : struct.events)
+ for (NotificationEvent _iter720 : struct.events)
{
- _iter712.write(oprot);
+ _iter720.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 _list713 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.events = new ArrayList<NotificationEvent>(_list713.size);
- NotificationEvent _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.events = new ArrayList<NotificationEvent>(_list721.size);
+ NotificationEvent _elem722;
+ for (int _i723 = 0; _i723 < _list721.size; ++_i723)
{
- _elem714 = new NotificationEvent();
- _elem714.read(iprot);
- struct.events.add(_elem714);
+ _elem722 = new NotificationEvent();
+ _elem722.read(iprot);
+ struct.events.add(_elem722);
}
}
struct.setEventsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4c0475ff/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
index ad42dbe..77c260d 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
+++ b/standalone-metastore/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 _list776 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list776.size);
- long _elem777;
- for (int _i778 = 0; _i778 < _list776.size; ++_i778)
+ org.apache.thrift.protocol.TList _list784 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list784.size);
+ long _elem785;
+ for (int _i786 = 0; _i786 < _list784.size; ++_i786)
{
- _elem777 = iprot.readI64();
- struct.fileIds.add(_elem777);
+ _elem785 = iprot.readI64();
+ struct.fileIds.add(_elem785);
}
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 _list779 = iprot.readListBegin();
- struct.metadata = new ArrayList<ByteBuffer>(_list779.size);
- ByteBuffer _elem780;
- for (int _i781 = 0; _i781 < _list779.size; ++_i781)
+ org.apache.thrift.protocol.TList _list787 = iprot.readListBegin();
+ struct.metadata = new ArrayList<ByteBuffer>(_list787.size);
+ ByteBuffer _elem788;
+ for (int _i789 = 0; _i789 < _list787.size; ++_i789)
{
- _elem780 = iprot.readBinary();
- struct.metadata.add(_elem780);
+ _elem788 = iprot.readBinary();
+ struct.metadata.add(_elem788);
}
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 _iter782 : struct.fileIds)
+ for (long _iter790 : struct.fileIds)
{
- oprot.writeI64(_iter782);
+ oprot.writeI64(_iter790);
}
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 _iter783 : struct.metadata)
+ for (ByteBuffer _iter791 : struct.metadata)
{
- oprot.writeBinary(_iter783);
+ oprot.writeBinary(_iter791);
}
oprot.writeListEnd();
}
@@ -651,16 +651,16 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter784 : struct.fileIds)
+ for (long _iter792 : struct.fileIds)
{
- oprot.writeI64(_iter784);
+ oprot.writeI64(_iter792);
}
}
{
oprot.writeI32(struct.metadata.size());
- for (ByteBuffer _iter785 : struct.metadata)
+ for (ByteBuffer _iter793 : struct.metadata)
{
- oprot.writeBinary(_iter785);
+ oprot.writeBinary(_iter793);
}
}
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 _list786 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list786.size);
- long _elem787;
- for (int _i788 = 0; _i788 < _list786.size; ++_i788)
+ org.apache.thrift.protocol.TList _list794 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list794.size);
+ long _elem795;
+ for (int _i796 = 0; _i796 < _list794.size; ++_i796)
{
- _elem787 = iprot.readI64();
- struct.fileIds.add(_elem787);
+ _elem795 = iprot.readI64();
+ struct.fileIds.add(_elem795);
}
}
struct.setFileIdsIsSet(true);
{
- org.apache.thrift.protocol.TList _list789 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.metadata = new ArrayList<ByteBuffer>(_list789.size);
- ByteBuffer _elem790;
- for (int _i791 = 0; _i791 < _list789.size; ++_i791)
+ org.apache.thrift.protocol.TList _list797 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.metadata = new ArrayList<ByteBuffer>(_list797.size);
+ ByteBuffer _elem798;
+ for (int _i799 = 0; _i799 < _list797.size; ++_i799)
{
- _elem790 = iprot.readBinary();
- struct.metadata.add(_elem790);
+ _elem798 = iprot.readBinary();
+ struct.metadata.add(_elem798);
}
}
struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4c0475ff/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java
new file mode 100644
index 0000000..97bb8a4
--- /dev/null
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java
@@ -0,0 +1,952 @@
+/**
+ * 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 ReplTblWriteIdStateRequest implements org.apache.thrift.TBase<ReplTblWriteIdStateRequest, ReplTblWriteIdStateRequest._Fields>, java.io.Serializable, Cloneable, Comparable<ReplTblWriteIdStateRequest> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ReplTblWriteIdStateRequest");
+
+ private static final org.apache.thrift.protocol.TField VALID_WRITE_IDLIST_FIELD_DESC = new org.apache.thrift.protocol.TField("validWriteIdlist", org.apache.thrift.protocol.TType.STRING, (short)1);
+ private static final org.apache.thrift.protocol.TField USER_FIELD_DESC = new org.apache.thrift.protocol.TField("user", org.apache.thrift.protocol.TType.STRING, (short)2);
+ private static final org.apache.thrift.protocol.TField HOST_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("hostName", org.apache.thrift.protocol.TType.STRING, (short)3);
+ private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("dbName", org.apache.thrift.protocol.TType.STRING, (short)4);
+ private static final org.apache.thrift.protocol.TField TABLE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tableName", org.apache.thrift.protocol.TType.STRING, (short)5);
+ private static final org.apache.thrift.protocol.TField PART_NAMES_FIELD_DESC = new org.apache.thrift.protocol.TField("partNames", org.apache.thrift.protocol.TType.LIST, (short)6);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new ReplTblWriteIdStateRequestStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new ReplTblWriteIdStateRequestTupleSchemeFactory());
+ }
+
+ private String validWriteIdlist; // required
+ private String user; // required
+ private String hostName; // required
+ private String dbName; // required
+ private String tableName; // required
+ private List<String> partNames; // 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 {
+ VALID_WRITE_IDLIST((short)1, "validWriteIdlist"),
+ USER((short)2, "user"),
+ HOST_NAME((short)3, "hostName"),
+ DB_NAME((short)4, "dbName"),
+ TABLE_NAME((short)5, "tableName"),
+ PART_NAMES((short)6, "partNames");
+
+ 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: // VALID_WRITE_IDLIST
+ return VALID_WRITE_IDLIST;
+ case 2: // USER
+ return USER;
+ case 3: // HOST_NAME
+ return HOST_NAME;
+ case 4: // DB_NAME
+ return DB_NAME;
+ case 5: // TABLE_NAME
+ return TABLE_NAME;
+ case 6: // PART_NAMES
+ return PART_NAMES;
+ 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 _Fields optionals[] = {_Fields.PART_NAMES};
+ 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.VALID_WRITE_IDLIST, new org.apache.thrift.meta_data.FieldMetaData("validWriteIdlist", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.USER, new org.apache.thrift.meta_data.FieldMetaData("user", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.HOST_NAME, new org.apache.thrift.meta_data.FieldMetaData("hostName", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.DB_NAME, new org.apache.thrift.meta_data.FieldMetaData("dbName", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.TABLE_NAME, new org.apache.thrift.meta_data.FieldMetaData("tableName", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.PART_NAMES, new org.apache.thrift.meta_data.FieldMetaData("partNames", 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))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ReplTblWriteIdStateRequest.class, metaDataMap);
+ }
+
+ public ReplTblWriteIdStateRequest() {
+ }
+
+ public ReplTblWriteIdStateRequest(
+ String validWriteIdlist,
+ String user,
+ String hostName,
+ String dbName,
+ String tableName)
+ {
+ this();
+ this.validWriteIdlist = validWriteIdlist;
+ this.user = user;
+ this.hostName = hostName;
+ this.dbName = dbName;
+ this.tableName = tableName;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public ReplTblWriteIdStateRequest(ReplTblWriteIdStateRequest other) {
+ if (other.isSetValidWriteIdlist()) {
+ this.validWriteIdlist = other.validWriteIdlist;
+ }
+ if (other.isSetUser()) {
+ this.user = other.user;
+ }
+ if (other.isSetHostName()) {
+ this.hostName = other.hostName;
+ }
+ if (other.isSetDbName()) {
+ this.dbName = other.dbName;
+ }
+ if (other.isSetTableName()) {
+ this.tableName = other.tableName;
+ }
+ if (other.isSetPartNames()) {
+ List<String> __this__partNames = new ArrayList<String>(other.partNames);
+ this.partNames = __this__partNames;
+ }
+ }
+
+ public ReplTblWriteIdStateRequest deepCopy() {
+ return new ReplTblWriteIdStateRequest(this);
+ }
+
+ @Override
+ public void clear() {
+ this.validWriteIdlist = null;
+ this.user = null;
+ this.hostName = null;
+ this.dbName = null;
+ this.tableName = null;
+ this.partNames = null;
+ }
+
+ public String getValidWriteIdlist() {
+ return this.validWriteIdlist;
+ }
+
+ public void setValidWriteIdlist(String validWriteIdlist) {
+ this.validWriteIdlist = validWriteIdlist;
+ }
+
+ public void unsetValidWriteIdlist() {
+ this.validWriteIdlist = null;
+ }
+
+ /** Returns true if field validWriteIdlist is set (has been assigned a value) and false otherwise */
+ public boolean isSetValidWriteIdlist() {
+ return this.validWriteIdlist != null;
+ }
+
+ public void setValidWriteIdlistIsSet(boolean value) {
+ if (!value) {
+ this.validWriteIdlist = null;
+ }
+ }
+
+ public String getUser() {
+ return this.user;
+ }
+
+ public void setUser(String user) {
+ this.user = user;
+ }
+
+ public void unsetUser() {
+ this.user = null;
+ }
+
+ /** Returns true if field user is set (has been assigned a value) and false otherwise */
+ public boolean isSetUser() {
+ return this.user != null;
+ }
+
+ public void setUserIsSet(boolean value) {
+ if (!value) {
+ this.user = null;
+ }
+ }
+
+ public String getHostName() {
+ return this.hostName;
+ }
+
+ public void setHostName(String hostName) {
+ this.hostName = hostName;
+ }
+
+ public void unsetHostName() {
+ this.hostName = null;
+ }
+
+ /** Returns true if field hostName is set (has been assigned a value) and false otherwise */
+ public boolean isSetHostName() {
+ return this.hostName != null;
+ }
+
+ public void setHostNameIsSet(boolean value) {
+ if (!value) {
+ this.hostName = null;
+ }
+ }
+
+ public String getDbName() {
+ return this.dbName;
+ }
+
+ public void setDbName(String dbName) {
+ this.dbName = dbName;
+ }
+
+ public void unsetDbName() {
+ this.dbName = null;
+ }
+
+ /** Returns true if field dbName is set (has been assigned a value) and false otherwise */
+ public boolean isSetDbName() {
+ return this.dbName != null;
+ }
+
+ public void setDbNameIsSet(boolean value) {
+ if (!value) {
+ this.dbName = null;
+ }
+ }
+
+ public String getTableName() {
+ return this.tableName;
+ }
+
+ public void setTableName(String tableName) {
+ this.tableName = tableName;
+ }
+
+ public void unsetTableName() {
+ this.tableName = null;
+ }
+
+ /** Returns true if field tableName is set (has been assigned a value) and false otherwise */
+ public boolean isSetTableName() {
+ return this.tableName != null;
+ }
+
+ public void setTableNameIsSet(boolean value) {
+ if (!value) {
+ this.tableName = null;
+ }
+ }
+
+ public int getPartNamesSize() {
+ return (this.partNames == null) ? 0 : this.partNames.size();
+ }
+
+ public java.util.Iterator<String> getPartNamesIterator() {
+ return (this.partNames == null) ? null : this.partNames.iterator();
+ }
+
+ public void addToPartNames(String elem) {
+ if (this.partNames == null) {
+ this.partNames = new ArrayList<String>();
+ }
+ this.partNames.add(elem);
+ }
+
+ public List<String> getPartNames() {
+ return this.partNames;
+ }
+
+ public void setPartNames(List<String> partNames) {
+ this.partNames = partNames;
+ }
+
+ public void unsetPartNames() {
+ this.partNames = null;
+ }
+
+ /** Returns true if field partNames is set (has been assigned a value) and false otherwise */
+ public boolean isSetPartNames() {
+ return this.partNames != null;
+ }
+
+ public void setPartNamesIsSet(boolean value) {
+ if (!value) {
+ this.partNames = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case VALID_WRITE_IDLIST:
+ if (value == null) {
+ unsetValidWriteIdlist();
+ } else {
+ setValidWriteIdlist((String)value);
+ }
+ break;
+
+ case USER:
+ if (value == null) {
+ unsetUser();
+ } else {
+ setUser((String)value);
+ }
+ break;
+
+ case HOST_NAME:
+ if (value == null) {
+ unsetHostName();
+ } else {
+ setHostName((String)value);
+ }
+ break;
+
+ case DB_NAME:
+ if (value == null) {
+ unsetDbName();
+ } else {
+ setDbName((String)value);
+ }
+ break;
+
+ case TABLE_NAME:
+ if (value == null) {
+ unsetTableName();
+ } else {
+ setTableName((String)value);
+ }
+ break;
+
+ case PART_NAMES:
+ if (value == null) {
+ unsetPartNames();
+ } else {
+ setPartNames((List<String>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case VALID_WRITE_IDLIST:
+ return getValidWriteIdlist();
+
+ case USER:
+ return getUser();
+
+ case HOST_NAME:
+ return getHostName();
+
+ case DB_NAME:
+ return getDbName();
+
+ case TABLE_NAME:
+ return getTableName();
+
+ case PART_NAMES:
+ return getPartNames();
+
+ }
+ 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 VALID_WRITE_IDLIST:
+ return isSetValidWriteIdlist();
+ case USER:
+ return isSetUser();
+ case HOST_NAME:
+ return isSetHostName();
+ case DB_NAME:
+ return isSetDbName();
+ case TABLE_NAME:
+ return isSetTableName();
+ case PART_NAMES:
+ return isSetPartNames();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof ReplTblWriteIdStateRequest)
+ return this.equals((ReplTblWriteIdStateRequest)that);
+ return false;
+ }
+
+ public boolean equals(ReplTblWriteIdStateRequest that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_validWriteIdlist = true && this.isSetValidWriteIdlist();
+ boolean that_present_validWriteIdlist = true && that.isSetValidWriteIdlist();
+ if (this_present_validWriteIdlist || that_present_validWriteIdlist) {
+ if (!(this_present_validWriteIdlist && that_present_validWriteIdlist))
+ return false;
+ if (!this.validWriteIdlist.equals(that.validWriteIdlist))
+ return false;
+ }
+
+ boolean this_present_user = true && this.isSetUser();
+ boolean that_present_user = true && that.isSetUser();
+ if (this_present_user || that_present_user) {
+ if (!(this_present_user && that_present_user))
+ return false;
+ if (!this.user.equals(that.user))
+ return false;
+ }
+
+ boolean this_present_hostName = true && this.isSetHostName();
+ boolean that_present_hostName = true && that.isSetHostName();
+ if (this_present_hostName || that_present_hostName) {
+ if (!(this_present_hostName && that_present_hostName))
+ return false;
+ if (!this.hostName.equals(that.hostName))
+ return false;
+ }
+
+ boolean this_present_dbName = true && this.isSetDbName();
+ boolean that_present_dbName = true && that.isSetDbName();
+ if (this_present_dbName || that_present_dbName) {
+ if (!(this_present_dbName && that_present_dbName))
+ return false;
+ if (!this.dbName.equals(that.dbName))
+ return false;
+ }
+
+ boolean this_present_tableName = true && this.isSetTableName();
+ boolean that_present_tableName = true && that.isSetTableName();
+ if (this_present_tableName || that_present_tableName) {
+ if (!(this_present_tableName && that_present_tableName))
+ return false;
+ if (!this.tableName.equals(that.tableName))
+ return false;
+ }
+
+ boolean this_present_partNames = true && this.isSetPartNames();
+ boolean that_present_partNames = true && that.isSetPartNames();
+ if (this_present_partNames || that_present_partNames) {
+ if (!(this_present_partNames && that_present_partNames))
+ return false;
+ if (!this.partNames.equals(that.partNames))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_validWriteIdlist = true && (isSetValidWriteIdlist());
+ list.add(present_validWriteIdlist);
+ if (present_validWriteIdlist)
+ list.add(validWriteIdlist);
+
+ boolean present_user = true && (isSetUser());
+ list.add(present_user);
+ if (present_user)
+ list.add(user);
+
+ boolean present_hostName = true && (isSetHostName());
+ list.add(present_hostName);
+ if (present_hostName)
+ list.add(hostName);
+
+ boolean present_dbName = true && (isSetDbName());
+ list.add(present_dbName);
+ if (present_dbName)
+ list.add(dbName);
+
+ boolean present_tableName = true && (isSetTableName());
+ list.add(present_tableName);
+ if (present_tableName)
+ list.add(tableName);
+
+ boolean present_partNames = true && (isSetPartNames());
+ list.add(present_partNames);
+ if (present_partNames)
+ list.add(partNames);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(ReplTblWriteIdStateRequest other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetValidWriteIdlist()).compareTo(other.isSetValidWriteIdlist());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetValidWriteIdlist()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.validWriteIdlist, other.validWriteIdlist);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetUser()).compareTo(other.isSetUser());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetUser()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.user, other.user);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetHostName()).compareTo(other.isSetHostName());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetHostName()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.hostName, other.hostName);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetDbName()).compareTo(other.isSetDbName());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetDbName()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.dbName, other.dbName);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetTableName()).compareTo(other.isSetTableName());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetTableName()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tableName, other.tableName);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetPartNames()).compareTo(other.isSetPartNames());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetPartNames()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partNames, other.partNames);
+ 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("ReplTblWriteIdStateRequest(");
+ boolean first = true;
+
+ sb.append("validWriteIdlist:");
+ if (this.validWriteIdlist == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.validWriteIdlist);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("user:");
+ if (this.user == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.user);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("hostName:");
+ if (this.hostName == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.hostName);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("dbName:");
+ if (this.dbName == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.dbName);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("tableName:");
+ if (this.tableName == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.tableName);
+ }
+ first = false;
+ if (isSetPartNames()) {
+ if (!first) sb.append(", ");
+ sb.append("partNames:");
+ if (this.partNames == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.partNames);
+ }
+ first = false;
+ }
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetValidWriteIdlist()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'validWriteIdlist' is unset! Struct:" + toString());
+ }
+
+ if (!isSetUser()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'user' is unset! Struct:" + toString());
+ }
+
+ if (!isSetHostName()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'hostName' is unset! Struct:" + toString());
+ }
+
+ if (!isSetDbName()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'dbName' is unset! Struct:" + toString());
+ }
+
+ if (!isSetTableName()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'tableName' 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 {
+ 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 ReplTblWriteIdStateRequestStandardSchemeFactory implements SchemeFactory {
+ public ReplTblWriteIdStateRequestStandardScheme getScheme() {
+ return new ReplTblWriteIdStateRequestStandardScheme();
+ }
+ }
+
+ private static class ReplTblWriteIdStateRequestStandardScheme extends StandardScheme<ReplTblWriteIdStateRequest> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, ReplTblWriteIdStateRequest 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: // VALID_WRITE_IDLIST
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.validWriteIdlist = iprot.readString();
+ struct.setValidWriteIdlistIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // USER
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.user = iprot.readString();
+ struct.setUserIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // HOST_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.hostName = iprot.readString();
+ struct.setHostNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // DB_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.dbName = iprot.readString();
+ struct.setDbNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 5: // TABLE_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.tableName = iprot.readString();
+ struct.setTableNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 6: // PART_NAMES
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list594 = iprot.readListBegin();
+ struct.partNames = new ArrayList<String>(_list594.size);
+ String _elem595;
+ for (int _i596 = 0; _i596 < _list594.size; ++_i596)
+ {
+ _elem595 = iprot.readString();
+ struct.partNames.add(_elem595);
+ }
+ iprot.readListEnd();
+ }
+ struct.setPartNamesIsSet(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, ReplTblWriteIdStateRequest struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.validWriteIdlist != null) {
+ oprot.writeFieldBegin(VALID_WRITE_IDLIST_FIELD_DESC);
+ oprot.writeString(struct.validWriteIdlist);
+ oprot.writeFieldEnd();
+ }
+ if (struct.user != null) {
+ oprot.writeFieldBegin(USER_FIELD_DESC);
+ oprot.writeString(struct.user);
+ oprot.writeFieldEnd();
+ }
+ if (struct.hostName != null) {
+ oprot.writeFieldBegin(HOST_NAME_FIELD_DESC);
+ oprot.writeString(struct.hostName);
+ oprot.writeFieldEnd();
+ }
+ if (struct.dbName != null) {
+ oprot.writeFieldBegin(DB_NAME_FIELD_DESC);
+ oprot.writeString(struct.dbName);
+ oprot.writeFieldEnd();
+ }
+ if (struct.tableName != null) {
+ oprot.writeFieldBegin(TABLE_NAME_FIELD_DESC);
+ oprot.writeString(struct.tableName);
+ oprot.writeFieldEnd();
+ }
+ if (struct.partNames != null) {
+ if (struct.isSetPartNames()) {
+ 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 _iter597 : struct.partNames)
+ {
+ oprot.writeString(_iter597);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class ReplTblWriteIdStateRequestTupleSchemeFactory implements SchemeFactory {
+ public ReplTblWriteIdStateRequestTupleScheme getScheme() {
+ return new ReplTblWriteIdStateRequestTupleScheme();
+ }
+ }
+
+ private static class ReplTblWriteIdStateRequestTupleScheme extends TupleScheme<ReplTblWriteIdStateRequest> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, ReplTblWriteIdStateRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeString(struct.validWriteIdlist);
+ oprot.writeString(struct.user);
+ oprot.writeString(struct.hostName);
+ oprot.writeString(struct.dbName);
+ oprot.writeString(struct.tableName);
+ BitSet optionals = new BitSet();
+ if (struct.isSetPartNames()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.isSetPartNames()) {
+ {
+ oprot.writeI32(struct.partNames.size());
+ for (String _iter598 : struct.partNames)
+ {
+ oprot.writeString(_iter598);
+ }
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, ReplTblWriteIdStateRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.validWriteIdlist = iprot.readString();
+ struct.setValidWriteIdlistIsSet(true);
+ struct.user = iprot.readString();
+ struct.setUserIsSet(true);
+ struct.hostName = iprot.readString();
+ struct.setHostNameIsSet(true);
+ struct.dbName = iprot.readString();
+ struct.setDbNameIsSet(true);
+ struct.tableName = iprot.readString();
+ struct.setTableNameIsSet(true);
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ {
+ org.apache.thrift.protocol.TList _list599 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partNames = new ArrayList<String>(_list599.size);
+ String _elem600;
+ for (int _i601 = 0; _i601 < _list599.size; ++_i601)
+ {
+ _elem600 = iprot.readString();
+ struct.partNames.add(_elem600);
+ }
+ }
+ struct.setPartNamesIsSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/hive/blob/4c0475ff/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java
index 62bc3b4..76dfe17 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java
+++ b/standalone-metastore/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 _list904 = iprot.readListBegin();
- struct.cols = new ArrayList<FieldSchema>(_list904.size);
- FieldSchema _elem905;
- for (int _i906 = 0; _i906 < _list904.size; ++_i906)
+ org.apache.thrift.protocol.TList _list912 = iprot.readListBegin();
+ struct.cols = new ArrayList<FieldSchema>(_list912.size);
+ FieldSchema _elem913;
+ for (int _i914 = 0; _i914 < _list912.size; ++_i914)
{
- _elem905 = new FieldSchema();
- _elem905.read(iprot);
- struct.cols.add(_elem905);
+ _elem913 = new FieldSchema();
+ _elem913.read(iprot);
+ struct.cols.add(_elem913);
}
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 _iter907 : struct.cols)
+ for (FieldSchema _iter915 : struct.cols)
{
- _iter907.write(oprot);
+ _iter915.write(oprot);
}
oprot.writeListEnd();
}
@@ -1323,9 +1323,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetCols()) {
{
oprot.writeI32(struct.cols.size());
- for (FieldSchema _iter908 : struct.cols)
+ for (FieldSchema _iter916 : struct.cols)
{
- _iter908.write(oprot);
+ _iter916.write(oprot);
}
}
}
@@ -1368,14 +1368,14 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TList _list909 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.cols = new ArrayList<FieldSchema>(_list909.size);
- FieldSchema _elem910;
- for (int _i911 = 0; _i911 < _list909.size; ++_i911)
+ org.apache.thrift.protocol.TList _list917 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.cols = new ArrayList<FieldSchema>(_list917.size);
+ FieldSchema _elem918;
+ for (int _i919 = 0; _i919 < _list917.size; ++_i919)
{
- _elem910 = new FieldSchema();
- _elem910.read(iprot);
- struct.cols.add(_elem910);
+ _elem918 = new FieldSchema();
+ _elem918.read(iprot);
+ struct.cols.add(_elem918);
}
}
struct.setColsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4c0475ff/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
index 4e465ac..d7e5132 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
+++ b/standalone-metastore/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 _list684 = iprot.readListBegin();
- struct.compacts = new ArrayList<ShowCompactResponseElement>(_list684.size);
- ShowCompactResponseElement _elem685;
- for (int _i686 = 0; _i686 < _list684.size; ++_i686)
+ org.apache.thrift.protocol.TList _list692 = iprot.readListBegin();
+ struct.compacts = new ArrayList<ShowCompactResponseElement>(_list692.size);
+ ShowCompactResponseElement _elem693;
+ for (int _i694 = 0; _i694 < _list692.size; ++_i694)
{
- _elem685 = new ShowCompactResponseElement();
- _elem685.read(iprot);
- struct.compacts.add(_elem685);
+ _elem693 = new ShowCompactResponseElement();
+ _elem693.read(iprot);
+ struct.compacts.add(_elem693);
}
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 _iter687 : struct.compacts)
+ for (ShowCompactResponseElement _iter695 : struct.compacts)
{
- _iter687.write(oprot);
+ _iter695.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.compacts.size());
- for (ShowCompactResponseElement _iter688 : struct.compacts)
+ for (ShowCompactResponseElement _iter696 : struct.compacts)
{
- _iter688.write(oprot);
+ _iter696.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 _list689 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.compacts = new ArrayList<ShowCompactResponseElement>(_list689.size);
- ShowCompactResponseElement _elem690;
- for (int _i691 = 0; _i691 < _list689.size; ++_i691)
+ org.apache.thrift.protocol.TList _list697 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.compacts = new ArrayList<ShowCompactResponseElement>(_list697.size);
+ ShowCompactResponseElement _elem698;
+ for (int _i699 = 0; _i699 < _list697.size; ++_i699)
{
- _elem690 = new ShowCompactResponseElement();
- _elem690.read(iprot);
- struct.compacts.add(_elem690);
+ _elem698 = new ShowCompactResponseElement();
+ _elem698.read(iprot);
+ struct.compacts.add(_elem698);
}
}
struct.setCompactsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4c0475ff/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
index cfc7f9c..0e1009c 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
+++ b/standalone-metastore/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 _list650 = iprot.readListBegin();
- struct.locks = new ArrayList<ShowLocksResponseElement>(_list650.size);
- ShowLocksResponseElement _elem651;
- for (int _i652 = 0; _i652 < _list650.size; ++_i652)
+ org.apache.thrift.protocol.TList _list658 = iprot.readListBegin();
+ struct.locks = new ArrayList<ShowLocksResponseElement>(_list658.size);
+ ShowLocksResponseElement _elem659;
+ for (int _i660 = 0; _i660 < _list658.size; ++_i660)
{
- _elem651 = new ShowLocksResponseElement();
- _elem651.read(iprot);
- struct.locks.add(_elem651);
+ _elem659 = new ShowLocksResponseElement();
+ _elem659.read(iprot);
+ struct.locks.add(_elem659);
}
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 _iter653 : struct.locks)
+ for (ShowLocksResponseElement _iter661 : struct.locks)
{
- _iter653.write(oprot);
+ _iter661.write(oprot);
}
oprot.writeListEnd();
}
@@ -416,9 +416,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetLocks()) {
{
oprot.writeI32(struct.locks.size());
- for (ShowLocksResponseElement _iter654 : struct.locks)
+ for (ShowLocksResponseElement _iter662 : struct.locks)
{
- _iter654.write(oprot);
+ _iter662.write(oprot);
}
}
}
@@ -430,14 +430,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list655 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.locks = new ArrayList<ShowLocksResponseElement>(_list655.size);
- ShowLocksResponseElement _elem656;
- for (int _i657 = 0; _i657 < _list655.size; ++_i657)
+ org.apache.thrift.protocol.TList _list663 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.locks = new ArrayList<ShowLocksResponseElement>(_list663.size);
+ ShowLocksResponseElement _elem664;
+ for (int _i665 = 0; _i665 < _list663.size; ++_i665)
{
- _elem656 = new ShowLocksResponseElement();
- _elem656.read(iprot);
- struct.locks.add(_elem656);
+ _elem664 = new ShowLocksResponseElement();
+ _elem664.read(iprot);
+ struct.locks.add(_elem664);
}
}
struct.setLocksIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4c0475ff/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
index 40822c6..20f225d 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
+++ b/standalone-metastore/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 _list602 = iprot.readListBegin();
- struct.invalidWriteIds = new ArrayList<Long>(_list602.size);
- long _elem603;
- for (int _i604 = 0; _i604 < _list602.size; ++_i604)
+ org.apache.thrift.protocol.TList _list610 = iprot.readListBegin();
+ struct.invalidWriteIds = new ArrayList<Long>(_list610.size);
+ long _elem611;
+ for (int _i612 = 0; _i612 < _list610.size; ++_i612)
{
- _elem603 = iprot.readI64();
- struct.invalidWriteIds.add(_elem603);
+ _elem611 = iprot.readI64();
+ struct.invalidWriteIds.add(_elem611);
}
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 _iter605 : struct.invalidWriteIds)
+ for (long _iter613 : struct.invalidWriteIds)
{
- oprot.writeI64(_iter605);
+ oprot.writeI64(_iter613);
}
oprot.writeListEnd();
}
@@ -803,9 +803,9 @@ import org.slf4j.LoggerFactory;
oprot.writeI64(struct.writeIdHighWaterMark);
{
oprot.writeI32(struct.invalidWriteIds.size());
- for (long _iter606 : struct.invalidWriteIds)
+ for (long _iter614 : struct.invalidWriteIds)
{
- oprot.writeI64(_iter606);
+ oprot.writeI64(_iter614);
}
}
oprot.writeBinary(struct.abortedBits);
@@ -827,13 +827,13 @@ import org.slf4j.LoggerFactory;
struct.writeIdHighWaterMark = iprot.readI64();
struct.setWriteIdHighWaterMarkIsSet(true);
{
- org.apache.thrift.protocol.TList _list607 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.invalidWriteIds = new ArrayList<Long>(_list607.size);
- long _elem608;
- for (int _i609 = 0; _i609 < _list607.size; ++_i609)
+ org.apache.thrift.protocol.TList _list615 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.invalidWriteIds = new ArrayList<Long>(_list615.size);
+ long _elem616;
+ for (int _i617 = 0; _i617 < _list615.size; ++_i617)
{
- _elem608 = iprot.readI64();
- struct.invalidWriteIds.add(_elem608);
+ _elem616 = iprot.readI64();
+ struct.invalidWriteIds.add(_elem616);
}
}
struct.setInvalidWriteIdsIsSet(true);